Skip to main content

Crate soaprs_memory

Crate soaprs_memory 

Source
Expand description

Reference in-memory implementation of soaprs ports.

Structs§

MemoryEventBus
Subscription-order event bus for tests and single-process applications.
MemoryEventOutbox
In-memory event store and outbox sharing one atomic commit boundary.
MemoryEventStore
Append-only in-memory event store with optimistic concurrency checks.
MemoryInboxStore
In-memory idempotency records scoped by consumer name.
MemoryOutboxStore
In-memory outbox with exclusive, expiring worker claims.
MemoryProjectionCheckpointStore
In-memory monotonically advancing projection checkpoints.
MemoryRepository
Thread-safe in-memory repository used as a reference adapter.
MemorySagaActionStore
In-memory durable saga action and timer store.
MemorySagaOutbox
In-memory saga state and action outbox sharing one atomic commit boundary.
MemorySagaStore
In-memory application-defined saga state.
MemorySnapshotStore
In-memory latest-snapshot persistence.
MemoryStoredEventStore
Append-only in-memory persistence for serialized event payloads.
MemoryTransactionalProjection
In-memory reference projection with an atomic read-model/checkpoint boundary.
SubscriptionId
Opaque identity of an in-memory event subscription.

Traits§

Queryable
Provides logical field values to the in-memory query evaluator.