List of all items
Structs
- ack_policy::Clause
- ack_policy::CursorView
- ack_policy::EvalStatus
- ack_policy::Policy
- promotion::PromotionRequest
- reader::ReaderRegistration
- reader::UringReaderHandle
- replication::Ack
- replication::Handshake
- replication::PendingAck
- replication::PendingAckQueue
- replication::ReplicaControlPlane
- replication::ReplicaCursors
- replication::ReplicationListener
- replication::ReplicationMetrics
- replication::Sender
- replication::SentHighWater
- response::Response
- server::PipelineCores
- server::ServerConfig
Enums
- ControlEvent
- ack_policy::AckPolicy
- ack_policy::Blocker
- ack_policy::Level
- ack_policy::PolicyError
- replication::PrimaryMessage
- replication::ReplicaMessage
Functions
- admin::spawn
- process::install_shutdown_handler
- process::try_lock_memory
- reader::spawn_reader
- replication::run_receiver
- replication::run_sender
- replication::try_flush_dual_track
- replication::wait_for_journal_cursor
- response::run
- server::run
- server::run_with_listener
Type Aliases
- reader::RequestDecoderArc
- replication::ReceiverResult
- response::ResponseEncoderArc
- server::EventPublisherFn