stdout

type Column struct {
	Name      string           `json:"name"`
	SqlType   string           `json:"sql_type"`
	InnerType byte             `json:"inner_type"`
	Unsigned  bool             `json:"unsigned"`
	Key       schema.IndexType `json:"key"`
	Charset   string           `json:"charset"`
}

type Config struct {
	Encoder string `toml:"encoder"`
}

type Operation struct {
	Header *OperationHeader `json:"header"`

	// NextLogName and NextLogPos field is for Rotate operation
	NextLogName string `json:"next_log_name,omitempty"`
	NextLogPos  uint32 `json:"next_log_pos,omitempty"`

	// Gtid field is for GTID operation
	Gtid string `json:"gtid,omitempty"`

	// Database and Statement filed is for QUERY/DDL operation
	Database  string `json:"database,omitempty"`
	Statement string `json:"statement,omitempty"`

	// Table and Rows field is for INSERT/UPDATE/DELETE operation
	Table *Table `json:"table,omitempty"`
	Rows  []*Row `json:"rows,omitempty"`

	// Progress field is for COMMIT/DDL operation,
	// represents the GTID_SET or file&pos
	Progress *Progress `json:"progress,omitempty"`
	// contains filtered or unexported fields
}

type OperationHeader struct {
	ServerID  uint32        `json:"server_id"`
	Type      OperationType `json:"type"`
	Timestamp uint32        `json:"timestamp"`
	LogPos    uint32        `json:"log_pos"`
}

type OperationType string

type Progress struct {
	Flavor   string `json:"flavor"`
	ServerID uint32 `json:"server_id"`
	LogName  string `json:"log_name"`
	LogPos   uint32 `json:"log_pos"`
	Gset     string `json:"gset"`
}

type Row struct {
	Before []interface{} `json:"before,omitempty"`
	After  []interface{} `json:"after,omitempty"`
}

type StdoutSink struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Table struct {
	Database string    `json:"database"`
	Name     string    `json:"name"`
	Columns  []*Column `json:"columns"`
}