List of all items
Structs
- BuiltIn
- ClosedSqlxBroker
- ConnectedSqlxBroker
- DatabaseClock
- InboxDelivery
- InboxQueue
- InboxSpec
- InboxSubscriber
- InboxThreads
- NamedDelivery
- NamedSubscriber
- Plain
- Repository
- RepositoryPublisher
- Routed
- RoutedPublisher
- RowBatch
- SqlxBroker
- SystemClock
- Transactional
- Tx
- keys::Attempt
- keys::InboxContext
- keys::Pool
- keys::PoolContext
- keys::Tx
- keys::TxContext
- outbox::Checked
- outbox::Nil
- outbox::Outbox
- outbox::PoolAlreadySet
- outbox::Registered
- outbox::Republishing
- outbox::TrackedPublisher
- outbox::TrackingLayer
- outbox::TrackingPublishLayer
- outbox::spec::Headers
- outbox::spec::OutboxSpec
- outbox::spec::ProcessedAt
- outbox::spec::Set
- outbox::spec::Unset
- outbox::spec::own::Ack
- outbox::spec::own::Discard
- outbox::spec::own::Fetch
- outbox::spec::own::Recover
- outbox::spec::own::Retry
- prelude::AppInfo
- prelude::BytesMut
- prelude::CallerName
- prelude::Context
- prelude::Ctx
- prelude::DefaultSlot
- prelude::FailurePolicies
- prelude::FixedName
- prelude::ForReply
- prelude::ForSlot
- prelude::HandlerOutcome
- prelude::HeaderMap
- prelude::Headers
- prelude::MainRuntime
- prelude::Message
- prelude::Name
- prelude::NameTemplate
- prelude::Names
- prelude::NoHeaders
- prelude::Out
- prelude::OutgoingMessageMetadata
- prelude::Outs
- prelude::Reads
- prelude::Reply
- prelude::Retry
- prelude::Router
- prelude::RunningApp
- prelude::RustStream
- prelude::SerializedReply
- prelude::SerializedWire
- prelude::Slot
- prelude::SoloDeserialized
- prelude::State
- prelude::Unnamed
- prelude::WithHeaders
- prelude::Workers
- spec::Advisory
- spec::Attempt
- spec::Clock
- spec::Fifo
- spec::HeaderFields
- spec::Headers
- spec::Key
- spec::Lease
- spec::Opens
- spec::Payload
- spec::ProcessedAt
- spec::RetryAfter
- spec::Set
- spec::Unset
- spec::own::Ack
- spec::own::Claim
- spec::own::DeadLetter
- spec::own::Discard
- spec::own::Extend
- spec::own::Fetch
- spec::own::Lock
- spec::own::Retry
- spec::own::RetryAfter
- spec::own::Unlock
Enums
- NamedTime
- SqlxBrokerError
- outbox::OutboxError
- outbox::TrackedPublishError
- prelude::FailurePolicy
- prelude::WireBytes
Traits
- Ack
- AttemptColumn
- AttemptRow
- BuiltInDialect
- ByName
- Claim
- Clock
- DeadLetter
- Discard
- Extend
- Fetch
- HeaderColumn
- HeaderField
- HeaderFields
- HeaderRow
- InboxHeaders
- InboxRow
- InboxSettings
- InboxTable
- Insert
- KeyColumn
- KeyRow
- LeaseRow
- Lock
- Notifies
- PayloadRow
- Publish
- QueueDatabase
- QueueTime
- Retry
- RetryAfter
- TimeColumn
- TimeSource
- Unlock
- outbox::Ack
- outbox::Discard
- outbox::Fetch
- outbox::OutboxDatabase
- outbox::OutboxRow
- outbox::Publish
- outbox::Recover
- outbox::Retry
- outbox::TrackedName
- outbox::spec::Declaration
- outbox::spec::Described
- outbox::spec::Merge
- outbox::spec::OutboxTable
- outbox::spec::OwnEvent
- outbox::spec::Push
- prelude::App
- prelude::Broker
- prelude::ContextKind
- prelude::Deserialized
- prelude::FromContext
- prelude::FromRef
- prelude::Handle
- prelude::IncomingMessage
- prelude::Input
- prelude::MapPublisher
- prelude::MessageHeaders
- prelude::MessageInfo
- prelude::MessageWire
- prelude::OutEntry
- prelude::OutMessages
- prelude::OutSlot
- prelude::OutgoingDestination
- prelude::OwnedTransactions
- prelude::PublishExt
- prelude::PublishPolicy
- prelude::PublishTransform
- prelude::PublishedThrough
- prelude::Publisher
- prelude::ReplyShape
- prelude::RequestReply
- prelude::RouterDef
- prelude::Serialized
- prelude::SubscriberSettings
- prelude::TransactionalPublisher
- spec::Declaration
- spec::Merge
- spec::OpeningLevel
- spec::OwnEvent
- spec::Push