package replicated

import "github.com/moby/swarmkit/v2/manager/orchestrator/replicated"

Index ¶

• type Orchestrator
• func NewReplicatedOrchestrator(store *store.MemoryStore) *Orchestrator
• func (r *Orchestrator) FixTask(ctx context.Context, batch *store.Batch, t *api.Task)
• func (r *Orchestrator) IsRelatedService(service *api.Service) bool
• func (r *Orchestrator) Run(ctx context.Context) error
• func (r *Orchestrator) SlotTuple(t *api.Task) orchestrator.SlotTuple
• func (r *Orchestrator) Stop()

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 ¶

func (r *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. 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

func (*Orchestrator) Run ¶

func (r *Orchestrator) Run(ctx context.Context) error

Run contains the orchestrator event loop. It runs until Stop is called.

func (*Orchestrator) SlotTuple ¶

func (r *Orchestrator) SlotTuple(t *api.Task) orchestrator.SlotTuple

SlotTuple returns a slot tuple for the replicated service task.

func (*Orchestrator) Stop ¶

func (r *Orchestrator) Stop()

Stop stops the orchestrator.

Source Files ¶

replicated.go services.go slot.go tasks.go