List of all items

Structs

• AddressedCopies
• AppId
• BrokerMoves
• Buffered
• BufferedSubscriber
• Bytes
• BytesMut
• CallerName
• Contact
• ExternalDocs
• FixedName
• HeaderMap
• Lend
• License
• Name
• NameTemplate
• NamedCopies
• NoHeaders
• OutgoingMessage
• PairError
• RawMessage
• RedeliveryAddress
• RetryDeclaration
• SecurityScheme
• ServerSpec
• StartAt
• Tag
• Take
• Unnamed
• WithHeaders
• asyncapi::Binding
• asyncapi::Bindings
• asyncapi::Channel
• asyncapi::Components
• asyncapi::Info
• asyncapi::MessageObject
• asyncapi::Operation
• asyncapi::OperationReply
• asyncapi::Parameter
• asyncapi::PublishBindings
• asyncapi::Reference
• asyncapi::ReplyAddress
• asyncapi::RetryExtension
• asyncapi::Server
• asyncapi::Spec
• asyncapi::SubscriptionBindings
• asyncapi::ViewerOptions
• codec::CborCodec
• codec::JsonCodec
• codec::MsgpackCodec
• conformance::harness::InProcessBroker
• conformance::message_shape::OptionCases
• conformance::settlement::Answers
• logging::Logging
• memory::ClosedMemoryBroker
• memory::ConnectedMemoryBroker
• memory::Discarding
• memory::MemoryBatchContext
• memory::MemoryBroker
• memory::MemoryContext
• memory::MemoryMessage
• memory::MemoryPattern
• memory::MemoryPublish
• memory::MemoryPublisher
• memory::MemoryRequest
• memory::MemoryRequester
• memory::MemorySeeker
• memory::MemorySource
• memory::MemorySubscriber
• memory::MemoryTransaction
• memory::Position
• memory::Retaining
• memory::SeekHandle
• metrics::Metrics
• metrics::MetricsHandler
• metrics::MetricsLayer
• metrics::MetricsPublish
• otel::export::Otel
• otel::export::OtelBuilder
• otel::export::OtelConsumeHandler
• otel::export::OtelConsumeLayer
• otel::export::OtelPublishLayer
• otel::propagation::OpenTelemetry
• otel::propagation::OpenTelemetryHandler
• otel::propagation::OpenTelemetryLayer
• otel::propagation::TracePropagation
• prelude::BytesMut
• runtime::After
• runtime::AppInfo
• runtime::BatchDeserialized
• runtime::BatchPublishTransformStack
• runtime::BatchTransformIdentity
• runtime::Bindable
• runtime::Bound
• runtime::BrokerScope
• runtime::CallCodec
• runtime::Context
• runtime::Ctx
• runtime::DefaultSlot
• runtime::Documented
• runtime::DynStack
• runtime::DynStackHandler
• runtime::EncodedReply
• runtime::EncodedWire
• runtime::FailurePolicies
• runtime::Fixed
• runtime::ForBatch
• runtime::ForReply
• runtime::ForSlot
• runtime::HandlerMetadata
• runtime::HandlerOutcome
• runtime::Headers
• runtime::HeadersUnset
• runtime::HealthProbe
• runtime::Identity
• runtime::MainRuntime
• runtime::MapHeaders
• runtime::Message
• runtime::MessageBody
• runtime::MissingSegment
• runtime::Mounting
• runtime::MountingSlots
• runtime::Names
• runtime::Next
• runtime::Open
• runtime::Out
• runtime::Outgoing
• runtime::OutgoingMessageMetadata
• runtime::Outs
• runtime::PipelinePublishError
• runtime::PollDiagnostics
• runtime::PollReport
• runtime::PublishBuilder
• runtime::PublishContext
• runtime::PublishDynNext
• runtime::PublishDynStack
• runtime::PublishIdentity
• runtime::PublishNext
• runtime::PublishStack
• runtime::PublishTransformIdentity
• runtime::PublishTransformStack
• runtime::Reads
• runtime::Reply
• runtime::Retry
• runtime::Router
• runtime::RouterSink
• runtime::RouterWith
• runtime::RunningApp
• runtime::RustStream
• runtime::SerializePayloadError
• runtime::SerializedReply
• runtime::SerializedWire
• runtime::Setup
• runtime::Slot
• runtime::SlotContext
• runtime::SlotPublisher
• runtime::SoloDeserialized
• runtime::Stack
• runtime::State
• runtime::SubscriberBuilder
• runtime::SubscriptionCount
• runtime::SuppliedName
• runtime::TransactionScope
• runtime::Typed
• runtime::TypedHeaders
• runtime::TypedTransaction
• runtime::Undocumented
• runtime::UnnamedCodec
• runtime::Wired
• runtime::Workers
• runtime::forms::Batch
• runtime::forms::BatchOut
• runtime::forms::BatchPublishing
• runtime::forms::BatchPublishingOut
• runtime::forms::CarriedBatch
• runtime::forms::Out
• runtime::forms::Publishing
• runtime::forms::PublishingOut
• runtime::forms::RawBatch
• runtime::forms::RawReply
• runtime::forms::RawReplyOut
• runtime::forms::RawSubscribing
• runtime::forms::Subscribing
• runtime::layers::TracingHandler
• runtime::layers::TracingLayer
• testing::BrokerHandle
• testing::Coordinator
• testing::InjectSink
• testing::PublishedAssertions
• testing::SubscriberAssertions
• testing::TestApp
• testing::TestBrokers
• testing::TestableRegistration

Enums

