Cleanup drops the provided replication slot and publication.

NewCDCIterator initializes logical replication by creating the publication and subscription manager.

NewCombinedIterator will initialize and start the Snapshot and CDC iterators.

Config holds configuration values for CDCIterator.

CDCHandler is responsible for handling logical replication messages, converting them to a record and sending them to a channel.

CDCIterator asynchronously listens for events from the logical replication slot and returns them to the caller through Next.