Versions in this module Expand all Collapse all v2 v2.0.15 Aug 4, 2024 Changes in this version + type Backend interface + GetState func(taskUUID string) (*tasks.TaskState, error) + GroupCompleted func(groupUUID string, groupTaskCount int) (bool, error) + GroupTaskStates func(groupUUID string, groupTaskCount int) ([]*tasks.TaskState, error) + InitGroup func(groupUUID string, taskUUIDs []string) error + IsAMQP func() bool + PurgeGroupMeta func(groupUUID string) error + PurgeState func(taskUUID string) error + SetStateFailure func(signature *tasks.Signature, err string) error + SetStatePending func(signature *tasks.Signature) error + SetStateReceived func(signature *tasks.Signature) error + SetStateRetry func(signature *tasks.Signature) error + SetStateStarted func(signature *tasks.Signature) error + SetStateSuccess func(signature *tasks.Signature, results []*tasks.TaskResult) error + TriggerChord func(groupUUID string) (bool, error)
Go to main page