pkg/

Package config owns the siphon configuration structs and their loaders.

Package consistency compares a PostgreSQL table against the table it replicates into, ClickHouse or PostgreSQL, and reports the key ranges where the two disagree.

Package failover implements durable buffering of CDC events when NATS is unavailable.

Package keyrange tiles a PostgreSQL primary-key space into half-open ranges, the last of which can close at its end.

Package natslock provides a TTL-renewed distributed mutex over a NATS KV bucket.

Package objectstorage provides a pluggable abstraction for storing CDC event blobs in durable storage.

Package pgschema reads table shape out of the PostgreSQL catalogs.

Package retention provides the consumer-aware dynamic MaxAge loop.

Package s3client builds the single *s3.Client shape shared by every S3 integration in Siphon (object storage, Parquet filesystem), so credential and endpoint handling live in one place.

Package schema – helmgen.go generates Helm values fragments from SSOT table definition YAML files (e.g.

Package snowflake opens key-pair (JWT) authenticated connections to Snowflake for the Snowflake sink consumer.

Package snowflakereconciler periodically verifies that each configured Snowflake log table and its current-state Dynamic Table match what the sink expects and that the Dynamic Table refreshes healthily.

Package testutil holds container fixtures shared across test packages.