List of all items

Structs

• CommitBuilder
• InMemoryOutboxStore
• InMemoryRepository
• StagedCommitBuilder
• aggregate::AggregateRepository
• bus::BusTopologyConfig
• bus::Handlers
• bus::InMemoryBus
• bus::InMemoryReceived
• bus::Message
• bus::PayloadDecodeError
• bus::RunOptions
• bus::SubscriptionPlan
• bus::TransportCapabilities
• bus::TransportError
• entity::BitcodePayloadCodec
• entity::Entity
• entity::EventRecord
• entity::EventRecordError
• entity::EventUpcaster
• lock::InMemoryLock
• lock::InMemoryLockFuture
• lock::InMemoryLockManager
• manifest::DistributedManifestEnvelope
• manifest::DistributedProjectManifest
• manifest::MessageEndpointManifest
• manifest::MetricsEndpointManifest
• manifest::ServiceManifest
• manifest::ServiceObservabilityManifest
• manifest::TracingManifest
• manifest::TransportManifest
• microsvc::CommandRequest
• microsvc::CommandResponse
• microsvc::Context
• microsvc::HandlerSpec
• microsvc::ReadModelStoreDependencies
• microsvc::RepoDependencies
• microsvc::RepoReadModelDependencies
• microsvc::RouteBuilder
• microsvc::Routes
• microsvc::Service
• microsvc::Session
• outbox::AggregateCommit
• outbox::CommitReceipt
• outbox::OutboxMessage
• outbox::OutboxPublisherConfig
• outbox_worker::BusOutboxPublishHook
• outbox_worker::BusPublisher
• outbox_worker::ClaimOutboxMessages
• outbox_worker::OutboxBacklogStats
• outbox_worker::OutboxClaimRef
• outbox_worker::OutboxDispatchOutcome
• outbox_worker::OutboxDispatcher
• outbox_worker::OutboxSource
• outbox_worker::ReceivedOutboxMessage
• queued_repo::QueuedRepository
• queued_repo::ReadOpts
• read_model::InMemoryReadModelStore
• read_model::ReadModelIncludeRows
• read_model::ReadModelLoadBuilder
• read_model::ReadModelLoadGraph
• read_model::ReadModelLoadRequest
• read_model::ReadModelQueryCapabilities
• read_model::ReadModelWorkspace
• read_model::ReadModelWritePlanBuilder
• read_model::Versioned
• repository::CommitBatch
• repository::InboxReceipt
• repository::PreparedEventAppend
• repository::StreamIdentity
• repository::StreamWrite
• snapshot::InMemorySnapshotStore
• snapshot::SnapshotRecord
• table::DeleteTableRowMutation
• table::ForeignKey
• table::PatchTableRowMutation
• table::PrimaryKey
• table::RelationshipDef
• table::RowKey
• table::RowPatch
• table::RowValues
• table::TableAdapterCapabilities
• table::TableColumn
• table::TableCommitOutcome
• table::TableIndex
• table::TableMigrationArtifact
• table::TableRowMutation
• table::TableSchema
• table::TableSchemaAdapterCapabilities
• table::TableSchemaBootstrap
• table::TableSchemaIssue
• table::TableSchemaRegistry
• table::TableSchemaVerification
• table::TableSqlSchemaAdapter
• table::TableWritePlan
• trace_context::TraceContext

Enums

• bus::ConsumerAckKind
• bus::ConsumerDeliveryMode
• bus::FailureAction
• bus::FailurePolicy
• bus::KnativeIntegrationKind
• bus::MessageKind
• bus::MessageNameError
• bus::NoInbox
• bus::StableMessageIdError
• bus::TransportErrorKind
• entity::UpcastError
• lock::LockError
• lock::RetryClass
• manifest::TraceExportMode
• manifest::TracePropagationMode
• microsvc::DeliveryKind
• microsvc::HandlerError
• microsvc::HandlerNames
• outbox::OutboxMessageStatus
• outbox_worker::OutboxPublishFailureAction
• repository::InboxOutcome
• repository::RepositoryError
• repository::SnapshotWrite
• table::ColumnType
• table::ExpectedVersion
• table::PatchMode
• table::RelationshipKind
• table::RowValue
• table::RowWriteMode
• table::TableMutation
• table::TableSchemaIssueKind
• table::TableSqlDialect
• table::TableStoreError

Traits

• CommitBuilderExt
• ReadModelWritePlanCommitExt
• aggregate::Aggregate
• aggregate::AggregateBuilder
• bus::Bus
• bus::BusConsumer
• bus::InboxHook
• bus::MessageHandler
• bus::MessagePublisher
• bus::MessageRouter
• bus::MessageSource
• bus::ReceivedMessage
• entity::PayloadCodec
• lock::Lock
• lock::LockManager
• microsvc::ConfigurableOutboxPublisher
• microsvc::HasOutboxStore
• microsvc::HasReadModelStore
• microsvc::HasRepo
• outbox::OutboxPublishHook
• outbox_worker::OutboxStore
• queued_repo::GetAllWithOpts
• queued_repo::GetWithOpts
• queued_repo::Queueable
• queued_repo::UnlockableRepository
• read_model::ReadModel
• read_model::ReadModelWorkspaceExt
• read_model::RelationalReadModel
• read_model::RelationalReadModelIncludes
• repository::GetStream
• repository::InboxStore
• repository::ReadModelWritePlanStore
• repository::RelationalReadModelQueryStore
• repository::Repository
• repository::SnapshotStore
• repository::TransactionalCommit
• snapshot::Snapshottable
• table::TableModel
• table::TableSchemaAdapter
• table::TableSchemaRegistryExt

Macros

• aggregate
• impl_aggregate
• routes

Attribute Macros

• digest
• sourced

Derive Macros

• ReadModel
• Snapshot

Functions

• aggregate::hydrate
• bus::resolve_consumer_group
• bus::run_source
• bus::validate_consumer_group
• bus::validate_message_name
• bus::validate_namespace
• bus::validate_stable_message_id
• entity::upcast_events
• entity::upcast_events_for_replay
• entity::upcast_payload
• outbox::outbox_message_insert_plan
• outbox::outbox_message_key
• outbox::outbox_message_row_values
• outbox::outbox_message_schema
• snapshot::hydrate_from_snapshot
• table::generate_table_migration_artifacts
• table::table_schema_bootstrap_result
• table::table_schema_statements
• trace_context::is_valid_traceparent

Type Aliases

• SourcedResult

Constants

• bus::DEFAULT_BUS_NAMESPACE
• bus::MAX_MESSAGE_NAME_LEN
• bus::MAX_STABLE_MESSAGE_ID_LEN
• bus::MAX_TOPOLOGY_NAME_LEN
• entity::BITCODE_PAYLOAD_CODEC
• entity::BITCODE_PAYLOAD_CODEC_VERSION
• manifest::DISTRIBUTED_MANIFEST_SCHEMA_VERSION
• microsvc::DEFAULT_MAX_PUBLISH_ATTEMPTS
• microsvc::DEFAULT_PUBLISH_LEASE
• microsvc::ROLE_KEY
• microsvc::USER_ID_KEY
• outbox::OUTBOX_MESSAGES_TABLE
• outbox_worker::DEFAULT_OUTBOX_SOURCE_BATCH
• outbox_worker::DEFAULT_OUTBOX_SOURCE_LEASE
• outbox_worker::SOURCED_METADATA_PREFIX
• table::DEFAULT_TABLE_VERSION_COLUMN
• trace_context::CAUSATION_ID
• trace_context::CORRELATION_ID
• trace_context::TRACEPARENT
• trace_context::TRACESTATE