cdc

type Connection interface {
	Read(b []byte) (n int, err error)
	Write(b []byte) (n int, err error)
	Close() error
}

type Dialer interface {
	Dial(ctx context.Context) (Connection, error)
}

type GTID struct {
	Domain   uint32 `json:"domain"`
	ServerId uint32 `json:"server_id"`
	Sequence uint64 `json:"sequence"`
}

type GTIDExtractor interface {
	Parse(line []byte) (*GTID, error)
}

type GTIDStore interface {
	Read() (*GTID, error)
	Write(gtid *GTID) error
}

type KafkaSender interface {
	Send(ctx context.Context, ch <-chan []byte) error
}

type MaxscaleReader struct {
	Dialer   Dialer
	User     string
	Password string
	UUID     string
	Format   string // JSON or AVRO
	Database string
	Table    string
	Version  string
}

type Reader interface {
	// Read changes and send them to the given channel
	Read(ctx context.Context, gtid *GTID, ch chan<- []byte) error
}

type RetryReader interface {
	Read(ctx context.Context, gtid *GTID, outch chan<- []byte) error
}

type Sender interface {
	Send(ctx context.Context, ch <-chan []byte) error
}

type Streamer interface {
	Run(ctx context.Context) error
}

type TcpDialer interface {
	Dial(ctx context.Context) (Connection, error)
}