server

Documentation

Index

• type Server
  • func NewServer(cfg *config.ServerConfig, logger hclog.Logger) *Server
  • func (s *Server) FailedNotify() <-chan struct{}
  • func (s *Server) OnAdminEvent(ctx context.Context, request *eventlistener.AdminEventRequest) (*shared.Empty, error)
  • func (s *Server) OnEvent(ctx context.Context, request *eventlistener.EventRequest) (*shared.Empty, error)
  • func (s *Server) ReadyNotify() <-chan struct{}
  • func (s *Server) Start()
  • func (s *Server) StartFailureReason() error
  • func (s *Server) Stop()
  • func (s *Server) StoppedNotify() <-chan struct{}

Types

type Server

type Server struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer(cfg *config.ServerConfig, logger hclog.Logger) *Server

func (*Server) FailedNotify

func (s *Server) FailedNotify() <-chan struct{}

FailedNotify returns a channel that will be closed when the server has failed to start.

func (*Server) OnAdminEvent

func (s *Server) OnAdminEvent(ctx context.Context, request *eventlistener.AdminEventRequest) (*shared.Empty, error)

OnAdminEvent is the implementation of the OnAdminEvent protobuf service.

func (*Server) OnEvent

func (s *Server) OnEvent(ctx context.Context, request *eventlistener.EventRequest) (*shared.Empty, error)

OnEvent is the implementation of the OnEvent protobuf service.

func (*Server) ReadyNotify

func (s *Server) ReadyNotify() <-chan struct{}

ReadyNotify returns a channel that will be closed when the server is ready to serve client requests.

func (*Server) Start

func (s *Server) Start()

func (*Server) StartFailureReason

func (s *Server) StartFailureReason() error

StartFailureReason returns an error which caused the server not to start.

func (*Server) Stop

func (s *Server) Stop()

Stop stops the server, if the server is started.

func (*Server) StoppedNotify

func (s *Server) StoppedNotify() <-chan struct{}

StoppedNotify returns a channel that will be closed when the server has stopped.