taskutil

func ActiveDeploymentErrorsByService ¶

func ActiveDeploymentErrorsByService(tasks []swarm.Task) map[string]string

ActiveDeploymentErrorsByService returns serviceID -> error text for services that have at least one slot where an error task is newer than the most recent running task (or where there is no running task for that slot).

Only errors within the last 5 minutes (relative to the newest task in the entire set) are considered, to avoid surfacing stale historical failures. When multiple slots error for the same service, the most recent error wins.

func LatestTasksByServiceKey ¶

func LatestTasksByServiceKey(tasks []swarm.Task) []swarm.Task

LatestTasksByServiceKey returns the most relevant task per slot. Tasks that want to be running are preferred over terminal tasks; within the same tier the most recent task wins.

func TaskKeyForService ¶

func TaskKeyForService(t swarm.Task) string

TaskKeyForService returns a unique key for a task's slot within its service. For replicated services this is serviceID:slot, for global services serviceID:nodeID.

func TaskTimestamp ¶

func TaskTimestamp(t swarm.Task) time.Time

TaskTimestamp returns the effective timestamp for a task, falling back to CreatedAt when Status.Timestamp is zero.