driver

type ConnFun interface {
	GetConnStatus() string
	SetConnStatus(status string)
	Connect() bool
	ReConnect() bool
	HeartCheck()
	Close() bool
	Insert(data *PluginDataType) (*PluginBinlog, error) //binlog位点，处理了多少条数据,错误信息
	Update(data *PluginDataType) (*PluginBinlog, error)
	Del(data *PluginDataType) (*PluginBinlog, error)
	Query(data *PluginDataType) (*PluginBinlog, error)
	SetParam(p interface{}) (interface{}, error)
	Commit() (*PluginBinlog, error)
}

type Driver interface {
	Open(uri string) ConnFun
	GetUriExample() string
	CheckUri(uri string) error
}

type DriverStructure struct {
	Version        string // 插件版本
	BifrostVersion string // 插件开发所使用的Bifrost的版本
	Error          string
	ExampleConnUri string
	// contains filtered or unexported fields
}

type PluginBinlog struct {
	BinlogFileNum  int
	BinlogPosition uint32
}

type PluginDataType struct {
	Timestamp      uint32
	EventType      string
	Rows           []map[string]interface{}
	Query          string
	SchemaName     string
	TableName      string
	BinlogFileNum  int
	BinlogPosition uint32
	Pri            []*string
}

type ToPluginParam struct {
	FromPluginBinlogChan chan PluginBinlog
}