postgres

type CDCConfig struct {
	SourceID             string                    `json:"source_id" yaml:"source_id"`
	SourceType           string                    `json:"source_type" yaml:"source_type"`
	ConnectionString     string                    `json:"connection_string" yaml:"connection_string"`
	SlotName             string                    `json:"slot_name" yaml:"slot_name"`
	PublicationName      string                    `json:"publication_name" yaml:"publication_name"`
	Plugin               string                    `json:"plugin" yaml:"plugin"`
	CreateSlot           bool                      `json:"create_slot" yaml:"create_slot"`
	Tables               []string                  `json:"tables" yaml:"tables"`
	Operations           []string                  `json:"operations" yaml:"operations"` // INSERT, UPDATE, DELETE
	SchemaMapping        map[string]string         `json:"schema_mapping" yaml:"schema_mapping"`
	StartLSN             string                    `json:"start_lsn" yaml:"start_lsn"`
	BatchSize            int                       `json:"batch_size" yaml:"batch_size"`
	HeartbeatIntervalSec int                       `json:"heartbeat_interval_sec" yaml:"heartbeat_interval_sec"`
	BufferSize           int                       `json:"buffer_size" yaml:"buffer_size"`
	PollInterval         time.Duration             `json:"poll_interval" yaml:"poll_interval"`
	MaxChanges           int                       `json:"max_changes" yaml:"max_changes"`
	Transforms           []adapters.Transformation `json:"transforms" yaml:"transforms"`
}

type CDCFactory struct{}

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

type ChangeEvent struct {
	Operation string                 `json:"operation"`
	Schema    string                 `json:"schema"`
	Table     string                 `json:"table"`
	Before    map[string]interface{} `json:"before,omitempty"`
	After     map[string]interface{} `json:"after,omitempty"`
	LSN       string                 `json:"lsn"`
	Timestamp time.Time              `json:"timestamp"`
	TxID      uint32                 `json:"tx_id"`
}

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

type PollerConfig struct {
	ConnectionString string      `json:"connection_string" yaml:"connection_string"`
	Query            string      `json:"query" yaml:"query"`
	IntervalSeconds  int         `json:"interval_seconds" yaml:"interval_seconds"`
	TimestampColumn  string      `json:"timestamp_column" yaml:"timestamp_column"`
	TieBreakColumn   string      `json:"tie_break_column" yaml:"tie_break_column"`
	ProcessedLedger  string      `json:"processed_ledger_table" yaml:"processed_ledger_table"`
	StartTimestamp   string      `json:"start_timestamp" yaml:"start_timestamp"`
	StartTieBreak    interface{} `json:"start_tie_break" yaml:"start_tie_break"`
	SchemaName       string      `json:"schema_name" yaml:"schema_name"`
	MaxRows          int         `json:"max_rows" yaml:"max_rows"`
}

type PostgresPollerFactory struct{}

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