atsf4g_go_robot_protocol_base

type TaskActionAwaitData struct {
	WaitingType uint32
	WaitingId   uint64
}

type TaskActionBase struct {
	Impl   TaskActionImpl
	Name   string
	TaskId uint64

	AwaitData    TaskActionAwaitData
	AwaitChannel chan *TaskActionResumeData

	Timeout *time.Timer
	// contains filtered or unexported fields
}

type TaskActionImpl interface {
	AwaitTask(TaskActionImpl) error
	InitOnFinish(func(error))
	GetTaskId() uint64
	BeforeYield()
	AfterYield()
	Finish(error)
	InitTaskId(uint64)
	GetTimeoutDuration() time.Duration
	InitTimeoutTimer(*time.Timer)
	TimeoutKill()
	Kill()
	HookRun() error
	Log(format string, a ...any)
}

type TaskActionManager struct {
	// contains filtered or unexported fields
}

type TaskActionResumeData struct {
	Err  error
	Data interface{}
}