global

Documentation

Index

• type Orchestrator
  • func NewGlobalOrchestrator(store *store.MemoryStore) *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()

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

func (g *Orchestrator) FixTask(ctx context.Context, batch *store.Batch, t *api.Task)

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.

func (*Orchestrator) Stop

func (g *Orchestrator) Stop()

Stop stops the orchestrator.