Module runner 

Global runtime machinery and thread-local storage.

This module provides global access to shared runtime resources including clocks, message queues, and time event channels. It manages thread-local storage for system-wide components that need to be accessible across threads.

Structs

SyncDataCommandSender

Synchronous DataCommandSender for backtest environments.

SyncTradingCommandSender

Synchronous TradingCommandSender for backtest environments.

TimeEventMessage

A send-safe live time event channel payload.

TradingCommandMessage

A deferred trading command and its direct endpoint.

Enums

SystemChannel

A monitored message channel feeding the runner event loop.

Traits

DataCommandSender

Trait for data command sending that can be implemented for both sync and async runners.

TimeEventSender

Trait for time event sending that can be implemented for both sync and async runners.

TradingCommandSender

Trait for trading command sending that can be implemented for both sync and async runners.

Functions

capture_trading_cmd

Captures a trading command for dispatch after the current endpoint handler returns.

data_cmd_queue_is_empty

Returns true if the data command queue is empty.

drain_data_cmd_queue

Drain all buffered data commands, dispatching each to the data engine.

drain_trading_cmd_queue

Drains all buffered trading commands to their direct endpoints.

get_data_cmd_sender

Gets the global data command sender.

get_time_event_sender

Gets the global time event sender.

get_trading_cmd_sender

Gets the global trading command sender.

replace_data_cmd_sender

Replaces the global data command sender for the current thread.

replace_exec_cmd_sender

Replaces the global trading command sender for the current thread.

replace_time_event_sender

Replaces the global time event sender for the current thread.

set_data_cmd_sender

Sets the global data command sender.

set_exec_cmd_sender

Sets the global trading command sender.

set_time_event_sender

Sets the global time event sender.

trading_cmd_is_dispatching

Returns true while a deferred trading command is being dispatched.

trading_cmd_queue_is_empty

Returns true if the trading command queue is empty.

try_get_time_event_sender

Attempts to get the global time event sender without panicking.

try_get_trading_cmd_sender

Attempts to get the global trading command sender without panicking.