orchestrator

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

type Config interface {
	IsEnabled() bool
	SetEnabled(v bool) Config
	GetReplicas() int
	SetReplicas(n int) Config
	GetFreq() Freq
	SetFreq(freq Freq) Config
	Clone() Config
}

type Freq interface {
	IsRateLimitDefined() bool
	IsTickFreqDefined() bool
	GetRateLimit() int
	SetRateLimit(new int) Freq
	GetTickFreq() time.Duration
	SetTickFreq(new time.Duration) Freq
	Clone() Freq
}

type Governor interface {
	Register(name string, s Service)
	Cfg(name string) (Config, error)
	On(name string) error
	Off(name string) error
	Start(name string) error
	Reload(name string, cfg Config) error
	ScaleTo(name string, n int) error
	Stop()
}

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

type Service interface {
	Name() string
	Cfg() Config
	Replicas() int
	Serve(t Transport)
	Transport() Transport
}

type Transport interface {
	Start() (sigSent bool)
	Ping() (sigSent bool) // orchestrator -> ping -> worker
	Pong() (sigSent bool) // worker -> pong -> orchestrator
	On() (sigSent bool)
	Off() (sigSent bool)
	Reload(cfg Config) (sigSent bool)
	ScaleTo(n int) (sigSent bool)
	Stop() (sigSent bool)
	IsClosed() bool
	Close() error

	OnStart() <-chan struct{}
	OnPing() <-chan struct{}
	OnPong() <-chan struct{}
	OnOn() <-chan struct{}
	OnOff() <-chan struct{}
	OnReload() <-chan Config
	OnScaleTo() <-chan int
	OnStop() <-chan struct{}
}