applier

type ApplierConfig struct {
	KafkaBrokerList string
	KafkaTopic      string
	KafkaPartition  int
	KafkaVersion    string
	KafkaOffset     int64
	// MySQL 配置
	MysqlHost           string
	MysqlPort           int
	MysqlUser           string
	MysqlPasswd         string
	MysqlCharset        string
	MysqlConnectTimeout int
	MysqlReadTimeout    int
	MysqlWriteTimeout   int
	MysqlWaitTimeout    int
	// 冲突处理
	HandleConflictStrategy string
	//时间冲突处理比较字段
	UpdateTimeColumn string
	// 是否允许DDL
	AllowDDL bool
	// 最大消费速率, kb/s
	MaxRate int
	// 乱序pkg数量累计一定程度后的告警阈值
	IncontinuousRdpPkgThreshold int
	// 慢事务的时间阈值
	SlowTrxThreshold int
}

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

type ApplyProgress struct {
	// 已经成功执行的offset
	Offset         int64  `json:"kafka_offset"`
	Gtid           string `json:"gtid"`
	Position       uint64 `json:"binlog_file_position"`
	BinlogFileName string `json:"binlog_file_name"`
}

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

type Column struct {
	// 名称
	Name string
	// int, varchar, blob等
	Type       string
	BinlogType ColumnType
	// 内容
	Value interface{}
	// 是否为pk
	IsPk bool
	// 是否为NULL
	IsNull bool
}

type ColumnType byte

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

type Event struct {
	DatabaseName string
	TableName    string
	EventType    EventType
	// 数据库的binlog时间
	Timestamp uint64
	// RDP处理binlog的时间
	TimestampOfReceipt uint64
	// 在binlog文件中的位置
	Position uint64
	// 下一条binlog的位置
	NextPosition uint64
	// binlog文件名
	BinlogFileName string
	ServerId       uint64
	// Query对应的SQL语句
	SqlStatement string
	Rows         []*Row
}

type EventType uint32

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

type ExecResult struct {
	Err error  `json:"-"`
	Msg string `json:"msg"`
	Trx *Trx   `json:"trx"`
}

type ExecutableSQL struct {
	Query string
	Args  []interface{}

	TrxGtid        string
	TrxBeginOffset int64

	EventType    EventType
	DatabaseName string
	TableName    string
	RowValue     *Row
}

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

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

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

type RdpPkg struct {
	rdp_messages.KafkaPkg
	Topic  string
	Offset int64
}

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

type Row struct {
	// Delete情况下，只有before
	Before []*Column
	// Insert情况下，只有after
	// Update情况下，before和after成对出现
	After []*Column
}

type StrategyType string

type Trx struct {
	// kafka topic
	Topic string `json:"topic"`
	// kafka offset
	BeginOffset int64 `json:"begin_offset"`
	EndOffset   int64 `json:"end_offset"`
	// LwmOffset 表示该kafka offset之前(含)的事务都已经执行过
	LwmOffset int64 `json:"lwm_offset"`

	Gtid string `json:"gtid"`
	// 一个Gtid范围内，有过多的event时，导致拆包的序列号，从0、1、2...
	Seq uint64 `json:"-"`
	// 在binlog文件中的位置
	Position uint64 `json:"position"`
	// binlog文件名
	BinlogFileName string `json:"binlog_file_name"`
	// 下一条binlog的位置
	NextPosition uint64 `json:"-"`
	// binlog文件名
	NextBinlogFileName string `json:"-"`
	// 组提交id
	LastCommitted  int64 `json:"last_committed"`
	SequenceNumber int64 `json:"sequence_number"`

	// 事务产生的时间，取自GTID
	Timestamp uint64 `json:"timestamp"`

	// 重试次数
	RetryTimes uint32 `json:"retry_times"`

	Events []*Event `json:"events"`
	// contains filtered or unexported fields
}

type ValueComparisonSign string