Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tasks

package

Go to main page

Versions in this module

v2

v2.0.13

Mar 19, 2024

v2.0.12

Jan 10, 2024

v2.0.11

Apr 13, 2021

v2.0.10

Feb 23, 2021

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("Task must return at least a single value")

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

+ func IsContextType(t reflect.Type) bool

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

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

+ func ValidateTask(task interface{}) error

+ type Arg struct

+ Name string

+ Type string

+ Value interface{}

+ type Chain struct

+ Tasks []*Signature

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

+ type Chord struct

+ Callback *Signature

+ Group *Group

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

+ type ErrRetryTaskLater struct

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

+ func (e ErrRetryTaskLater) Error() string

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

+ 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, error)

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

+ type GroupMeta struct

+ ChordTriggered bool

+ CreatedAt time.Time

+ GroupUUID string

+ Lock bool

+ TTL int64

+ TaskUUIDs []string

+ type Headers map[string]interface

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

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

+ type Retriable interface

+ RetryIn func() time.Duration

+ type Signature struct

+ Args []Arg

+ BrokerMessageGroupId string

+ ChordCallback *Signature

+ ETA *time.Time

+ GroupTaskCount int

+ GroupUUID string

+ Headers Headers

+ IgnoreWhenTaskNotRegistered bool

+ Immutable bool

+ Name string

+ OnError []*Signature

+ OnSuccess []*Signature

+ Priority uint8

+ RetryCount int

+ RetryTimeout int

+ RoutingKey string

+ SQSReceiptHandle string

+ StopTaskDeletionOnError bool

+ UUID string

+ func CopySignature(signature *Signature) *Signature

+ func CopySignatures(signatures ...*Signature) []*Signature

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

+ func SignatureFromContext(ctx context.Context) *Signature

+ type Task struct

+ Args []reflect.Value

+ Context context.Context

+ TaskFunc reflect.Value

+ UseContext bool

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

+ func NewWithSignature(taskFunc interface{}, signature *Signature) (*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

+ CreatedAt time.Time

+ Error string

+ Results []*TaskResult

+ State string

+ TTL int64

+ TaskName 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