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 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(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 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
}