List of all items

Structs

• contract::BackpressurePolicy
• contract::GuaranteeMatrix
• contract::SubscriptionSemantics
• contract::delivery::DeliveryState
• contract::delivery::PartialDeliveryState
• contract::message::SchemaDescriptor
• contract::message::TraceContext
• eventbus::BatchError
• eventbus::BatchOutcome
• eventbus::ConsumerGroup
• eventbus::ConsumerName
• eventbus::Message
• eventbus::MessageId
• eventbus::PublishOptions
• eventbus::SubscriptionConfig
• eventbus::SubscriptionConfigBuilder
• eventbus::Topic
• stream::ClaimedMessage
• stream::StreamBus
• stream::StreamBusOptions
• stream::StreamSubscription

Enums

• contract::AckMode
• contract::ConsumerBalanceMode
• contract::DeliveryGuarantee
• contract::OrderingMode
• contract::OverflowStrategy
• contract::PublishConfirmation
• contract::delivery::DeliveryOutcome
• error::EventBusError
• stream::ErrorScope
• stream::FetchedEntry

Traits

• contract::delivery::DeliveryInspector
• eventbus::Bus
• eventbus::Codec
• eventbus::Delivery
• eventbus::DeliveryControl
• eventbus::DeliveryHandle
• eventbus::Handler
• eventbus::Publisher
• eventbus::PublisherExt
• eventbus::Subscriber
• eventbus::SubscriberExt
• eventbus::Subscription
• stream::ErrorObserver
• stream::StreamBackend

Functions

• serde_bytes::deserialize
• serde_bytes::serialize

Type Aliases

• BoxFuture
• BoxedError
• eventbus::Headers

Constants

• contract::message::HEADER_BAGGAGE
• contract::message::HEADER_CONTENT_TYPE
• contract::message::HEADER_DEAD_LETTER_REASON
• contract::message::HEADER_EVENT_VERSION
• contract::message::HEADER_IDEMPOTENCY_KEY
• contract::message::HEADER_RETRY_ATTEMPT
• contract::message::HEADER_RETRY_REASON
• contract::message::HEADER_TRACE_PARENT
• contract::message::HEADER_TRACE_STATE