Struct CommandHandlerClient 

pub struct CommandHandlerClient { /* private fields */ }

Default command handler coordinator client using tonic gRPC.

Implementations

impl CommandHandlerClient

pub async fn connect(endpoint: &str) -> Result<Self>

Connect to a command handler coordinator at the given endpoint.

Supports both TCP (host:port) and Unix Domain Sockets (file paths).

pub async fn from_env(env_var: &str, default: &str) -> Result<Self>

Connect using an endpoint from environment variable with fallback.

pub fn from_channel(channel: Channel) -> Self

Create a client from an existing channel.

pub async fn handle_command( &self, command: CommandRequest, ) -> Result<CommandResponse>

Execute a command with specified sync mode.

Use SyncMode::Async for fire-and-forget (default). Use SyncMode::Simple to wait for sync projectors. Use SyncMode::Cascade for full sync including saga cascade.

pub async fn handle(&self, command: CommandBook) -> Result<CommandResponse>

Execute a command asynchronously (fire-and-forget).

Convenience method that wraps CommandBook in CommandRequest with async sync mode.

pub async fn handle_sync_speculative( &self, request: SpeculateCommandHandlerRequest, ) -> Result<CommandResponse>

Speculative execution against temporal state.

Trait Implementations

impl Clone for CommandHandlerClient

fn clone(&self) -> CommandHandlerClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl GatewayClient for CommandHandlerClient

fn execute<'life0, 'async_trait>( &'life0 self, command: CommandBook, ) -> Pin<Box<dyn Future<Output = Result<CommandResponse>> + Send + 'async_trait>>

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

Execute a command asynchronously (fire and forget).