Struct InMemoryOperationStore 

pub struct InMemoryOperationStore { /* private fields */ }

Default in-memory operation store.

Implementations

impl InMemoryOperationStore

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryOperationStore

fn default() -> Self

Returns the “default value” for a type.

impl OperationStore for InMemoryOperationStore

fn admit(&self, operation_id: OperationId)

Record that we’re starting to process this operation.

fn lookup(&self, operation_id: OperationId) -> OperationState

Check the state of an operation.

fn get_sealed(&self, operation_id: OperationId) -> Option<SealedResponse>

Retrieve a sealed response.

fn seal( &self, operation_id: OperationId, response: &PostcardPayload, root_type: &TypeRef, registry: &SchemaRegistry, )

Store the sealed response for an operation.

fn remove(&self, operation_id: OperationId)

Remove an admitted (but not sealed) operation, e.g. after handler failure.

fn schema_source(&self) -> &dyn SchemaSource

Access the store’s schema source for looking up schemas by hash.

impl SchemaSource for InMemoryOperationStore

fn get_schema(&self, id: SchemaHash) -> Option<Schema>