plugin

type BaseJob struct {
	*BasePlugin
	// contains filtered or unexported fields
}

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

type BasePlugin struct {
	*BasePluggable
}

type BaseTask struct {
	*BasePlugin
	// contains filtered or unexported fields
}

type Job interface {
	Plugin
	Collector() JobCollector   //todo 工作采集器目前未使用
	SetCollector(JobCollector) //todo  设置工作采集器目前未使用
}

type JobCollector interface {
	MessageMap() map[string][]string
	MessageByKey(key string) []string
}

type Pluggable interface {
	//插件开发者,一般写入插件配置中
	Developer() (string, error)
	//插件描述,一般写入插件配置中
	Description() (string, error)
	//插件名称,一般写入插件配置中
	PluginName() (string, error)
	/*插件配置，基础配置如下，其余可以根据个性化定制
	{
		"name" : "mysqlreader",
		"developer":"Breeze0806",
		"description":"use github.com/go-sql-driver/mysql. database/sql DB execute select sql, retrieve data from the ResultSet. warn: The more you know about the database, the less problems you encounter."
	}
	*/
	PluginConf() *config.JSON
	//插件工作配置
	PluginJobConf() *config.JSON
	//对应插件名（对于Writer来说就是Reader，对应Reader来说就是Wirter）
	PeerPluginName() string
	//对应插件配置（对于Writer来说就是Reader，对应Reader来说就是Wirter）
	PeerPluginJobConf() *config.JSON
	//设置工作插件
	SetPluginJobConf(conf *config.JSON)
	//设置对应插件配置（对于Writer来说就是Reader，对应Reader来说就是Wirter）
	SetPeerPluginJobConf(conf *config.JSON)
	//设置对应插件名（对于Writer来说就是Reader，对应Reader来说就是Wirter）
	SetPeerPluginName(name string)
	//设置插件配置
	SetPluginConf(conf *config.JSON)
	//初始化插件，需要实现者个性化实现
	Init(ctx context.Context) error
	//销毁插件，需要实现者个性化实现
	Destroy(ctx context.Context) error
}

type Plugin interface {
	Pluggable
	//预检查，在数据库中用于检查权限
	PreCheck(ctx context.Context) error
	//准备
	Prepare(ctx context.Context) error
	//后置通知
	Post(ctx context.Context) error
	//预备处理， todo当前未用到
	PreHandler(ctx context.Context, conf *config.JSON) error
	//后置通知处理， todo当前未用到
	PostHandler(ctx context.Context, conf *config.JSON) error
}

type RecordReceiver interface {
	GetFromReader() (element.Record, error) //从reader中读取记录
	Shutdown() error                        // 关闭
}

type RecordSender interface {
	CreateRecord() (element.Record, error)  //创建记录
	SendWriter(record element.Record) error //将记录发往写入器
	Flush() error                           //将记录刷新到记录发送器
	Terminate() error                       //终止发送信号
	Shutdown() error                        //关闭
}

type Task interface {
	Plugin

	//任务信息收集器，todo 未使用
	TaskCollector() TaskCollector
	//设置任务信息收集器，todo 未使用
	SetTaskCollector(collector TaskCollector)

	//工作ID
	JobID() int64
	//设置工作ID
	SetJobID(jobID int64)
	//任务组ID
	TaskGroupID() int64
	//设置任务组ID
	SetTaskGroupID(taskGroupID int64)
	//任务ID
	TaskID() int64
	//设置任务ID
	SetTaskID(taskID int64)
	//包裹错误
	Wrapf(err error, format string, args ...interface{}) error
	//Format 日志格式
	Format(format string) string
}

type TaskCollector interface {
	CollectDirtyRecordWithError(record element.Record, err error)
	CollectDirtyRecordWithMsg(record element.Record, msgErr string)
	CollectDirtyRecord(record element.Record, err error, msgErr string)
	CollectMessage(key string, value string)
}

type Type string