• AckError
• ApiKeyLocation
• AppIdError
• DeclareRetryError
• DeserializeHeadersError
• HttpApiKeyLocation
• SerializeHeadersError
• asyncapi::BindingError
• codec::CodecError
• conformance::in_process::Refusal
• conformance::settlement::Answer
• logging::LoggingInitError
• memory::MemoryError
• memory::MemoryPosition
• memory::PatternError
• memory::RequestError
• memory::Retention
• memory::Routing
• otel::export::OtelInitError
• prelude::WireBytes
• runtime::FailurePolicy
• runtime::HealthState
• runtime::OutgoingKind
• runtime::OutgoingName
• runtime::Placement
• runtime::PublishError
• runtime::RustStreamError
• runtime::SubscriptionEnd
• runtime::TransactionPublishError
• runtime::cli::AppRuntime
• runtime::cli::CliError
• testing::Backlog
• testing::Outcome
• testing::TestError

Traits

• BatchSubscriber
• Broker
• BuildBatchContext
• BuildContext
• Carries
• CarriesBatch
• ConnectedBroker
• ContextField
• CopyPath
• DefaultPublish
• DescribeServer
• DestinationForm
• Field
• FieldMut
• FromName
• HeadersContract
• IncomingMessage
• MessageHeaders
• MessageInfo
• OutgoingDestination
• OwnedTransactions
• Partitioned
• PayloadForm
• Positioned
• PublishPolicy
• Publisher
• RedeliveryAddressed
• RequestReply
• Seekable
• Seeker
• Subscribe
• Subscriber
• SubscriptionSource
• Transaction
• TransactionalPublisher
• codec::Codec
• memory::LogMode
• runtime::App
• runtime::BatchPublishTransform
• runtime::BatchSized
• runtime::BatchStep
• runtime::BindSlots
• runtime::BlanketLayer
• runtime::BoundSegment
• runtime::BrokerRegistration
• runtime::ContainsMessage
• runtime::ContextKind
• runtime::CtxKey
• runtime::Declared
• runtime::Deserialized
• runtime::Documentable
• runtime::DynMiddleware
• runtime::FailureStep
• runtime::FromContext
• runtime::FromRef
• runtime::Handle
• runtime::Handler
• runtime::HandlerExt
• runtime::HasSlots
• runtime::HeaderSource
• runtime::IncludeDef
• runtime::Input
• runtime::IntoSource
• runtime::Layer
• runtime::ListOffer
• runtime::MapPublisher
• runtime::MapSourceStep
• runtime::MessageWire
• runtime::NameStep
• runtime::OutEntry
• runtime::OutMessages
• runtime::OutPipeline
• runtime::OutSlot
• runtime::PublishAt
• runtime::PublishCodec
• runtime::PublishDynLayer
• runtime::PublishExt
• runtime::PublishHeaders
• runtime::PublishLayer
• runtime::PublishPipeline
• runtime::PublishSink
• runtime::PublishTransform
• runtime::PublishedThrough
• runtime::ReplyShape
• runtime::ResolvedName
• runtime::RouterDef
• runtime::RouterHandlers
• runtime::SatisfiesContract
• runtime::Serialized
• runtime::StartAtStep
• runtime::SubscriberSettings
• runtime::TemplateAddress
• runtime::WorkersStep
• testing::InProcess
• testing::TestableBroker

Macros

• nonzero
• prelude::nonzero
• register_testable_broker

Attribute Macros

• app
• prelude::app
• prelude::subscriber
• subscriber

Derive Macros

• Deserialized
• FromRef
• MessageInfo
• OutMessages
• OutSlot
• Outgoing
• Serialized
• prelude::Deserialized
• prelude::FromRef
• prelude::MessageInfo
• prelude::OutMessages
• prelude::OutSlot
• prelude::Outgoing
• prelude::Serialized

Functions

• asyncapi::build_spec
• asyncapi::render_viewer_html
• conformance::capabilities::batch_seeking
• conformance::capabilities::batches
• conformance::capabilities::carries
• conformance::capabilities::carries_batch
• conformance::capabilities::owned_transactions
• conformance::capabilities::request_reply
• conformance::capabilities::seeking
• conformance::capabilities::seeking_unknown_position
• conformance::capabilities::transactions
• conformance::harness::describes_without_credentials
• conformance::harness::lifecycle
• conformance::harness::run_suite
• conformance::helpers::next_message
• conformance::helpers::unique_subject
• conformance::helpers::wait_for_no_messages
• conformance::helpers::wait_until
• conformance::helpers::wait_until_async
• conformance::in_process::backlog_matches_server
• conformance::in_process::refuses_like_the_server
• conformance::lifecycle::shared_handle_closes
• conformance::lifecycle::shutdown_flushes
• conformance::message_shape::describes_addresses_without_credentials
• conformance::message_shape::keyed_order
• conformance::message_shape::publish_options
• conformance::message_shape::publishes_without_credentials
• conformance::retry::broker_moves
• conformance::retry::redelivery_address
• conformance::settlement::matches_in_process
• conformance::settlement::suite
• logging::init
• runtime::cli::run_main
• runtime::cli::run_main_on
• runtime::for_batch
• runtime::subscriber
• runtime::typed
• testing::expect_published

Type Aliases

• Connected
• OutgoingFor
• Str
• codec::DefaultCodec
• prelude::Str
• runtime::AllOpen
• runtime::RouterOut
• runtime::RouterPublishing
• runtime::RouterPublishingOut
• runtime::ValueBuilder
• runtime::Verdict

Constants

• memory::PARTITION_KEY_HEADER
• otel::export::PUBLISH_TIME_HEADER
• runtime::RETRY_COUNT_HEADER