internal

Documentation

Index

• Constants
• func NewServer(logger hclog.Logger) pub.PublisherServer
• type Server
  • func (s *Server) Connect(ctx context.Context, req *pub.ConnectRequest) (*pub.ConnectResponse, error)
  • func (s *Server) Disconnect(context.Context, *pub.DisconnectRequest) (*pub.DisconnectResponse, error)
  • func (s *Server) DiscoverShapes(ctx context.Context, req *pub.DiscoverShapesRequest) (*pub.DiscoverShapesResponse, error)
  • func (s *Server) PublishStream(req *pub.PublishRequest, stream pub.Publisher_PublishStreamServer) error
• type Settings
  • func (s *Settings) GetConnectionString() (string, error)
  • func (s *Settings) Validate() error
• type SettingsForm
• type SettingsStrategy
• type SettingsStringWithPassword

Constants

const StrategyForm = SettingsStrategy("Form")

const StrategyStringWithPassword = SettingsStrategy("Connection String")

Functions

func NewServer

func NewServer(logger hclog.Logger) pub.PublisherServer

NewServer creates a new publisher Host.

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

func (*Server) Connect

func (s *Server) Connect(ctx context.Context, req *pub.ConnectRequest) (*pub.ConnectResponse, error)

func (*Server) Disconnect

func (s *Server) Disconnect(context.Context, *pub.DisconnectRequest) (*pub.DisconnectResponse, error)

func (*Server) DiscoverShapes

func (s *Server) DiscoverShapes(ctx context.Context, req *pub.DiscoverShapesRequest) (*pub.DiscoverShapesResponse, error)

func (*Server) PublishStream

func (s *Server) PublishStream(req *pub.PublishRequest, stream pub.Publisher_PublishStreamServer) error

type Settings

type Settings struct {
	Strategy           SettingsStrategy            `json:"strategy"`
	Form               *SettingsForm               `json:"form"`
	StringWithPassword *SettingsStringWithPassword `json:"stringWithPassword"`
}

func (*Settings) GetConnectionString

func (s *Settings) GetConnectionString() (string, error)

func (*Settings) Validate

func (s *Settings) Validate() error

Validate returns an error if the Settings are not valid. It also populates the internal fields of settings.

type SettingsForm

type SettingsForm struct {
	Hostname    string `json:"hostname"`
	Port        int    `json:"port"`
	ServiceName string `json:"serviceName"`
	Username    string `json:"username"`
	Password    string `json:"password"`
}

type SettingsStrategy

type SettingsStrategy string

type SettingsStringWithPassword

type SettingsStringWithPassword struct {
	ConnectionString string `json:"connectionString"`
	Password         string `json:"password"`
}