corn

type CornConf struct {
	Expression string `json:"expression"` // corn表达式

	Type                string `json:"type"`                  // 数据库类型
	Host                string `json:"host"`                  // 数据库地址
	Username            string `json:"username"`              // 用户名
	Password            string `json:"password"`              // 密码
	DB                  string `json:"db"`                    // 库名称
	Schema              string `json:"schema"`                // schema
	Table               string `json:"table"`                 // 表名称
	Column              string `json:"column"`                // 字段名称
	IDColumnName        string `json:"id_column_name"`        // id字段名称
	TimestampColumnName string `json:"timestamp_column_name"` // 时间字段名称
}

type SyncConf struct {
	DBOptions   *options.DBOptions
	Brokers     []string
	RedisConfig redis.RedisConf
	Sources     []*CornConf
}

type SyncMessage struct {
	Data      any    `json:"data"` // 变更后的数据
	Source    source `json:"source"`
	Operation string `json:"op"`    // 变更类型 u更新 c新建 d删除
	TimeStamp int64  `json:"ts_ms"` // 变更时间 毫秒时间戳
}

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