List of all items

Structs

• causal::CausalContext
• causal::MessageId
• causal::orderer::CausalOrderer
• causal::orderer::OrderedEnvelope
• channel::PublishRecord
• channel::admission::ChannelPressureConfig
• channel::admission::PressureAggregate
• channel::registry::ChannelRegistry
• channel::registry::ChannelSummary
• channel::schema::Schema
• channel::schema::SchemaId
• channel::subscription::ConnectionInboxBudget
• channel::subscription::InboxInstall
• channel::subscription::SubscriptionHandle
• channel::supervisor::ChannelRestartPolicy
• channel::supervisor::ChannelSupervisor
• channel::types::ChannelConfig
• channel::types::ChannelDelivery
• channel::types::ChannelHandle
• conversation::actor::ConversationActor
• conversation::actor::ConversationSupervisor
• conversation::participant::EchoBehaviour
• conversation::types::Conversation
• conversation::types::ConversationConfig
• conversation::types::ConversationHandle
• conversation::types::ConversationMessage
• conversation::types::ConversationState
• conversation::types::ParticipantPid
• conversation::types::ParticipantStatus
• durability::channel::CausalContext
• durability::channel::DurableChannel
• durability::channel::EphemeralChannel
• durability::channel::KeyLookup
• durability::channel::MessageEnvelope
• durability::channel::PartitionKey
• durability::channel::UnresolvedAppend
• durability::config::DurabilityConfig
• durability::conversation::ConversationState
• durability::conversation::DurableConversation
• durability::counting::CountingStore
• durability::counting::StoreCounts
• durability::counting::StoreCountsHandle
• durability::cursor::CheckpointDriver
• durability::cursor::ConsumerCursor
• durability::dedup::ClaimEvidence
• durability::dedup::DedupCache
• durability::dedup::DedupEntry
• durability::dedup::DedupHeadCounts
• durability::dedup::DedupSweepReport
• durability::dedup::DedupSweeper
• durability::dedup::InFlightClaim
• durability::ephemeral_root::EphemeralRoot
• durability::ephemeral_root::EphemeralSweepCounts
• durability::receipt::ProcessingReceipt
• durability::recovery::RecoveredCursor
• durability::store::EphemeralHaematiteStore
• durability::store::HaematiteStore
• durability::store::RoutedBatchItem
• durability::store::ScanCursor
• durability::store::ScanPage
• durability::store::StoredEntry
• envelope::Envelope
• envelope::PublisherId
• metrics::channel::ChannelMetrics
• metrics::conversation::ConversationMetrics
• metrics::pressure::PressureMetrics
• metrics::registry::CounterFamily
• metrics::registry::CounterHandle
• metrics::registry::GaugeFamily
• metrics::registry::GaugeHandle
• metrics::registry::HistogramBucketSnapshot
• metrics::registry::HistogramFamily
• metrics::registry::HistogramHandle
• metrics::registry::HistogramSnapshot
• metrics::registry::MetricSnapshot
• metrics::registry::MetricsRegistry
• metrics::registry::MetricsSnapshot
• pressure::capacity::CapacityTracker
• pressure::capacity::ConsumerCapacity
• pressure::enforce::EnforcementOutcome
• pressure::enforce::PressureEnforcer
• pressure::enforce::ScaleSignal
• pressure::monitor::ChannelPressureSnapshot
• pressure::monitor::ConsumerPressureMetrics
• pressure::monitor::ConsumerPressureSnapshot
• pressure::monitor::PressureMonitor
• pressure::policy::ChannelPolicyConfig
• pressure::policy::PressurePolicy
• pressure::signal::DeliveryResult
• protocol::backpressure::AcceptPayload
• protocol::backpressure::DeferPayload
• protocol::backpressure::RejectPayload
• protocol::backpressure::StreamPressure
• protocol::causal::CausalContext
• protocol::causal::MessageId
• protocol::envelope::MessageEnvelope
• protocol::envelope::SchemaId
• protocol::frame::DeliveredId
• protocol::frame::FrameHeader
• protocol::frame::LinkOffer
• protocol::frame::WorkerActivityDescriptor
• protocol::frame::WorkerRegistration
• protocol::lifecycle::LifecycleAction
• protocol::multiplex::StreamAllocator
• protocol::multiplex::StreamId
• protocol::multiplex::StreamTable
• protocol::version::ProtocolVersion
• routing::compiler::CompiledFunction
• routing::dispatch::DispatchConversation
• routing::dispatch::DispatchOutcome
• routing::dispatch::RerouteTiming
• routing::function::execute::ConsumerId
• routing::function::execute::ConsumerStateView
• routing::function::execute::RoutingDecision
• routing::function::execute::RoutingMessage
• routing::function::execute::SupervisedExecutor
• routing::function::loader::ContentHash
• routing::function::loader::ModuleLoader
• routing::function::loader::RoutingFunction
• routing::function::loader::RoutingModule
• routing::function::loader::RoutingSlot
• routing::group::ConsumerGroup
• routing::group::ConsumerGroupSnapshot
• routing::group::ConsumerRegistration
• routing::predicate::FieldPath
• routing::table::RoutingTable
• routing::table::SubscriberId
• routing::table::Subscription
• tracing::context::TraceContext
• tracing::logging::LogEntry
• tracing::logging::LogEntryBuilder
• tracing::logging::NoopEmitter
• tracing::span::ConversationSpan
• tracing::span::FinishedSpan
• tracing::span::NoopCollector
• tracing::span::Span
• tracing::span::SpanGuard

Enums

