Documentation ¶
Index ¶
- type ChainTask
- func (t *ChainTask) Cancel(ctx context.Context, execCtx tasks.ExecutionContext) error
- func (t *ChainTask) GetMetadata(ctx context.Context, taskID string) (proto.Message, error)
- func (t *ChainTask) GetResponse() proto.Message
- func (t *ChainTask) Load(request, state []byte) error
- func (t *ChainTask) Run(ctx context.Context, execCtx tasks.ExecutionContext) error
- func (t *ChainTask) Save() ([]byte, error)
- type PanicTask
- func (t *PanicTask) Cancel(ctx context.Context, execCtx tasks.ExecutionContext) error
- func (t *PanicTask) GetMetadata(ctx context.Context, taskID string) (proto.Message, error)
- func (t *PanicTask) GetResponse() proto.Message
- func (t *PanicTask) Load(request, state []byte) error
- func (t *PanicTask) Run(ctx context.Context, execCtx tasks.ExecutionContext) error
- func (t *PanicTask) Save() ([]byte, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChainTask ¶
type ChainTask struct {
// contains filtered or unexported fields
}
func NewChainTask ¶
func (*ChainTask) GetMetadata ¶
func (*ChainTask) GetResponse ¶
type PanicTask ¶
type PanicTask struct{}
func NewPanicTask ¶
func NewPanicTask() *PanicTask
func (*PanicTask) GetMetadata ¶
func (*PanicTask) GetResponse ¶
Click to show internal directories.
Click to hide internal directories.