Struct ExecutionEventEmitter 

pub struct ExecutionEventEmitter { /* private fields */ }

Event emitter for live trading - combines event generation with async dispatch.

This struct wraps an OrderEventFactory for event construction and an unbounded channel sender for async dispatch. It provides emit_* convenience methods that generate and send events in a single call.

The sender is set during the adapter’s start() phase via set_sender.

Implementations

impl ExecutionEventEmitter

pub fn new( clock: &'static AtomicTime, trader_id: TraderId, account_id: AccountId, account_type: AccountType, base_currency: Option<Currency>, ) -> Self

Creates a new ExecutionEventEmitter with no sender.

Call set_sender in the adapter’s start() method.

pub fn set_sender(&mut self, sender: UnboundedSender<ExecutionEvent>)

Sets the sender. Call in adapter’s start().

pub fn is_initialized(&self) -> bool

Returns true if the sender is initialized.

pub fn trader_id(&self) -> TraderId

Returns the trader ID.

pub fn account_id(&self) -> AccountId

Returns the account ID.

pub fn set_account_id(&mut self, account_id: AccountId)

Sets the account ID for generated events.

pub fn emit_account_state( &self, balances: Vec<AccountBalance>, margins: Vec<MarginBalance>, reported: bool, ts_event: UnixNanos, )

Generates and emits an account state event.

pub fn emit_order_denied(&self, order: &OrderAny, reason: &str)

Generates and emits an order denied event.

pub fn emit_order_submitted(&self, order: &OrderAny)

Generates and emits an order submitted event.

pub fn emit_order_rejected( &self, order: &OrderAny, reason: &str, ts_event: UnixNanos, due_post_only: bool, )

Generates and emits an order rejected event.

pub fn emit_order_accepted( &self, order: &OrderAny, venue_order_id: VenueOrderId, ts_event: UnixNanos, )

Generates and emits an order accepted event.

pub fn emit_order_modify_rejected( &self, order: &OrderAny, venue_order_id: Option<VenueOrderId>, reason: &str, ts_event: UnixNanos, )

Generates and emits an order modify rejected event.

pub fn emit_order_cancel_rejected( &self, order: &OrderAny, venue_order_id: Option<VenueOrderId>, reason: &str, ts_event: UnixNanos, )

Generates and emits an order cancel rejected event.

pub fn emit_order_updated( &self, order: &OrderAny, venue_order_id: VenueOrderId, quantity: Quantity, price: Option<Price>, trigger_price: Option<Price>, protection_price: Option<Price>, ts_event: UnixNanos, )

Generates and emits an order updated event.

pub fn emit_order_canceled( &self, order: &OrderAny, venue_order_id: Option<VenueOrderId>, ts_event: UnixNanos, )

Generates and emits an order canceled event.

pub fn emit_order_triggered( &self, order: &OrderAny, venue_order_id: Option<VenueOrderId>, ts_event: UnixNanos, )

Generates and emits an order triggered event.

pub fn emit_order_expired( &self, order: &OrderAny, venue_order_id: Option<VenueOrderId>, ts_event: UnixNanos, )

Generates and emits an order expired event.

pub fn emit_order_filled( &self, order: &OrderAny, venue_order_id: VenueOrderId, venue_position_id: Option<PositionId>, trade_id: TradeId, last_qty: Quantity, last_px: Price, quote_currency: Currency, commission: Option<Money>, liquidity_side: LiquiditySide, ts_event: UnixNanos, )

Generates and emits an order filled event.

pub fn emit_order_rejected_event( &self, strategy_id: StrategyId, instrument_id: InstrumentId, client_order_id: ClientOrderId, reason: &str, ts_event: UnixNanos, due_post_only: bool, )

Constructs and emits an order rejected event from raw fields.

pub fn emit_order_modify_rejected_event( &self, strategy_id: StrategyId, instrument_id: InstrumentId, client_order_id: ClientOrderId, venue_order_id: Option<VenueOrderId>, reason: &str, ts_event: UnixNanos, )

Constructs and emits an order modify rejected event from raw fields.

pub fn emit_order_cancel_rejected_event( &self, strategy_id: StrategyId, instrument_id: InstrumentId, client_order_id: ClientOrderId, venue_order_id: Option<VenueOrderId>, reason: &str, ts_event: UnixNanos, )

Constructs and emits an order cancel rejected event from raw fields.

pub fn send_order_event(&self, event: OrderEventAny)

Emits an order event.

pub fn send_order_submitted_batch(&self, batch: OrderSubmittedBatch)

Emits a batch of order submitted events as a single channel message.

pub fn send_order_accepted_batch(&self, batch: OrderAcceptedBatch)

Emits a batch of order accepted events as a single channel message.

pub fn send_order_canceled_batch(&self, batch: OrderCanceledBatch)

Emits a batch of order canceled events as a single channel message.

pub fn send_account_state(&self, state: AccountState)

Emits an account state event.

pub fn send_execution_report(&self, report: ExecutionReport)

Emits an execution report.

pub fn send_order_status_report(&self, report: OrderStatusReport)

Emits an order status report.

pub fn send_fill_report(&self, report: FillReport)

Emits a fill report.

pub fn send_order_with_fills( &self, report: OrderStatusReport, fills: Vec<FillReport>, )

Emits an order status report bundled with the fills that produced it.

pub fn send_position_report(&self, report: PositionStatusReport)

Emits a position status report.

Trait Implementations

impl Clone for ExecutionEventEmitter

fn clone(&self) -> ExecutionEventEmitter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExecutionEventEmitter

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

Formats the value using the given formatter.