• channel::schema::SchemaValidationError
• channel::types::ChannelMode
• channel::wire::WireError
• conversation::actor::ConversationCommand
• conversation::types::ConversationContextEntry
• conversation::types::ConversationPhase
• conversation::types::CrashPolicy
• conversation::types::ParticipantHealth
• durability::bridge::BridgeError
• durability::channel::AppendResolution
• durability::config::CheckpointPolicy
• durability::config::DurabilityMode
• durability::conversation::ConversationEvent
• durability::conversation::RedeliveryDecision
• durability::dedup::DedupDecision
• durability::error::DurabilityError
• durability::head_checkpoint::HeadCheckpointRefusal
• error::LiminalError
• metrics::conversation::ConversationOutcome
• metrics::pressure::DeliveryOutcome
• metrics::registry::MetricKind
• metrics::registry::MetricRegistrationError
• metrics::registry::MetricValue
• pressure::capacity::CapacityError
• pressure::enforce::PolicyEvent
• pressure::policy::AlertSeverity
• pressure::policy::PolicyAction
• pressure::signal::PressureSignal
• protocol::backpressure::PressureState
• protocol::error::ProtocolError
• protocol::frame::DisconnectReason
• protocol::frame::Frame
• protocol::frame::FrameType
• protocol::frame::LinkEnd
• protocol::frame::LinkOpenOutcome
• protocol::frame::WorkerRegisterOutcome
• protocol::lifecycle::ConnectionState
• protocol::multiplex::StreamState
• routing::dispatch::DispatchError
• routing::evaluate::FieldValueRef
• routing::function::execute::FunctionError
• routing::predicate::ComparisonOp
• routing::predicate::FieldValue
• routing::predicate::Predicate
• tracing::logging::LogEmitterInstallError
• tracing::logging::LogLevel
• tracing::logging::LogValue
• tracing::span::SpanCollectorInstallError

Traits

• channel::observer::ClusterObserver
• conversation::participant::ParticipantBehaviour
• durability::counting::StoreCountObserver
• durability::store::DurableStore
• metrics::registry::HistogramValue
• protocol::multiplex::AllocateStreamId
• routing::evaluate::FieldAccessor
• tracing::logging::LogEmitter
• tracing::span::SpanCollector

Functions

• channel::admission::clamp_capacity_to_depth_cap
• channel::admission::default_capacity
• channel::admission::defer_after_append
• channel::admission::defer_delay
• channel::admission::watermark_reached
• channel::supervisor::shared_supervisor
• channel::wire::decode_envelope
• channel::wire::encode_envelope
• conversation::patterns::ask
• durability::bridge::block_on
• durability::counting::record_store_opened
• durability::counting::stores_opened
• durability::cursor::cursor_key_for
• durability::dedup::dedup_head_counts
• durability::dedup::key_hash
• durability::head_checkpoint::advance_head
• durability::head_checkpoint::head_checkpoint_key
• durability::head_checkpoint::recover_partition_head
• durability::recovery::recover_conversation
• durability::recovery::recover_cursor
• durability::recovery::recover_cursor_with_replay
• durability::recovery::recover_durable_channel
• durability::recovery::recover_partition_sequences
• durability::replay::replay_from
• durability::replay::replay_range
• durability::settle::append_all_settled
• durability::settle::append_settled
• durability::settle::apply_routed_batch_settled
• durability::settle::cas_settled
• durability::settle::flush_settled
• metrics::export::render
• metrics::registry::global_registry
• metrics::registry::install_global_registry
• metrics::registry::metrics_enabled
• protocol::causal::extract_causal_context
• protocol::codec::decode
• protocol::codec::encode
• protocol::codec::encoded_len
• protocol::frame::validate_stream
• protocol::handshake::connect_ack_frame
• protocol::handshake::connect_error_frame
• protocol::handshake::connect_frame
• protocol::schema::negotiate_schema
• protocol::schema::subscribe_error_frame
• protocol::version::negotiate_version
• routing::compiler::compile
• routing::evaluate::evaluate
• tracing::logging::clear_min_log_level
• tracing::logging::emit_entry
• tracing::logging::global_log_emitter
• tracing::logging::install_boxed_log_emitter
• tracing::logging::install_log_emitter
• tracing::logging::level_enabled
• tracing::logging::log
• tracing::logging::log_emitter_enabled
• tracing::logging::log_enabled
• tracing::logging::log_with_fields
• tracing::logging::min_log_level
• tracing::logging::set_min_log_level
• tracing::span::current_trace_context
• tracing::span::global_span_collector
• tracing::span::install_boxed_span_collector
• tracing::span::install_span_collector
• tracing::span::span_collector_enabled

Type Aliases

• channel::Recipient
• channel::subscription::InboxNotifier
• channel::types::SchemaRef

Constants

• channel::admission::DEFAULT_MAX_BUFFER_DEPTH
• channel::admission::DEFAULT_MAX_IN_FLIGHT
• conversation::patterns::DEFAULT_ASK_TIMEOUT
• durability::head_checkpoint::HEAD_CHECKPOINT_EVERY
• protocol::frame::CONVERSATION_REPLY_REQUESTED_FLAG
• protocol::frame::DELIVER_MESSAGE_ID_FLAG
• protocol::frame::DELIVER_MESSAGE_ID_VERSION
• protocol::frame::DISCONNECT_REASON_BODY_MAX
• protocol::frame::DISCONNECT_REASON_BODY_VERSION
• protocol::frame::DISCONNECT_REASON_NAME_MAX
• protocol::frame::HEADER_LEN
• protocol::frame::LINK_MACHINE_LEN
• protocol::frame::PUBLISH_ACK_POSITION_VERSION
• protocol::frame::PUBLISH_DELIVERED_FLAG
• protocol::frame::PUBLISH_DURABLE_POSITION_FLAG
• protocol::frame::PUBLISH_IDEMPOTENCY_KEY_FLAG
• protocol::frame::REVOCATION_CLOSE_VERSION