iface

Jul 12, 2018

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)