Struct InMemoryCommandRegistry 

pub struct InMemoryCommandRegistry { /* private fields */ }

In-memory implementation for tests and local development.

Tracks command metadata in memory. Targets are registered explicitly via register_target; resolution then follows exactly the production rules documented on CommandRegistry::resolve_target.

Implementations

impl InMemoryCommandRegistry

pub fn new() -> Self

Create a new in-memory registry whose Worker targets use Pull delivery (the safe default: matches platforms without a push path).

pub fn with_worker_delivery_mode( worker_delivery_mode: CommandDeliveryMode, ) -> Self

Create a new in-memory registry with the specified Worker delivery mode.

Container/Daemon targets are always Pull regardless of this setting.

pub async fn register_target( &self, resource_id: impl Into<String>, resource_type: CommandTargetType, ) -> Result<()>

Register a command-capable target that commands can resolve to.

Mirrors production, where the target set comes from the deployment’s stack (Stack::command_targets(): Worker/Container/Daemon resources with commands_enabled). The id is validated through the same shared guard as resolution, so a :-bearing id is rejected here at registration rather than surfacing later as a key-grammar collision.

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

List all command IDs (useful for debugging/testing)

Trait Implementations

impl CommandRegistry for InMemoryCommandRegistry

fn resolve_target<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, deployment_id: &'life1 str, requested: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<ResolvedCommandTarget>> + Send + 'async_trait>>

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

Resolve which command-capable resource a command is addressed to.

fn create_command<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, deployment_id: &'life1 str, command_name: &'life2 str, target: &'life3 ResolvedCommandTarget, 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, 'life3: 'async_trait,

Create a new command addressed to a previously resolved target 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<bool>> + Send + 'async_trait>>

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

Atomically update a non-terminal command’s lifecycle state.

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

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

Atomically transition a command from any NON-terminal state to the given terminal state.

fn mark_dispatched_if_not_terminal<'life0, 'life1, 'async_trait>( &'life0 self, command_id: &'life1 str, dispatched_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Atomically mark a command Dispatched unless it is already terminal.

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).

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

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

Get the canonical ownership fields used to authorize command reads.

impl Default for InMemoryCommandRegistry

fn default() -> Self

Returns the “default value” for a type.