syncserver

Documentation

Index

• Constants
• Variables
• type BreadcrumbProvider
• type Config
  • func (c *Config) ApplyDefaults()
  • func (c *Config) ListenPort() int
• type Server
  • func New(caches map[syncproto.SyncerType]BreadcrumbProvider, config Config) *Server
  • func (s *Server) Port() int
  • func (s *Server) SetMaxConns(numConns int)
  • func (s *Server) Start(cxt context.Context)

Constants

const (
	PortRandom = -1
)

Variables

var (
	ErrReadFailed               = errors.New("Failed to read from client")
	ErrUnexpectedClientMsg      = errors.New("Unexpected message from client")
	ErrUnsupportedClientFeature = errors.New("Unsupported client feature")
)

Types

type BreadcrumbProvider

type BreadcrumbProvider interface {
	CurrentBreadcrumb() *snapcache.Breadcrumb
}

type Config

type Config struct {
	Port                    int
	MaxMessageSize          int
	MaxFallBehind           time.Duration
	MinBatchingAgeThreshold time.Duration
	PingInterval            time.Duration
	PongTimeout             time.Duration
	DropInterval            time.Duration
	MaxConns                int
	HealthAggregator        *health.HealthAggregator
	KeyFile                 string
	CertFile                string
	CAFile                  string
	ClientCN                string
	ClientURISAN            string
}

func (*Config) ApplyDefaults

func (c *Config) ApplyDefaults()

func (*Config) ListenPort

func (c *Config) ListenPort() int

type Server

type Server struct {
	Finished sync.WaitGroup
	// contains filtered or unexported fields
}

func New

func New(caches map[syncproto.SyncerType]BreadcrumbProvider, config Config) *Server

func (*Server) Port

func (s *Server) Port() int

func (*Server) SetMaxConns

func (s *Server) SetMaxConns(numConns int)

func (*Server) Start

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