Struct DomainClient 

pub struct DomainClient {
    pub command_handler: CommandHandlerClient,
    pub query: QueryClient,
    pub speculative: SpeculativeClient,
}

Per-domain client combining command execution, event querying, and speculative operations.

Connects to a single domain’s endpoint and provides:

• Command execution via command_handler
• Event querying via query
• Speculative (what-if) execution via speculative

Matches the distributed architecture where each domain has its own coordinator service.

Fields

command_handler: CommandHandlerClient

Command handler client for command execution.

query: QueryClient

Query client for event retrieval.

speculative: SpeculativeClient

Speculative client for dry-run and what-if scenarios.

Implementations

impl DomainClient

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

Connect to a domain’s 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 execute(&self, command: CommandBook) -> Result<CommandResponse>

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

Use execute_with_mode() to specify a different sync mode.

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

Execute a command with the 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 get_events(&self, query: Query) -> Result<EventBook>

Query events (delegates to query client).

Trait Implementations

impl Clone for DomainClient

fn clone(&self) -> DomainClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl GatewayClient for DomainClient

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

impl QueryClient for DomainClient

fn get_events<'life0, 'async_trait>( &'life0 self, query: Query, ) -> Pin<Box<dyn Future<Output = Result<EventBook>> + Send + 'async_trait>>

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

Get events for the given query.