ha

type BackupFn func(context.Context, *sql.DB, io.Writer) error

type CDCPublisher interface {
	Publish(cs *ChangeSet) error
}

type CDCSubscriber interface {
	Start() error
	LatestSeq() uint64
	RemoveConsumer(ctx context.Context, name string) error
	DeliveredInfo(ctx context.Context, name string) (any, error)
}

type Change struct {
	Database  string   `json:"database,omitempty"`
	Table     string   `json:"table,omitempty"`
	Columns   []string `json:"columns,omitempty"`
	Operation string   `json:"operation"` // "INSERT", "UPDATE", "DELETE", "SQL", "CUSTOM"
	OldRowID  int64    `json:"old_rowid,omitempty"`
	NewRowID  int64    `json:"new_rowid,omitempty"`
	OldValues []any    `json:"old_values,omitempty"`
	NewValues []any    `json:"new_values,omitempty"`
	Command   string   `json:"command,omitempty"`
	Args      []any    `json:"args,omitempty"`
}

type ChangeSet struct {
	Node      string   `json:"node"`
	ProcessID int64    `json:"process_id"`
	Filename  string   `json:"filename"`
	Changes   []Change `json:"changes"`
	Timestamp int64    `json:"timestamp_ns"`
	StreamSeq uint64   `json:"-"`
	// contains filtered or unexported fields
}

type ChangeSetInterceptor interface {
	BeforeApply(*ChangeSet, *sql.Conn) (skip bool, err error)
	AfterApply(*ChangeSet, *sql.Conn, error) error
}

type ChangeSetSerializer func(*ChangeSet) ([]byte, error)

type ConnHooksFactory func(nodeName string, filename string, disableDDSSync bool, publisher CDCPublisher) ConnHooksProvider

type ConnHooksProvider interface {
	RegisterHooks(driver.Conn) (driver.Conn, error)
	DisableHooks(*sql.Conn) error
	EnableHooks(*sql.Conn) error
}

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

type DBSnapshotter interface {
	TakeSnapshot(ctx context.Context, db *sql.DB) (sequence uint64, err error)
	LatestSnapshot(ctx context.Context) (sequence uint64, reader io.ReadCloser, err error)
}

type DriverProvider interface {
	driver.Driver
	ConnWithoutHooks() (*sql.Conn, error)
	EnableHooks(conn *sql.Conn)
	OnConnect(c driver.Conn) (driver.Conn, error)
}

type EmbeddedNatsConfig struct {
	Name       string
	Port       int
	StoreDir   string
	User       string
	Pass       string
	File       string
	EnableLogs bool
}

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

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

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

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

type NoopPublisher struct{}

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

type NoopSubscriber struct{}

type Option func(*Connector)

type SequenceProvider interface {
	LatestSeq() uint64
}

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

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