clusterserver

Documentation

Index

• type Config
• type Server
  • func New(cfg Config, localRouter *c2s.LocalRouter, comps *component.Components, ...) *Server
  • func (s *Server) Start(_ context.Context) error
  • func (s *Server) Stop(_ context.Context) error

Types

type Config

type Config struct {
	BindAddr string `fig:"bind_addr"`
	Port     int    `fig:"port" default:"14369"`
}

Config contains Server configuration parameters.

type Server

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

Server represents cluster server type.

func New

func New(
	cfg Config,
	localRouter *c2s.LocalRouter,
	comps *component.Components,
	streamQueueMap *streamqueue.QueueMap,
	logger kitlog.Logger,
) *Server

New returns a new initialized Server instance.

func (*Server) Start

func (s *Server) Start(_ context.Context) error

Start starts cluster server.

func (*Server) Stop

func (s *Server) Stop(_ context.Context) error

Stop stops cluster server.