binlog

type Binlog struct {
	Position mysql.Position `json:"position"`
}

type CDCChange struct {
	Stream    types.StreamInterface
	Timestamp time.Time
	Position  mysql.Position
	Kind      string
	Schema    string
	Table     string
	Data      map[string]interface{}
}

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

type Config struct {
	ServerID        uint32
	Flavor          string
	Host            string
	Port            uint16
	User            string
	Password        string
	Charset         string
	VerifyChecksum  bool
	HeartbeatPeriod time.Duration
	InitialWaitTime time.Duration
	SSHClient       *ssh.Client
}

type Connection struct {
	CurrentPos mysql.Position // Current binlog position
	ServerID   uint32
	// contains filtered or unexported fields
}

type OnChange func(change CDCChange) error