pkg/

Package pgflonats provides NATS integration for PostgreSQL replication state management.

Package replicator provides PostgreSQL replication functionality for pg_flo.

Package routing provides message routing capabilities for pg_flo.

Package rules provides filtering and transformation rules for CDC messages.

Package sinks provides various output destinations for processed CDC messages.

Package utils provides common utilities and data structures for pg_flo.

Package worker provides message processing workers for pg_flo.