syncserver

Aug 16, 2017

Changes in this version

+ const PortRandom

+ var ErrReadFailed = errors.New("Failed to read from client")

+ var ErrUnexpectedClientMsg = errors.New("Unexpected message from client")

+ type BreadcrumbProvider interface

+ CurrentBreadcrumb func() *snapcache.Breadcrumb

+ type Config struct

+ DropInterval time.Duration

+ HealthAggregator *health.HealthAggregator

+ MaxConns int

+ MaxFallBehind time.Duration

+ MaxMessageSize int

+ MinBatchingAgeThreshold time.Duration

+ PingInterval time.Duration

+ PongTimeout time.Duration

+ Port int

+ func (c *Config) ApplyDefaults()

+ func (c *Config) ListenPort() int

+ type Server struct

+ Finished sync.WaitGroup

+ func New(cache BreadcrumbProvider, config Config) *Server

+ func (s *Server) Port() int

+ func (s *Server) SetMaxConns(numConns int)

+ func (s *Server) Start(cxt context.Context)