grpc

Documentation

Index

• type Server
  • func NewServer(fs ...ServerOpt) (*Server, error)
  • func (s *Server) Start(ctx context.Context) error
• type ServerOpt
  • func WithAdmin(a admin.AdminService) ServerOpt
  • func WithBindAddress(bindAddress string) ServerOpt
  • func WithDispatcher(d dispatcher.Dispatcher) ServerOpt
  • func WithIngestor(i ingestor.Ingestor) 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(ctx context.Context) error

type ServerOpt

type ServerOpt func(*ServerOpts)

func WithAdmin

func WithAdmin(a admin.AdminService) ServerOpt

func WithBindAddress

func WithBindAddress(bindAddress string) ServerOpt

func WithDispatcher

func WithDispatcher(d dispatcher.Dispatcher) ServerOpt

func WithIngestor

func WithIngestor(i ingestor.Ingestor) 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
}