record

type Record struct {
	ID       string         // Source-assigned logical ID
	Data     map[string]any // Column/field values (normalized)
	Metadata RecordMetadata
}

type RecordMetadata struct {
	SourceTable   string
	SourceDB      string
	PartitionID   string
	Offset        any      // Logical offset (e.g., PK value, ctid, or cursor position)
	Checksum      [32]byte // SHA-256 of Data bytes
	IngestionTime time.Time
}