Struct BlockchainExecutionClient 

pub struct BlockchainExecutionClient { /* private fields */ }

Execution client for blockchain interactions including balance tracking and order execution.

Implementations

impl BlockchainExecutionClient

pub fn new( core_client: ExecutionClientCore, config: BlockchainExecutionClientConfig, ) -> Result<Self>

Creates a new BlockchainExecutionClient instance for the specified configuration.

Errors

Returns an error if the wallet address or any token address in the config is invalid.

Trait Implementations

impl Debug for BlockchainExecutionClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ExecutionClient for BlockchainExecutionClient

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.

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

Starts the execution client.

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

Stops the execution client.

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

Submits a single order command to the execution venue.

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

Submits a list of orders to the execution venue.

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

Modifies an existing order.

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

Cancels a specific order.

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

Cancels all orders.

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

Cancels a batch of orders.

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

Queries the status of an account.

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

Queries the status of an order.

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.

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.

impl LiveExecutionClient for BlockchainExecutionClient

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.

fn generate_order_status_reports<'life0, 'life1, 'async_trait>( &'life0 self, _cmd: &'life1 GenerateOrderStatusReport, ) -> 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.

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.

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

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

Generates position status reports.

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.