# Functions
HumanReadableResults ...
IsContextType checks to see if the type is a context.Context.
New tries to use reflection to convert the function and arguments into a reflect.Value and prepare it for invocation.
NewChain creates a new chain of tasks to be processed one by one, passing results unless task signatures are set to be immutable.
NewChord creates a new chord (a group of tasks with a single callback to be executed after all tasks in the group has completed).
NewErrRetryTaskLater returns new ErrRetryTaskLater instance.
NewErrUnsupportedType returns new ErrUnsupportedType.
NewFailureTaskState ...
NewGroup creates a new group of tasks to be processed in parallel.
NewPendingTaskState ...
NewReceivedTaskState ...
NewRetryTaskState ...
NewSignature creates a new task signature.
NewStartedTaskState ...
NewSuccessTaskState ...
NewWithSignature is the same as New but injects the signature.
ReflectTaskResults ...
ReflectValue converts interface{} to reflect.Value based on string type.
SignatureFromContext gets the signature from the context.
ValidateTask validates task function using reflection and makes sure it has a proper signature.
# Constants
StateFailure - when processing of the task fails.
StatePending - initial state of a task.
StateReceived - when task is received by a worker.
StateRetry - when failed task has been scheduled for retry.
StateStarted - when the worker starts processing the task.
StateSuccess - when the task is processed successfully.
# Variables
ErrLastReturnValueMustBeError ..
ErrTaskMustBeFunc ...
ErrTaskPanicked ...
ErrTaskReturnsNoValue ...
# Structs
Arg represents a single argument passed to invocation fo a task.
Chain creates a chain of tasks to be executed one after another.
Chord adds an optional callback to the group to be executed after all tasks in the group finished.
ErrRetryTaskLater ...
ErrUnsupportedType ...
Group creates a set of tasks to be executed in parallel.
GroupMeta stores useful metadata about tasks within the same group E.g.
Signature represents a single task invocation.
Task wraps a signature and methods used to reflect task arguments and return values after invoking the task.
TaskResult represents an actual return value of a processed task.
TaskState represents a state of a task.
# Interfaces
Retriable is interface that retriable errors should implement.
# Type aliases
Headers represents the headers which should be used to direct the task.