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
}

func NewJob

func NewJob() *Job

func (*Job) Destroy

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

type Task

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

Task

func NewTask

func NewTask() *Task

NewTask Create a new task

func (*Task) Destroy

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

Destroy Destroy

func (*Task) Init

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

Init Initialize the task

func (*Task) StartRead

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

StartRead Start reading data and send it to the sender