server

type Announce interface {
	// Do the announcement
	// Usually here advertise config is renewed
	// Unblocking. Run periodically
	Advertise([]net.IP) error
	// Stop announcement
	// Usually here advertise config is deleted
	Withdraw() error
}

type Checker interface {
	// Check is a method which performs basic validations that responder is alive
	Check() error

	// IncListeners atomically add 1 to the counter
	IncListeners()
	// IncWorkers atomically add 1 to the counter
	IncWorkers()

	// DecListeners atomically removes 1 from the counter
	DecListeners()
	// DecWorkers atomically removes 1 from the counter
	DecWorkers()
}

type Config struct {
	ExtraOffset    time.Duration
	Iface          string
	IPs            MultiIPs
	ManageLoopback bool
	MonitoringPort int
	Port           int
	RefID          string
	ShouldAnnounce bool
	Stratum        int
	TimestampType  timestamp.Timestamp
	Workers        int
	// contains filtered or unexported fields
}

type MultiIPs []net.IP

type Server struct {
	Config   Config
	Announce Announce
	Stats    Stats
	Checker  Checker
	// contains filtered or unexported fields
}

type Stats interface {
	// Start starts a stat reporter
	// Use this for passive reporters
	Start(int)

	// IncInvalidFormat atomically add 1 to the counter
	IncInvalidFormat()
	// IncRequests atomically add 1 to the counter
	IncRequests()
	// IncResponses atomically add 1 to the counter
	IncResponses()
	// IncListeners atomically add 1 to the counter
	IncListeners()
	// IncWorkers atomically add 1 to the counter
	IncWorkers()
	// IncReadError atomically add 1 to the counter
	IncReadError()

	// DecListeners atomically removes 1 from the counter
	DecListeners()
	// DecWorkers atomically removes 1 from the counter
	DecWorkers()

	// SetAnnounce atomically sets counter to 1
	SetAnnounce()
	// ResetAnnounce atomically sets counter to 0
	ResetAnnounce()
}