List of all items
Structs
- StartupEvents
- ack_policy::Clause
- ack_policy::CursorView
- ack_policy::EvalStatus
- ack_policy::Policy
- connection_limit::RingSizing
- early_reply::EarlyReply
- early_reply::EarlyReplyQueue
- early_reply::EarlyReplySender
- halt::DegradedRelease
- halt::HaltGate
- layout::PipelineCores
- layout::Placement
- policy_control::AckPolicyControl
- policy_control::AckPolicyPublisher
- policy_control::BootedClaim
- policy_control::PublisherClaim
- 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::GatePolicy
- response::GateStart
- response::Response
- server::DpdkArgs
- server::ServerConfig
Enums
- ControlEvent
- ack_policy::AckPolicy
- ack_policy::Blocker
- ack_policy::Level
- ack_policy::PolicyError
- client_auth::ClientAuthError
- connection_limit::MaxConnectionsError
- early_reply::EarlyKind
- halt::Verdict
- layout::ReaderThread
- replication::PrimaryMessage
- replication::ReplicaMessage
- server::JournalStagingMode
Functions
- admin::spawn
- client_auth::verify_client
- early_reply::early_reply_channel
- 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
- server::run_with_shutdown
Type Aliases
- reader::RequestDecoderArc
- replication::ReceiverResult
- response::ResponseEncoderArc
- server::EventPublisherFn