postgres

type Config struct {
	CommonConfig          *common.CommonConfig
	DestinationSchemaName string

	SyncMode                    SyncMode
	DatabaseUrl                 string
	IncludeTables               common.Set[string]
	ExcludeTables               common.Set[string]
	CursorColumnNameByTableName map[string]string  // Incremental sync
	ReplicationSlot             string             // CDC sync
	IgnoreUpdateColumns         common.Set[string] // CDC sync
	Nats                        NatsConfig         // CDC sync
}

type DebeziumData struct {
	Operation string `json:"op"`
}

type DebeziumOperation string

type DebeziumRowData struct {
	Operation string                 `json:"op"`
	Before    map[string]interface{} `json:"before"`
	After     map[string]interface{} `json:"after"`
	Source    DebeziumRowSource      `json:"source"`
}

type DebeziumRowSource struct {
	Schema        string `json:"schema"`
	Table         string `json:"table"`
	CommittedAtNs int64  `json:"ts_ns"`
	Position      int64  `json:"lsn"`
}

type Nats struct {
	Config *Config
}

type NatsConfig struct {
	Url                 string
	Stream              string
	Subject             string
	ConsumerName        string
	FetchTimeoutSeconds int
}

type PgSchemaColumn struct {
	ColumnName          string
	DataType            string
	UdtName             string
	IsNullable          string
	OrdinalPosition     string
	NumericPrecision    string
	NumericScale        string
	DatetimePrecision   string
	Namespace           string
	IsPartOfUniqueIndex bool
	Config              *Config
}

type PgSchemaTable struct {
	Schema                 string
	Table                  string
	ParentPartitionedTable string
}

type Postgres struct {
	PostgresClient *common.PostgresClient
	Config         *Config
}

type SyncMode string

type Syncer struct {
	Config       *Config
	Utils        *SyncerUtils
	StorageS3    *common.StorageS3
	DuckdbClient *common.DuckdbClient
}

type SyncerFullRefresh struct {
	Config       *Config
	Utils        *SyncerUtils
	StorageS3    *common.StorageS3
	DuckdbClient *common.DuckdbClient
}

type SyncerUtils struct {
	Config       *Config
	StorageS3    *common.StorageS3
	DuckdbClient *common.DuckdbClient
}