server

package
v0.0.0-...-9aa8380 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 11, 2022 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL