result

Jul 12, 2018

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)