Struct MessagingSwitchboard 

pub struct MessagingSwitchboard { /* private fields */ }

Represents a switchboard of built-in messaging endpoint names.

Implementations

impl MessagingSwitchboard

pub fn data_engine_queue_execute() -> MStr<Endpoint>

Queued entry point for DataEngine commands.

pub fn data_engine_execute() -> MStr<Endpoint>

Direct dispatch endpoint for DataEngine commands.

pub fn data_engine_process() -> MStr<Endpoint>

pub fn data_engine_process_data() -> MStr<Endpoint>

pub fn data_engine_process_defi_data() -> MStr<Endpoint>

pub fn data_engine_response() -> MStr<Endpoint>

pub fn data_response_topic() -> MStr<Topic>

pub fn time_event_topic() -> MStr<Topic>

Pub/sub topic used by the event-store tap for fired clock events.

pub fn exec_engine_execute() -> MStr<Endpoint>

Direct dispatch endpoint for ExecEngine commands.

pub fn exec_engine_queue_execute() -> MStr<Endpoint>

Queued entry point for ExecEngine commands.

pub fn exec_engine_process() -> MStr<Endpoint>

pub fn exec_engine_reconcile_execution_report() -> MStr<Endpoint>

pub fn risk_engine_execute() -> MStr<Endpoint>

Direct dispatch endpoint for RiskEngine commands.

pub fn risk_engine_queue_execute() -> MStr<Endpoint>

Queued entry point for RiskEngine commands.

pub fn risk_engine_process() -> MStr<Endpoint>

pub fn order_emulator_execute() -> MStr<Endpoint>

pub fn portfolio_update_account() -> MStr<Endpoint>

pub fn portfolio_update_order() -> MStr<Endpoint>

pub fn shutdown_system_topic() -> MStr<Topic>

Pub/sub topic carrying ShutdownSystem commands published by actors, engines, and strategies.

Matches the Python topic. The kernel subscribes to validate the command and signal graceful shutdown; additional components may subscribe to react to the same signal.

pub fn reconciliation_raw_order_status_report_topic() -> MStr<Topic>

Pub/sub topic carrying raw OrderStatusReports that arrived from a venue client, published by the execution engine at the top of reconciliation before any state mutation.

The event store bus tap captures publications on this topic so forensic replay can re-run reconciliation against the same raw inputs the live engine saw. Subscribers are not expected in production; the capture surface is the sole consumer today.

pub fn reconciliation_raw_fill_report_topic() -> MStr<Topic>

Pub/sub topic carrying raw FillReports that arrived from a venue client, published by the execution engine at the top of reconciliation before any state mutation.

See Self::reconciliation_raw_order_status_report_topic for the capture contract.

pub fn reconciliation_raw_position_status_report_topic() -> MStr<Topic>

Pub/sub topic carrying raw PositionStatusReports that arrived from a venue client, published by the execution engine at the top of reconciliation before any state mutation.

See Self::reconciliation_raw_order_status_report_topic for the capture contract.

pub fn instruments_pattern(&mut self, venue: Venue) -> MStr<Pattern>

Returns a wildcard pattern for matching all instrument topics for a venue.

pub fn signal_topic(&mut self, name: &str) -> MStr<Topic>

Returns the exact signal publish topic for name (data.Signal<TitleName>).

The title-cased encoding mirrors the v1 Python convention so subscribers keyed on either a specific name or the global data.Signal* wildcard receive published signals.

pub fn signal_pattern(&mut self, name: &str) -> MStr<Pattern>

Returns the subscription pattern for name (data.Signal<TitleName>*).

An empty name yields the wildcard data.Signal* that matches every signal topic.

pub fn get_custom_topic(&mut self, data_type: &DataType) -> MStr<Topic>

pub fn get_instruments_topic(&mut self, venue: Venue) -> MStr<Topic>

pub fn get_instrument_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_book_deltas_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_book_depth10_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_book_snapshots_topic( &mut self, instrument_id: InstrumentId, interval_ms: NonZeroUsize, ) -> MStr<Topic>

pub fn get_quotes_topic(&mut self, instrument_id: InstrumentId) -> MStr<Topic>

pub fn get_trades_topic(&mut self, instrument_id: InstrumentId) -> MStr<Topic>

pub fn get_bars_topic(&mut self, bar_type: BarType) -> MStr<Topic>

pub fn get_mark_price_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_index_price_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_funding_rate_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_funding_settlement_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_instrument_status_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_instrument_close_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_option_greeks_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_option_chain_topic( &mut self, series_id: OptionSeriesId, ) -> MStr<Topic>

pub fn get_order_submitted_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_order_rejected_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_order_pending_update_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_order_pending_cancel_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_order_modify_rejected_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_order_cancel_rejected_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_order_canceled_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_order_filled_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_event_order_topic(&mut self, strategy_id: StrategyId) -> MStr<Topic>

pub fn get_event_position_topic( &mut self, strategy_id: StrategyId, ) -> MStr<Topic>

pub fn get_snapshot_order_topic( &mut self, client_order_id: ClientOrderId, ) -> MStr<Topic>

pub fn get_snapshot_position_topic( &mut self, position_id: PositionId, ) -> MStr<Topic>

impl MessagingSwitchboard

pub fn get_pipeline_custom_topic(&mut self, data_type: &DataType) -> MStr<Topic>

pub fn get_pipeline_book_deltas_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_book_depth10_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_quotes_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_trades_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_bars_topic(&mut self, bar_type: BarType) -> MStr<Topic>

pub fn get_pipeline_mark_price_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_index_price_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_funding_rate_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_instrument_status_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_option_greeks_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_pipeline_instrument_close_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_book_deltas_pattern( &mut self, instrument_id: InstrumentId, ) -> MStr<Pattern>

Returns the subscription pattern for order book deltas on instrument_id.

pub fn get_book_depth10_pattern( &mut self, instrument_id: InstrumentId, ) -> MStr<Pattern>

Returns the subscription pattern for order book depth10 snapshots on instrument_id.

pub fn get_book_snapshots_pattern( &mut self, instrument_id: InstrumentId, interval_ms: NonZeroUsize, ) -> MStr<Pattern>

Returns the subscription pattern for periodic order book snapshots on instrument_id.

impl MessagingSwitchboard

pub fn get_defi_blocks_topic(&mut self, chain: Blockchain) -> MStr<Topic>

pub fn get_defi_pool_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_defi_pool_swaps_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_defi_pool_liquidity_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_defi_pool_collect_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

pub fn get_defi_pool_flash_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

Trait Implementations

impl Clone for MessagingSwitchboard

fn clone(&self) -> MessagingSwitchboard

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessagingSwitchboard

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

Formats the value using the given formatter.

impl Default for MessagingSwitchboard

fn default() -> Self

Creates a new default MessagingSwitchboard instance.