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, method_id: MethodId, response: &PostcardPayload, )

Store the sealed response for an operation. response is the postcard-encoded payload without schemas; method_id is needed at replay time to look up the response shape from the running code.

fn remove(&self, operation_id: OperationId)

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