Struct ExecutionClientAdapter 

pub struct ExecutionClientAdapter {
    pub client_id: ClientId,
    pub venue: Venue,
    pub account_id: AccountId,
    pub oms_type: OmsType,
    /* private fields */
}

Wraps an [ExecutionClient], managing its lifecycle and providing access to the client.

Fields

client_id: ClientId

venue: Venue

account_id: AccountId

oms_type: OmsType

Implementations

impl ExecutionClientAdapter

pub fn new(client: Box<dyn ExecutionClient>) -> Self

Creates a new ExecutionClientAdapter with the given client.

pub async fn connect(&mut self) -> Result<()>

Connects the execution client to the venue.

Errors

Returns an error if connection fails.

pub async fn disconnect(&mut self) -> Result<()>

Disconnects the execution client from the venue.

Errors

Returns an error if disconnection fails.

pub async fn generate_order_status_report( &self, cmd: &GenerateOrderStatusReport, ) -> Result<Option<OrderStatusReport>>

Generates a single order status report.

Errors

Returns an error if report generation fails.

pub async fn generate_order_status_reports( &self, cmd: &GenerateOrderStatusReports, ) -> Result<Vec<OrderStatusReport>>

Generates multiple order status reports.

Errors

Returns an error if report generation fails.

pub async fn generate_fill_reports( &self, cmd: GenerateFillReports, ) -> Result<Vec<FillReport>>

Generates fill reports based on execution results.

Errors

Returns an error if fill report generation fails.

pub async fn generate_position_status_reports( &self, cmd: &GeneratePositionStatusReports, ) -> Result<Vec<PositionStatusReport>>

Generates position status reports.

Errors

Returns an error if generation fails.

pub async fn generate_mass_status( &self, lookback_mins: Option<u64>, ) -> Result<Option<ExecutionMassStatus>>

Generates mass status for executions.

Errors

Returns an error if status generation fails.

pub fn register_external_order( &self, client_order_id: ClientOrderId, venue_order_id: VenueOrderId, instrument_id: InstrumentId, strategy_id: StrategyId, ts_init: UnixNanos, )

Registers an external order for tracking by the execution client.

This is called after reconciliation creates an external order, allowing the execution client to track it for subsequent events (e.g., cancellations).

Trait Implementations

impl Debug for ExecutionClientAdapter

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

Formats the value using the given formatter.

impl Deref for ExecutionClientAdapter

type Target = Box<dyn ExecutionClient>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for ExecutionClientAdapter

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.