orchestrator

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

type Config interface {
	GetEnabled() bool
	GetReplicas() int
	SetReplicas(n int)
	GetLimitOrInterval() int64
}

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

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

type Scalable interface {
	ScaleTo(n int) error
	Replicas() int
}

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

type ServiceState struct {
	Name           string
	State          State
	DesiredEnabled bool
	DesiredInst    int
	Active         bool
	Instances      int
	Failures       int
	LastError      string
	LastCheck      time.Time
	Uptime         time.Duration
	CfgHash        string
}

type State int32

type Transport interface {
	Start(cfg Config) (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 Config
	OnPing() <-chan struct{}
	OnPong() <-chan struct{}
	OnOn() <-chan struct{}
	OnOff() <-chan struct{}
	OnReload() <-chan Config
	OnScaleTo() <-chan int
	OnStop() <-chan struct{}
}