grpc

Documentation

Index

• type Server
  • func NewServer(fs ...ServerOpt) (*Server, error)
  • func (s *Server) Start() (func() error, error)
• type ServerOpt
  • func WithAdmin(a admin.AdminService) ServerOpt
  • func WithAlerter(a errors.Alerter) ServerOpt
  • func WithAnalytics(a analytics.Analytics) ServerOpt
  • func WithBindAddress(bindAddress string) ServerOpt
  • func WithConfig(config *server.ServerConfig) ServerOpt
  • func WithDispatcher(d dispatcher.Dispatcher) ServerOpt
  • func WithIngestor(i ingestor.Ingestor) ServerOpt
  • func WithInsecure() ServerOpt
  • func WithLogger(l *zerolog.Logger) ServerOpt
  • func WithPort(port int) ServerOpt
  • func WithTLSConfig(tls *tls.Config) ServerOpt
• type ServerOpts

Types

type Server

type Server struct {
	eventcontracts.UnimplementedEventsServiceServer
	dispatchercontracts.UnimplementedDispatcherServer
	admincontracts.UnimplementedWorkflowServiceServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(fs ...ServerOpt) (*Server, error)

func (*Server) Start

func (s *Server) Start() (func() error, error)

type ServerOpt

type ServerOpt func(*ServerOpts)

func WithAdmin

func WithAdmin(a admin.AdminService) ServerOpt

func WithAlerter

func WithAlerter(a errors.Alerter) ServerOpt

func WithAnalytics

func WithAnalytics(a analytics.Analytics) ServerOpt

func WithBindAddress

func WithBindAddress(bindAddress string) ServerOpt

func WithConfig

func WithConfig(config *server.ServerConfig) ServerOpt

func WithDispatcher

func WithDispatcher(d dispatcher.Dispatcher) ServerOpt

func WithIngestor

func WithIngestor(i ingestor.Ingestor) ServerOpt

func WithInsecure

func WithInsecure() ServerOpt

func WithLogger

func WithLogger(l *zerolog.Logger) ServerOpt

func WithPort

func WithPort(port int) ServerOpt

func WithTLSConfig

func WithTLSConfig(tls *tls.Config) ServerOpt

type ServerOpts

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