Versions in this module Expand all Collapse all v0 v0.7.4 May 29, 2018 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)
Go to main page