Versions in this module Expand all Collapse all v1 v1.0.1 Mar 17, 2026 Changes in this version type TaskActionBase + AwaitData TaskActionAwaitData v1.0.0 Mar 11, 2026 Changes in this version + const TaskActionAwaitTypeNone + const TaskActionAwaitTypeNormal + const TaskActionAwaitTypeRPC + var SocketUrl string + func AwaitTask(other TaskActionImpl) error + type TaskActionAwaitData struct + WaitingId uint64 + WaitingType uint32 + type TaskActionBase struct + AwaitChannel chan *TaskActionResumeData + Impl TaskActionImpl + Name string + TaskId uint64 + Timeout *time.Timer + func NewTaskActionBase(timeoutDuration time.Duration, name string) *TaskActionBase + func (t *TaskActionBase) AfterYield() + func (t *TaskActionBase) AwaitTask(other TaskActionImpl) error + func (t *TaskActionBase) BeforeYield() + func (t *TaskActionBase) Finish(result error) + func (t *TaskActionBase) GetTaskId() uint64 + func (t *TaskActionBase) GetTimeoutDuration() time.Duration + func (t *TaskActionBase) InitOnFinish(fn func(error)) + func (t *TaskActionBase) InitTaskId(id uint64) + func (t *TaskActionBase) InitTimeoutTimer(timer *time.Timer) + func (t *TaskActionBase) Kill() + func (t *TaskActionBase) Resume(awaitData *TaskActionAwaitData, resumeData *TaskActionResumeData) + func (t *TaskActionBase) TimeoutKill() + func (t *TaskActionBase) Yield(awaitData TaskActionAwaitData) *TaskActionResumeData + type TaskActionImpl interface + AfterYield func() + AwaitTask func(TaskActionImpl) error + BeforeYield func() + Finish func(error) + GetTaskId func() uint64 + GetTimeoutDuration func() time.Duration + HookRun func() error + InitOnFinish func(func(error)) + InitTaskId func(uint64) + InitTimeoutTimer func(*time.Timer) + Kill func() + Log func(format string, a ...any) + TimeoutKill func() + type TaskActionManager struct + func NewTaskActionManager() *TaskActionManager + func (m *TaskActionManager) CloseAll() + func (m *TaskActionManager) RunTaskAction(taskAction TaskActionImpl) + func (m *TaskActionManager) WaitAll() + type TaskActionResumeData struct + Data interface{} + Err error
Go to main page