Documentation
¶
Index ¶
- type Orchestrator
- func (g *Orchestrator) FixTask(ctx context.Context, batch *store.Batch, t *api.Task)
- func (g *Orchestrator) IsRelatedService(service *api.Service) bool
- func (g *Orchestrator) Run(ctx context.Context) error
- func (g *Orchestrator) SlotTuple(t *api.Task) orchestrator.SlotTuple
- func (g *Orchestrator) Stop()
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
}
Orchestrator runs a reconciliation loop to create and destroy tasks as necessary for global services.
func NewGlobalOrchestrator ¶
func NewGlobalOrchestrator(store *store.MemoryStore) *Orchestrator
NewGlobalOrchestrator creates a new global Orchestrator
func (*Orchestrator) FixTask ¶
FixTask validates a task with the current cluster settings, and takes action to make it conformant to node state and service constraint it's called at orchestrator initialization
func (*Orchestrator) IsRelatedService ¶
func (g *Orchestrator) IsRelatedService(service *api.Service) bool
IsRelatedService returns true if the service should be governed by this orchestrator
func (*Orchestrator) Run ¶
func (g *Orchestrator) Run(ctx context.Context) error
Run contains the global orchestrator event loop
func (*Orchestrator) SlotTuple ¶
func (g *Orchestrator) SlotTuple(t *api.Task) orchestrator.SlotTuple
SlotTuple returns a slot tuple for the global service task.
Source Files
Click to show internal directories.
Click to hide internal directories.