server

Documentation

Index

• type Server
  • func NewServer(conf *config.Config, logger log.Logger) (*Server, error)
  • func (s *Server) ClusterState() *cluster.State
  • func (s *Server) Config() *config.Config
  • func (s *Server) Shutdown()
  • func (s *Server) Start() error
  • func (s *Server) Wait(ctx context.Context) bool

Types

type Server

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

Server is a Piko server node.

func NewServer

func NewServer(conf *config.Config, logger log.Logger) (*Server, error)

NewServer creates a server node with the given configuration.

This loads the server configuration and open the server TCP listens, though won't start accepting traffic.

func (*Server) ClusterState

func (s *Server) ClusterState() *cluster.State

func (*Server) Config

func (s *Server) Config() *config.Config

func (*Server) Shutdown

func (s *Server) Shutdown()

Shutdown gracefully stops the server node.

func (*Server) Start

func (s *Server) Start() error

Start starts the Piko node.

func (*Server) Wait

func (s *Server) Wait(ctx context.Context) bool

Wait waits for the server to be shutdown, either due to the given context being cancelled or a fatal error in the server. Returns whether the server exited due to being gracefully shutdown or a fatal error.