List of all items
Structs
- client::PgClient
- job::CheckOutput
- job::JobContext
- job::PgSinkFactory
- job::RuntimeStatus
- job::SnapshotStatus
- job::SourceStatus
- job::StatusOutput
- job::TableSyncRow
- replication::conn::ReplicationConnection
- replication::conn::SimpleResult
- replication::slot::CreatedSlot
- replication::slot::SlotInfo
- replication::slot::SystemInfo
- replication::stream::PgEventStream
- replication::stream::PgStreamFactory
- schema::TargetColumn
- sink::PgSink
- sink::RuntimeRow
- sink::SinkLimits
- snapshot::CopyStats
- source::CheckResult
- source::ColumnInfo
- source::PreflightReport
- source::PublicationInfo
- source::PublicationTable
- source::RoleInfo
- source::ServerInfo
- source::SourcePreflight
- source::TableInfo
- url::ConnectionInfo
Enums
- replication::pgoutput::LogicalMessage
- replication::pgoutput::ReplicationMessage
- source::CheckStatus
- source::PreflightMode
- url::TlsPolicy
Traits
Functions
- client::connect
- errors::error_chain
- errors::from_io
- errors::from_pg
- errors::kind_for_sqlstate
- job::bootstrap
- job::check
- job::cleanup
- job::group_digits
- job::run
- job::status
- replication::conn::stream_error_kind
- replication::pgoutput::decode
- replication::pgoutput::decode_logical
- replication::pgoutput::encode_standby_status
- replication::slot::create_slot_with_snapshot
- replication::slot::drop_slot
- replication::slot::identify_system
- replication::slot::read_slot
- replication::slot::slot_info_from_json
- replication::slot::start_replication_command
- replication::stream::verify_slot_continuity
- schema::apply_schema
- schema::dump_schema
- schema::filter_dump
- schema::target_columns
- schema::verify_columns
- sink::configure_session
- sink::delete_job
- sink::set_job_state
- sink::upsert_checkpoint
- sink::upsert_runtime
- snapshot::copy_table
- snapshot::import_snapshot
- source::current_wal_lsn
- source::preflight
- source::publication_info
- source::role_info
- source::server_info
- source::slot_info
- source::table_info
- tls::client_config
- tls::server_name
- url::is_loopback_host