wal

type BucketAssigner interface {
	AssignBuckets(ctx context.Context, table string, recordID string, operation synchro.Operation, data map[string]any) ([]string, error)
}

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

type ConsumerConfig struct {
	// ConnString is the PostgreSQL connection string with replication=database.
	ConnString string

	// SlotName is the replication slot name.
	SlotName string

	// PublicationName is the publication to subscribe to.
	PublicationName string

	// Registry is used to look up table configurations.
	Registry *synchro.Registry

	// Assigner determines bucket IDs for changed records.
	Assigner BucketAssigner

	// ChangelogDB writes entries to sync sidecar tables and persists WAL position.
	ChangelogDB synchro.DB

	// Logger for consumer events.
	Logger *slog.Logger

	// StandbyTimeout is how often to send standby status updates.
	// Defaults to 10 seconds.
	StandbyTimeout time.Duration
}

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

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

type WALEvent struct {
	TableName string
	RecordID  string
	Operation synchro.Operation
	Data      map[string]any
}