Trait ExecutionClient 

pub trait ExecutionClient {
    // Required methods
    fn is_connected(&self) -> bool;
    fn client_id(&self) -> ClientId;
    fn account_id(&self) -> AccountId;
    fn venue(&self) -> Venue;
    fn oms_type(&self) -> OmsType;
    fn get_account(&self) -> Option<AccountAny>;
    fn generate_account_state(
        &self,
        balances: Vec<AccountBalance>,
        margins: Vec<MarginBalance>,
        reported: bool,
        ts_event: UnixNanos,
    ) -> Result<()>;
    fn start(&mut self) -> Result<()>;
    fn stop(&mut self) -> Result<()>;

    // Provided methods
    fn connect<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn disconnect<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn submit_order(&self, cmd: &SubmitOrder) -> Result<()> { ... }
    fn submit_order_list(&self, cmd: &SubmitOrderList) -> Result<()> { ... }
    fn modify_order(&self, cmd: &ModifyOrder) -> Result<()> { ... }
    fn cancel_order(&self, cmd: &CancelOrder) -> Result<()> { ... }
    fn cancel_all_orders(&self, cmd: &CancelAllOrders) -> Result<()> { ... }
    fn batch_cancel_orders(&self, cmd: &BatchCancelOrders) -> Result<()> { ... }
    fn query_account(&self, cmd: &QueryAccount) -> Result<()> { ... }
    fn query_order(&self, cmd: &QueryOrder) -> Result<()> { ... }
    fn generate_order_status_report<'life0, 'life1, 'async_trait>(
        &'life0 self,
        cmd: &'life1 GenerateOrderStatusReport,
    ) -> Pin<Box<dyn Future<Output = Result<Option<OrderStatusReport>>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait { ... }
    fn generate_order_status_reports<'life0, 'life1, 'async_trait>(
        &'life0 self,
        cmd: &'life1 GenerateOrderStatusReports,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<OrderStatusReport>>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait { ... }
    fn generate_fill_reports<'life0, 'async_trait>(
        &'life0 self,
        cmd: GenerateFillReports,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<FillReport>>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn generate_position_status_reports<'life0, 'life1, 'async_trait>(
        &'life0 self,
        cmd: &'life1 GeneratePositionStatusReports,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<PositionStatusReport>>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait { ... }
    fn generate_mass_status<'life0, 'async_trait>(
        &'life0 self,
        lookback_mins: Option<u64>,
    ) -> Pin<Box<dyn Future<Output = Result<Option<ExecutionMassStatus>>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
}

Defines the interface for an execution client managing order operations.

Thread Safety

Client instances are not intended to be sent across threads. The ?Send bound allows implementations to hold non-Send state for any Python interop.

Required Methods

fn is_connected(&self) -> bool

fn client_id(&self) -> ClientId

fn account_id(&self) -> AccountId

fn venue(&self) -> Venue

fn oms_type(&self) -> OmsType

fn get_account(&self) -> Option<AccountAny>

fn generate_account_state( &self, balances: Vec<AccountBalance>, margins: Vec<MarginBalance>, reported: bool, ts_event: UnixNanos, ) -> Result<()>

Generates and publishes the account state event.

Errors

Returns an error if generating the account state fails.

fn start(&mut self) -> Result<()>

Starts the execution client.

Errors

Returns an error if the client fails to start.

fn stop(&mut self) -> Result<()>

Stops the execution client.

Errors

Returns an error if the client fails to stop.

Provided Methods

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>

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

Connects the client to the execution venue.

Errors

Returns an error if connection fails.

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>

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

Disconnects the client from the execution venue.

Errors

Returns an error if disconnection fails.

fn submit_order(&self, cmd: &SubmitOrder) -> Result<()>

Submits a single order command to the execution venue.

Errors

Returns an error if submission fails.

fn submit_order_list(&self, cmd: &SubmitOrderList) -> Result<()>

Submits a list of orders to the execution venue.

Errors

Returns an error if submission fails.

fn modify_order(&self, cmd: &ModifyOrder) -> Result<()>

Modifies an existing order.

Errors

Returns an error if modification fails.

fn cancel_order(&self, cmd: &CancelOrder) -> Result<()>

Cancels a specific order.

Errors

Returns an error if cancellation fails.

fn cancel_all_orders(&self, cmd: &CancelAllOrders) -> Result<()>

Cancels all orders.

Errors

Returns an error if cancellation fails.

fn batch_cancel_orders(&self, cmd: &BatchCancelOrders) -> Result<()>

Cancels a batch of orders.

Errors

Returns an error if batch cancellation fails.

fn query_account(&self, cmd: &QueryAccount) -> Result<()>

Queries the status of an account.

Errors

Returns an error if the query fails.

fn query_order(&self, cmd: &QueryOrder) -> Result<()>

Queries the status of an order.

Errors

Returns an error if the query fails.

fn generate_order_status_report<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GenerateOrderStatusReport, ) -> Pin<Box<dyn Future<Output = Result<Option<OrderStatusReport>>> + 'async_trait>>

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

Generates a single order status report.

Errors

Returns an error if report generation fails.

fn generate_order_status_reports<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GenerateOrderStatusReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<OrderStatusReport>>> + 'async_trait>>

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

Generates multiple order status reports.

Errors

Returns an error if report generation fails.

fn generate_fill_reports<'life0, 'async_trait>( &'life0 self, cmd: GenerateFillReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<FillReport>>> + 'async_trait>>

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

Generates fill reports based on execution results.

Errors

Returns an error if fill report generation fails.

fn generate_position_status_reports<'life0, 'life1, 'async_trait>( &'life0 self, cmd: &'life1 GeneratePositionStatusReports, ) -> Pin<Box<dyn Future<Output = Result<Vec<PositionStatusReport>>> + 'async_trait>>

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

Generates position status reports.

Errors

Returns an error if generation fails.

fn generate_mass_status<'life0, 'async_trait>( &'life0 self, lookback_mins: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Option<ExecutionMassStatus>>> + 'async_trait>>

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

Generates mass status for executions.

Errors

Returns an error if status generation fails.

Implementors