List of all items

Structs

• aion::channels::ChannelName
• aion::codec::DispatchAck
• aion::codec::DispatchRequest
• aion::codec::DispatchResponse
• aion::dispatch::DispatchContext
• aion::dispatch::DispatchOperation
• aion::dispatch::DispatchWorker
• aion::dispatch::RecordedDispatchOutcome
• aion::dispatch::RoutingFunctionDispatchRouter
• aion::history::HistoryChannel
• aion::history::HistoryContext
• aion::history::HistoryPublishFailure
• aion::history::HistorySubscription
• aion::signal::RecordedSignalDelivery
• aion::signal::SignalChannel
• aion::signal::SignalContext
• aion::signal::SignalDeclaration
• aion::signal::SignalOperation
• aion::signal::SignalWorkflowConfig
• aion::types::ActivityRequest
• aion::types::HistoryEvent
• aion::types::Payload
• aion::types::SignalPayload
• aion::types::WorkerCapacity
• aion::worker::WorkerContext
• aion::worker::WorkerRegistration
• causal::CausalContext
• causal::MessageId
• causal::orderer::CausalOrderer
• causal::orderer::OrderedEnvelope
• channel::registry::ChannelRegistry
• channel::registry::ChannelSummary
• channel::schema::Schema
• channel::schema::SchemaId
• 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::MessageEnvelope
• durability::channel::PartitionKey
• durability::config::DurabilityConfig
• durability::conversation::ConversationState
• durability::conversation::DurableConversation
• durability::cursor::CheckpointDriver
• durability::cursor::ConsumerCursor
• durability::dedup::DedupCache
• durability::dedup::DedupEntry
• durability::dedup::DedupSweepReport
• durability::dedup::DedupSweeper
• durability::receipt::ProcessingReceipt
• durability::recovery::RecoveredCursor
• durability::store::HaematiteStore
• 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::FrameHeader
• 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

• aion::codec::DispatchAckStatus
• aion::dispatch::ActivityDispatchState
• aion::dispatch::DispatchConversationEvent
• aion::dispatch::DispatchOperationKind
• aion::error::AionSurfaceError
• aion::signal::SignalOperationKind
• aion::signal::WorkflowTerminalStatus
• aion::types::ActivityResult
• 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::config::CheckpointPolicy
• durability::config::DurabilityMode
• durability::conversation::ConversationEvent
• durability::conversation::RedeliveryDecision
• durability::dedup::DedupDecision
• durability::error::DurabilityError
• 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::Frame
• protocol::frame::FrameType
• 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

• aion::dispatch::ConversationIdProvider
• aion::dispatch::DispatchConversation
• aion::dispatch::DispatchConversationFactory
• aion::dispatch::DispatchRecorder
• aion::dispatch::DispatchRouter
• aion::dispatch::DispatchWorkerPool
• aion::history::HistoryPublishReporter
• aion::signal::SignalDeliverer
• aion::signal::SignalRecorder
• channel::observer::ClusterObserver
• conversation::participant::ParticipantBehaviour
• durability::store::DurableStore
• metrics::registry::HistogramValue
• protocol::multiplex::AllocateStreamId
• routing::evaluate::FieldAccessor
• tracing::logging::LogEmitter
• tracing::span::SpanCollector

Functions

• aion::channels::dispatch_channel
• aion::channels::history_channel
• aion::channels::signal_channel
• aion::codec::dispatch_ack_schema
• aion::codec::dispatch_request_schema
• aion::codec::dispatch_response_schema
• aion::codec::encode_dispatch_ack
• aion::codec::encode_dispatch_request
• aion::codec::encode_dispatch_response
• aion::dispatch::dispatch_activity
• aion::dispatch::dispatch_activity_with_context
• aion::history::publish_history_after_record
• aion::history::publish_recorded_event
• aion::history::start_workflow_history
• aion::history::subscribe_history
• aion::signal::complete_workflow_signals
• aion::signal::publish_signal
• aion::signal::replay_signal_deliveries
• aion::signal::start_workflow_signals
• aion::worker::default_worker_context
• aion::worker::register_worker
• channel::supervisor::shared_supervisor
• channel::wire::decode_envelope
• channel::wire::encode_envelope
• conversation::patterns::ask
• durability::bridge::block_on
• durability::cursor::cursor_key_for
• durability::dedup::key_hash
• 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
• 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

• aion::worker::WorkerPool
• channel::types::SchemaRef

Constants

• aion::codec::DISPATCH_ACK_CONTENT_TYPE
• aion::codec::DISPATCH_REQUEST_CONTENT_TYPE
• aion::codec::DISPATCH_RESPONSE_CONTENT_TYPE
• conversation::patterns::DEFAULT_ASK_TIMEOUT
• protocol::frame::CONVERSATION_REPLY_REQUESTED_FLAG
• protocol::frame::HEADER_LEN
• protocol::frame::PUBLISH_DELIVERED_FLAG
• protocol::frame::PUBLISH_IDEMPOTENCY_KEY_FLAG