atsf4g_go_robot_protocol_base

Documentation

Index

• Constants
• Variables
• func AwaitTask(other TaskActionImpl) error
• type TaskActionAwaitData
• type TaskActionBase
  • 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
• type TaskActionManager
  • func NewTaskActionManager() *TaskActionManager
  • func (m *TaskActionManager) CloseAll()
  • func (m *TaskActionManager) RunTaskAction(taskAction TaskActionImpl)
  • func (m *TaskActionManager) WaitAll()
• type TaskActionResumeData

Constants

const (
	TaskActionAwaitTypeNone = iota
	TaskActionAwaitTypeNormal
	TaskActionAwaitTypeRPC
)

Variables

var SocketUrl string

Functions

func AwaitTask

func AwaitTask(other TaskActionImpl) error

Types

type TaskActionAwaitData

type TaskActionAwaitData struct {
	WaitingType uint32
	WaitingId   uint64
}

type TaskActionBase

type TaskActionBase struct {
	Impl   TaskActionImpl
	Name   string
	TaskId uint64

	AwaitData    TaskActionAwaitData
	AwaitChannel chan *TaskActionResumeData

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

func NewTaskActionBase

func NewTaskActionBase(timeoutDuration time.Duration, name string) *TaskActionBase

func (*TaskActionBase) AfterYield

func (t *TaskActionBase) AfterYield()

func (*TaskActionBase) AwaitTask

func (t *TaskActionBase) AwaitTask(other TaskActionImpl) error

func (*TaskActionBase) BeforeYield

func (t *TaskActionBase) BeforeYield()

func (*TaskActionBase) Finish

func (t *TaskActionBase) Finish(result error)

func (*TaskActionBase) GetTaskId

func (t *TaskActionBase) GetTaskId() uint64

func (*TaskActionBase) GetTimeoutDuration

func (t *TaskActionBase) GetTimeoutDuration() time.Duration

func (*TaskActionBase) InitOnFinish

func (t *TaskActionBase) InitOnFinish(fn func(error))

func (*TaskActionBase) InitTaskId

func (t *TaskActionBase) InitTaskId(id uint64)

func (*TaskActionBase) InitTimeoutTimer

func (t *TaskActionBase) InitTimeoutTimer(timer *time.Timer)

func (*TaskActionBase) Kill

func (t *TaskActionBase) Kill()

func (*TaskActionBase) Resume

func (t *TaskActionBase) Resume(awaitData *TaskActionAwaitData, resumeData *TaskActionResumeData)

func (*TaskActionBase) TimeoutKill

func (t *TaskActionBase) TimeoutKill()

func (*TaskActionBase) Yield

func (t *TaskActionBase) Yield(awaitData TaskActionAwaitData) *TaskActionResumeData

type TaskActionImpl

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

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

func NewTaskActionManager

func NewTaskActionManager() *TaskActionManager

func (*TaskActionManager) CloseAll

func (m *TaskActionManager) CloseAll()

func (*TaskActionManager) RunTaskAction

func (m *TaskActionManager) RunTaskAction(taskAction TaskActionImpl)

func (*TaskActionManager) WaitAll

func (m *TaskActionManager) WaitAll()

type TaskActionResumeData

type TaskActionResumeData struct {
	Err  error
	Data interface{}
}