Versions in this module Expand all Collapse all v1 v1.12.0 Jul 26, 2016 Changes in this version + type GlobalOrchestrator struct + func NewGlobalOrchestrator(store *store.MemoryStore) *GlobalOrchestrator + func (g *GlobalOrchestrator) Run(ctx context.Context) error + func (g *GlobalOrchestrator) Stop() + type ReplicatedOrchestrator struct + func NewReplicatedOrchestrator(store *store.MemoryStore) *ReplicatedOrchestrator + func (r *ReplicatedOrchestrator) Run(ctx context.Context) error + func (r *ReplicatedOrchestrator) Stop() + type RestartSupervisor struct + func NewRestartSupervisor(store *store.MemoryStore) *RestartSupervisor + func (r *RestartSupervisor) Cancel(taskID string) + func (r *RestartSupervisor) CancelAll() + func (r *RestartSupervisor) ClearServiceHistory(serviceID string) + func (r *RestartSupervisor) DelayStart(ctx context.Context, _ store.Tx, oldTask *api.Task, newTaskID string, ...) <-chan struct{} + func (r *RestartSupervisor) Restart(ctx context.Context, tx store.Tx, cluster *api.Cluster, service *api.Service, ...) error + func (r *RestartSupervisor) StartNow(tx store.Tx, taskID string) error + type TaskReaper struct + func NewTaskReaper(store *store.MemoryStore) *TaskReaper + func (tr *TaskReaper) Run() + func (tr *TaskReaper) Stop() + type UpdateSupervisor struct + func NewUpdateSupervisor(store *store.MemoryStore, restartSupervisor *RestartSupervisor) *UpdateSupervisor + func (u *UpdateSupervisor) CancelAll() + func (u *UpdateSupervisor) Update(ctx context.Context, cluster *api.Cluster, service *api.Service, ...) + type Updater struct + func NewUpdater(store *store.MemoryStore, restartSupervisor *RestartSupervisor, ...) *Updater + func (u *Updater) Cancel() + func (u *Updater) Run(ctx context.Context, tasks []*api.Task)
Go to main page