tasks

Oct 22, 2019

Changes in this version

type Signature

+ DurationMs int64

+ FinishTime *time.Time

+ ReceivedTime *time.Time

+ StartTime *time.Time

+ State string

Jun 24, 2019

Changes in this version

type Signature

+ Kwargs map[string]interface{}

type Task

+ Signature *Signature

Jun 24, 2019

Changes in this version

type Task

+ BugsnagConfig *bugsnag.Configuration

Jan 4, 2019

Changes in this version

type Signature

+ Expires *time.Time

Dec 18, 2018

Changes in this version

type Signature

+ Id string

+ Task string

May 4, 2018

Changes in this version

type TaskState

+ TaskName string

Apr 29, 2018

Changes in this version

type Arg

+ Name string

Apr 5, 2018

Changes in this version

type GroupMeta

+ CreatedAt time.Time

type TaskState

+ CreatedAt time.Time

Mar 4, 2018

Changes in this version

type Headers

+ func (h Headers) ForeachKey(handler func(key, val string) error) error

+ func (h Headers) Set(key, val string)

type Task

+ Context context.Context

Mar 1, 2018

Changes in this version

+ type ErrRetryTaskLater struct

+ func NewErrRetryTaskLater(msg string, retryIn time.Duration) ErrRetryTaskLater

+ func (e ErrRetryTaskLater) Error() string

+ func (e ErrRetryTaskLater) RetryIn() time.Duration

+ type Retriable interface

+ RetryIn func() time.Duration

Nov 15, 2017

Changes in this version

+ func HumanReadableResults(results []reflect.Value) string

+ func ReflectTaskResults(taskResults []*TaskResult) ([]reflect.Value, error)

Aug 27, 2017

Changes in this version

+ const StateFailure

+ const StatePending

+ const StateReceived

+ const StateRetry

+ const StateStarted

+ const StateSuccess

+ var ErrLastReturnValueMustBeError = errors.New("Last return value of a task must be error")

+ var ErrTaskMustBeFunc = errors.New("Task must be a func type")

+ var ErrTaskPanicked = errors.New("Invoking task caused a panic")

+ var ErrTaskReturnsNoValue = errors.New("Taks must return at least a single value")

+ func IsContextType(t reflect.Type) bool

+ func ReflectValue(valueType string, value interface{}) (reflect.Value, error)

+ func ValidateTask(task interface{}) error

+ type Arg struct

+ Type string

+ Value interface{}

+ type Chain struct

+ Tasks []*Signature

+ func NewChain(signatures ...*Signature) *Chain

+ type Chord struct

+ Callback *Signature

+ Group *Group

+ func NewChord(group *Group, callback *Signature) *Chord

+ type ErrUnsupportedType struct

+ func NewErrUnsupportedType(valueType string) ErrUnsupportedType

+ func (e ErrUnsupportedType) Error() string

+ type Group struct

+ GroupUUID string

+ Tasks []*Signature

+ func NewGroup(signatures ...*Signature) *Group

+ func (group *Group) GetUUIDs() []string

+ type GroupMeta struct

+ ChordTriggered bool

+ GroupUUID string

+ Lock bool

+ TaskUUIDs []string

+ type Headers map[string]interface

+ type Signature struct

+ Args []Arg

+ ChordCallback *Signature

+ ETA *time.Time

+ GroupTaskCount int

+ GroupUUID string

+ Headers Headers

+ Immutable bool

+ Name string

+ OnError []*Signature

+ OnSuccess []*Signature

+ RetryCount int

+ RetryTimeout int

+ RoutingKey string

+ UUID string

+ func NewSignature(name string, args []Arg) *Signature

+ type Task struct

+ Args []reflect.Value

+ TaskFunc reflect.Value

+ UseContext bool

+ func New(taskFunc interface{}, args []Arg) (*Task, error)

+ func (t *Task) Call() (taskResults []*TaskResult, err error)

+ func (t *Task) ReflectArgs(args []Arg) error

+ type TaskResult struct

+ Type string

+ Value interface{}

+ type TaskState struct

+ Error string

+ Results []*TaskResult

+ State string

+ TaskUUID string

+ func NewFailureTaskState(signature *Signature, err string) *TaskState

+ func NewPendingTaskState(signature *Signature) *TaskState

+ func NewReceivedTaskState(signature *Signature) *TaskState

+ func NewRetryTaskState(signature *Signature) *TaskState

+ func NewStartedTaskState(signature *Signature) *TaskState

+ func NewSuccessTaskState(signature *Signature, results []*TaskResult) *TaskState

+ func (taskState *TaskState) IsCompleted() bool

+ func (taskState *TaskState) IsFailure() bool

+ func (taskState *TaskState) IsSuccess() bool