server

Documentation

Index

• type EphemeralStorage
• type Server
  • func New(log *zap.Logger, options ...ServerOption) *Server
  • func (s *Server) Listen(natsURL string, grpcPort int)
  • func (s *Server) Ready() bool
  • func (s *Server) Shutdown()
• type ServerOption

Types

type EphemeralStorage

type EphemeralStorage struct {
	ServerOption
}

type Server

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

func New

func New(log *zap.Logger, options ...ServerOption) *Server

New creates a new SHAR server. Leave the exporter nil if telemetry is not required

func (*Server) Listen

func (s *Server) Listen(natsURL string, grpcPort int)

Listen starts the GRPC server for both serving requests, and thw GRPC health endpoint.

func (*Server) Ready

func (s *Server) Ready() bool

func (*Server) Shutdown

func (s *Server) Shutdown()

shutdown gracefully shuts down the GRPC server, and requests that

type ServerOption

type ServerOption interface {
	// contains filtered or unexported methods
}