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. Clones share the sender slot and observe later sender installations and replacements.

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

Installs or replaces the sender for this emitter and all its clones.

Call in the adapter’s start() method.

pub fn is_initialized(&self) -> bool

Returns true if the sender is initialized for this emitter and its clones.

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, info: Option<Params>, )

Generates and emits an account state event.

pub fn try_emit_account_state( &self, balances: Vec<AccountBalance>, margins: Vec<MarginBalance>, reported: bool, ts_event: UnixNanos, info: Option<Params>, ) -> Result<()>

Generates and emits an account state event, reporting dispatch failures.

Errors

Returns an error if the sender is uninitialized or its receiver is closed.

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 try_send_order_event(&self, event: OrderEventAny) -> Result<()>

Emits an order event and returns any channel error to the caller.

Errors

Returns an error if the sender is uninitialized or its receiver is closed.

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 try_send_execution_report(&self, report: ExecutionReport) -> Result<()>

Emits an execution report and returns any channel error to the caller.

Errors

Returns an error if the sender is not initialized or the receiving channel is closed.

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.