Struct InMemoryInboxStore 

pub struct InMemoryInboxStore { /* private fields */ }

In-memory inbox store implementation

Thread-safe storage using RwLock. Suitable for single-node deployments. For distributed deployments, use Redis-backed implementation.

Implementations

impl InMemoryInboxStore

pub fn new() -> Self

Create a new empty inbox store

pub fn shared() -> Arc<Self>

Create an Arc-wrapped instance for sharing

Trait Implementations

impl Default for InMemoryInboxStore

fn default() -> InMemoryInboxStore

Returns the “default value” for a type.

impl InboxStore for InMemoryInboxStore

fn push(&self, execution_id: &ExecutionId, message: InboxMessage)

Push a message to the inbox for a specific execution

fn len(&self, execution_id: &ExecutionId) -> usize

Get the number of pending messages for an execution

fn has_control_messages(&self, execution_id: &ExecutionId) -> bool

Check if there are any control messages (highest priority)

fn drain_messages(&self, execution_id: &ExecutionId) -> Vec<InboxMessage>

Drain all messages for an execution, sorted by priority

fn peek(&self, execution_id: &ExecutionId) -> Option<InboxMessage>

Peek at the next message without removing it

fn pop(&self, execution_id: &ExecutionId) -> Option<InboxMessage>

Pop the highest-priority message

fn clear(&self, execution_id: &ExecutionId)

Clear all messages for an execution

fn is_empty(&self, execution_id: &ExecutionId) -> bool

Check if there are any pending messages