file

Documentation

Index

• type Job
  • func NewJob() *Job
  • func (j *Job) Destroy(ctx context.Context) (err error)
• type Task
  • func NewTask() *Task
  • func (t *Task) Destroy(ctx context.Context) (err error)
  • func (t *Task) Init(ctx context.Context) (err error)
  • func (t *Task) StartRead(ctx context.Context, sender plugin.RecordSender) (err error)

Types

type Job

type Job struct {
	*plugin.BaseJob
}

Job 工作

func NewJob

func NewJob() *Job

NewJob 新建

func (*Job) Destroy

func (j *Job) Destroy(ctx context.Context) (err error)

Destroy 销毁

type Task

type Task struct {
	*plugin.BaseTask
	// contains filtered or unexported fields
}

Task 任务

func NewTask

func NewTask() *Task

NewTask 新建任务

func (*Task) Destroy

func (t *Task) Destroy(ctx context.Context) (err error)

Destroy 销毁

func (*Task) Init

func (t *Task) Init(ctx context.Context) (err error)

Init 初始化任务

func (*Task) StartRead

func (t *Task) StartRead(ctx context.Context, sender plugin.RecordSender) (err error)

StartRead 开启读取数据发往sender