Struct InMemoryCommandRegistry 

pub struct InMemoryCommandRegistry { /* private fields */ }

In-memory implementation for tests and local development.

Tracks command metadata in memory. Configurable deployment model (defaults to Pull).

Implementations

impl InMemoryCommandRegistry

pub fn new() -> Self

Create a new in-memory registry with Pull deployment model (default).

pub fn with_deployment_model(deployment_model: DeploymentModel) -> Self

Create a new in-memory registry with the specified deployment model.

pub async fn list_command_ids(&self) -> Vec<String>

List all command IDs (useful for debugging/testing)

Trait Implementations

impl CommandRegistry for InMemoryCommandRegistry

fn create_command<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, deployment_id: &'life1 str, command_name: &'life2 str, initial_state: CommandState, deadline: Option<DateTime<Utc>>, request_size_bytes: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<CommandMetadata>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Create a new command and return metadata for routing.

fn get_command_metadata<'life0, 'life1, 'async_trait>( &'life0 self, command_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<CommandEnvelopeData>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get metadata needed to build an envelope during lease acquisition.

fn get_command_status<'life0, 'life1, 'async_trait>( &'life0 self, command_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<CommandStatus>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get full command status for status endpoint.

fn update_command_state<'life0, 'life1, 'async_trait>( &'life0 self, command_id: &'life1 str, state: CommandState, dispatched_at: Option<DateTime<Utc>>, completed_at: Option<DateTime<Utc>>, response_size_bytes: Option<u64>, error: Option<Value>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update command state during lifecycle (dispatched, completed, failed).

fn increment_attempt<'life0, 'life1, 'async_trait>( &'life0 self, command_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u32>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Increment attempt count (on lease release/expiry).

impl Default for InMemoryCommandRegistry

fn default() -> Self

Returns the “default value” for a type.