tidb_cdc

type CDCSchema struct {
	Database string                 `json:"database"` // 数据库
	Table    string                 `json:"table"`    // 表
	Type     CDCType                `json:"type"`     // delete, insert, update
	Ts       int                    `json:"ts"`       // 时间
	Data     map[string]interface{} `json:"data"`
	Old      map[string]interface{} `json:"old"`
}

type CDCType string

type Configuration struct {
	// 基础Kafka信息
	KafkaConfig KafkaConfiguration
	// 对应初版中的 TopicPrefix，由于需要支持一个 connector 监控多个库，
	// 故改为 connector server name，database name 当作参数传入
	ServerName string
	// default: 1
	NumberOfConsumers int
	// default: 2.1.1
	KafkaVersion string
	// default: range
	Assignor string
	// only read latest message in topics
	Oldest  bool
	Verbose bool
}

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

type Consumer struct {
	Typ              reflect.Type
	ConsumerHandlers []ConsumerHandler
	// contains filtered or unexported fields
}

type ConsumerGroup struct {
	// 反序列化类型信息
	Typ     reflect.Type
	Brokers []string
	Topic   string
	// 实际消费消息方法
	ConsumerHandlers []ConsumerHandler
	NumOfConsumers   int

	Version  string
	Group    string
	Assignor string
	Oldest   bool
	Verbose  bool
}

type ConsumerHandler interface {
	Create(after interface{}) error
	Update(before interface{}, after interface{}) error
	Delete(before interface{}) error
}

type HandlerFunc func(before, after interface{}) error

type KafkaConfiguration struct {
	Brokers    []string
	User       string
	Password   string
	EnableSASL bool
}

type Message struct {
	After  *json.RawMessage `json:"after"`
	Before *json.RawMessage `json:"before"`
	Op     string           `json:"op"`
}

type RegistrationHelper struct {
	DBName    string
	TableName string
	Model     interface{}
	Handlers  []ConsumerHandler
}