Versions in this module Expand all Collapse all v2 v2.0.14 Oct 26, 2024 Changes in this version + var ErrBackendNotConfigured = errors.New("Result backend not configured") + var ErrTimeoutReached = errors.New("Timeout reached") + type AsyncResult struct + Signature *tasks.Signature + func NewAsyncResult(signature *tasks.Signature, backend iface.Backend) *AsyncResult + func (asyncResult *AsyncResult) Get(sleepDuration time.Duration) ([]reflect.Value, error) + func (asyncResult *AsyncResult) GetState() *tasks.TaskState + func (asyncResult *AsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error) + func (asyncResult *AsyncResult) Touch() ([]reflect.Value, error) + type ChainAsyncResult struct + func NewChainAsyncResult(tasks []*tasks.Signature, backend iface.Backend) *ChainAsyncResult + func (chainAsyncResult *ChainAsyncResult) Get(sleepDuration time.Duration) ([]reflect.Value, error) + func (chainAsyncResult *ChainAsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error) + type ChordAsyncResult struct + func NewChordAsyncResult(groupTasks []*tasks.Signature, chordCallback *tasks.Signature, ...) *ChordAsyncResult + func (chordAsyncResult *ChordAsyncResult) Get(sleepDuration time.Duration) ([]reflect.Value, error) + func (chordAsyncResult *ChordAsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error)
Go to main page