reader

Documentation

Index

• type Job
• type Task

Types

type Job

type Job interface {
	plugin.Job

	//根据Job进行切分，将原有任务切分成number个任务，主要以配置文件的形式传递给每个任务
	Split(ctx context.Context, number int) ([]*config.JSON, error)
}

Job 工作

type Task

type Task interface {
	plugin.Task

	//StartRead 开始从sender中读取
	StartRead(ctx context.Context, sender plugin.RecordSender) error
}

Task 任务