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>

pub fn data_engine_execute() -> MStr<Endpoint>

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 exec_engine_execute() -> MStr<Endpoint>

pub fn exec_engine_queue_execute() -> MStr<Endpoint>

pub fn exec_engine_process() -> MStr<Endpoint>

pub fn exec_engine_reconcile_execution_report() -> MStr<Endpoint>

pub fn risk_engine_execute() -> MStr<Endpoint>

pub fn risk_engine_queue_execute() -> MStr<Endpoint>

Queued endpoint for deferred command execution (re-entrancy safe). Falls back to direct endpoint when no TradingCommandSender is available (backtest / test environments).

pub fn risk_engine_process() -> MStr<Endpoint>

pub fn order_emulator_execute() -> MStr<Endpoint>

pub fn portfolio_update_account() -> 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 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_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_fills_topic( &mut self, instrument_id: InstrumentId, ) -> MStr<Topic>

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

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

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

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

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

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.