taskinit

Documentation

Index

• func CheckTasks(ctx context.Context, s *store.MemoryStore, readTx store.ReadTx, ...) error
• type InitHandler

Functions

func CheckTasks

func CheckTasks(ctx context.Context, s *store.MemoryStore, readTx store.ReadTx, initHandler InitHandler, startSupervisor *restart.Supervisor) error

CheckTasks fixes tasks in the store before orchestrator runs. The previous leader might not have finished processing their updates and left them in an inconsistent state.

Types

type InitHandler

type InitHandler interface {
	IsRelatedService(service *api.Service) bool
	FixTask(ctx context.Context, batch *store.Batch, t *api.Task)
	SlotTuple(t *api.Task) orchestrator.SlotTuple
}

InitHandler defines orchestrator's action to fix tasks at start.