server

Documentation

Index

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

Functions

func EphemeralStorage

func EphemeralStorage() ephemeralStorageOption

Types

type Option

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

type Server

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

func New

func New(log *zap.Logger, options ...Option) *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