List of all items

Structs

• config::PostgresCdcSourceConfig
• pgoutput::decoder::PrimaryKeepAlive
• pgoutput::decoder::XLogDataHeader
• pgoutput::messages::Begin
• pgoutput::messages::ColumnDesc
• pgoutput::messages::Commit
• pgoutput::messages::Delete
• pgoutput::messages::Insert
• pgoutput::messages::Relation
• pgoutput::messages::Truncate
• pgoutput::messages::TupleData
• pgoutput::messages::Update
• pgoutput::registry::RelationRegistry
• replication::Client
• replication::Duplex
• replication::ReplicationParams
• state::Bookmark
• stream::PostgresCdcSource

Enums

• FaucetError
• config::CdcTls
• config::SlotType
• pgoutput::messages::DeleteOldKind
• pgoutput::messages::Message
• pgoutput::messages::MessageKind
• pgoutput::messages::ReplicaIdentity
• pgoutput::messages::TupleCell
• pgoutput::messages::UpdateOldKind
• replication::ReplicationEvent

Traits

• Source

Functions

• pgoutput::decoder::decode_message
• pgoutput::values::text_to_json
• replication::advance_slot
• replication::connect
• replication::drop_slot
• replication::ensure_slot
• replication::is_slot_active_error
• replication::postgres_clock_now
• replication::postgres_clock_to_unix_ms
• replication::recv
• replication::retry_on_slot_active
• replication::send_status_update
• replication::start_replication
• state::format_lsn
• state::parse_lsn
• state::state_key

Constants

• replication::POSTGRES_EPOCH_MICROS