task

package

v1.0.2 Latest Latest Go to latest Published: Jul 9, 2024 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Task 运行中的任务代理 goroutine safe

func NewTask(dbTask *model.AsyncTask, asyncTask async_task.ITask, log async_config.Logger) *Task

func (t *Task) CheckStop() bool

func (t *Task) Deleting(ctx context.Context) (<-chan async_task.IReport, error)

func (t *Task) ID() uint32

func (t *Task) InitCtx() string

func (t *Task) Running(ctx context.Context) (<-chan async_task.IReport, error)

func (t *Task) SendStop() error