Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Orchestrator ¶
type Orchestrator struct {
// contains filtered or unexported fields
}
An Orchestrator runs a reconciliation loop to create and destroy tasks as necessary for the replicated services.
func NewReplicatedOrchestrator ¶
func NewReplicatedOrchestrator(store *store.MemoryStore) *Orchestrator
NewReplicatedOrchestrator creates a new replicated Orchestrator.
func (*Orchestrator) FixTask ¶
FixTask validates a task with the current cluster settings, and takes action to make it conformant. it's called at orchestrator initialization.
func (*Orchestrator) IsRelatedService ¶
func (r *Orchestrator) IsRelatedService(service *api.Service) bool
IsRelatedService returns true if the service should be governed by this orchestrator
Click to show internal directories.
Click to hide internal directories.