Documentation
¶
Index ¶
- Variables
- type AsyncResult
- func (asyncResult *AsyncResult) Get(sleepDuration time.Duration) ([]reflect.Value, error)
- func (asyncResult *AsyncResult) GetState() *task.Status
- func (asyncResult *AsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error)
- func (asyncResult *AsyncResult) Monitor() ([]reflect.Value, error)
- type ChainAsyncResult
- type GroupCallbackAsyncResult
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrBackendEmpty = errors.New("backend is empty")
ErrBackendEmpty ...
Functions ¶
This section is empty.
Types ¶
type AsyncResult ¶
type AsyncResult struct {
Signature *task.Signature // Signature 任务签名
// contains filtered or unexported fields
}
AsyncResult 异步结果
func NewAsyncResult ¶
func NewAsyncResult(signature *task.Signature, backend backend.Backend) *AsyncResult
NewAsyncResult 创建异步任务返回结果
func (*AsyncResult) GetState ¶
func (asyncResult *AsyncResult) GetState() *task.Status
GetState 获取任务状态
func (*AsyncResult) GetWithTimeout ¶
func (asyncResult *AsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error)
GetWithTimeout 返回结果 带有超时时间
type ChainAsyncResult ¶
type ChainAsyncResult struct {
// contains filtered or unexported fields
}
ChainAsyncResult 链式调用任务结果返回
func NewChainAsyncResult ¶
func NewChainAsyncResult(chainAsyncResult []*task.Signature, backend backend.Backend) *ChainAsyncResult
NewChainAsyncResult 创建链式调用任务返回结果
func (*ChainAsyncResult) GetWithTimeout ¶
func (chainAsyncResult *ChainAsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error)
GetWithTimeout 返回结果 带有超时时间
type GroupCallbackAsyncResult ¶
type GroupCallbackAsyncResult struct {
// contains filtered or unexported fields
}
GroupCallbackAsyncResult 具有回调任务的个任务组异步结果
func NewGroupCallbackAsyncResult ¶
func NewGroupCallbackAsyncResult(groupAsyncResult []*task.Signature, callbackAsyncResult *task.Signature, backend backend.Backend) *GroupCallbackAsyncResult
NewGroupCallbackAsyncResult 创建具有回调任务组的异步返回结果
func (*GroupCallbackAsyncResult) Get ¶
func (groupCallbackAsyncResult *GroupCallbackAsyncResult) Get(sleepDuration time.Duration) ([]reflect.Value, error)
Get 返回结果
func (*GroupCallbackAsyncResult) GetWithTimeout ¶
func (groupCallbackAsyncResult *GroupCallbackAsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error)
GetWithTimeout 返回结果 带有超时时间
Source Files
Click to show internal directories.
Click to hide internal directories.