Struct Trader 

pub struct Trader {
    pub trader_id: TraderId,
    pub instance_id: UUID4,
    pub environment: Environment,
    /* private fields */
}

Central orchestrator for managing trading components.

The Trader manages the lifecycle and coordination of actors, strategies, and execution algorithms within the trading system. It provides component registration, state management, and integration with system engines.

Fields

trader_id: TraderId

The unique trader identifier.

instance_id: UUID4

The unique instance identifier.

environment: Environment

The trading environment context.

Implementations

impl Trader

pub fn new( trader_id: TraderId, instance_id: UUID4, environment: Environment, clock: Rc<RefCell<dyn Clock>>, cache: Rc<RefCell<Cache>>, ) -> Self

Creates a new Trader instance.

pub const fn trader_id(&self) -> TraderId

Returns the trader ID.

pub const fn instance_id(&self) -> UUID4

Returns the instance ID.

pub const fn environment(&self) -> Environment

Returns the trading environment.

pub const fn state(&self) -> ComponentState

Returns the current component state.

pub const fn ts_created(&self) -> UnixNanos

Returns the timestamp when the trader was created (UNIX nanoseconds).

pub const fn ts_started(&self) -> Option<UnixNanos>

Returns the timestamp when the trader was last started (UNIX nanoseconds).

pub const fn ts_stopped(&self) -> Option<UnixNanos>

Returns the timestamp when the trader was last stopped (UNIX nanoseconds).

pub const fn actor_count(&self) -> usize

Returns the number of registered actors.

pub fn strategy_count(&self) -> usize

Returns the number of registered strategies.

pub fn exec_algorithm_count(&self) -> usize

Returns the number of registered execution algorithms.

pub fn component_count(&self) -> usize

Returns the total number of registered components.

pub fn actor_ids(&self) -> Vec<ActorId>

Returns a list of all registered actor IDs.

pub fn strategy_ids(&self) -> Vec<StrategyId>

Returns a list of all registered strategy IDs.

pub fn exec_algorithm_ids(&self) -> Vec<ExecAlgorithmId>

Returns a list of all registered execution algorithm IDs.

pub fn add_actor<T>(&mut self, actor: T) -> Result<()>

where T: DataActor + Component + Debug + 'static,

Adds an actor to the trader.

Errors

Returns an error if:

• The trader is not in a valid state for adding components.
• An actor with the same ID is already registered.

pub fn add_actor_from_factory<F, T>(&mut self, factory: F) -> Result<()>

where F: FnOnce() -> Result<T>, T: DataActor + Component + Debug + 'static,

Adds an actor to the trader using a factory function.

The factory function is called at registration time to create the actor, avoiding cloning issues with non-cloneable actor types.

Errors

Returns an error if:

• The factory function fails to create the actor.
• The trader is not in a valid state for adding components.
• An actor with the same ID is already registered.

pub fn add_registered_actor<T>(&mut self, actor: T) -> Result<()>

where T: DataActor + Component + Debug + 'static,

Adds an already registered actor to the trader’s component registry.

Errors

This function will return an error if the actor cannot be registered in the component registry.

pub fn add_actor_id_for_lifecycle(&mut self, actor_id: ActorId) -> Result<()>

Adds an actor ID to the trader’s lifecycle management without consuming the actor.

This is useful when the actor is already registered in the global component registry but the trader needs to track it for lifecycle management. The caller is responsible for ensuring the actor is properly registered in the global registries.

Errors

This function will return an error if the actor ID is already tracked by this trader.

pub fn add_strategy(&mut self, strategy: Box<dyn Component>) -> Result<()>

Adds a strategy to the trader.

Errors

Returns an error if:

• The trader is not in a valid state for adding components
• A strategy with the same ID is already registered

pub fn add_exec_algorithm( &mut self, exec_algorithm: Box<dyn Component>, ) -> Result<()>

Adds an execution algorithm to the trader.

Errors

Returns an error if:

• The trader is not in a valid state for adding components
• An execution algorithm with the same ID is already registered

pub fn start_components(&mut self) -> Result<()>

Starts all registered components.

Errors

Returns an error if any component fails to start.

pub fn stop_components(&mut self) -> Result<()>

Stops all registered components.

Errors

Returns an error if any component fails to stop.

pub fn reset_components(&mut self) -> Result<()>

Resets all registered components.

Errors

Returns an error if any component fails to reset.

pub fn dispose_components(&mut self) -> Result<()>

Disposes of all registered components.

Errors

Returns an error if any component fails to dispose.

pub fn initialize(&mut self) -> Result<()>

Initializes the trader, transitioning from PreInitialized to Ready state.

This method must be called before starting the trader.

Errors

Returns an error if the trader cannot be initialized from its current state.

Trait Implementations

impl Component for Trader

fn component_id(&self) -> ComponentId

Returns the unique identifier for this component.

fn state(&self) -> ComponentState

Returns the current state of the component.

fn transition_state(&mut self, trigger: ComponentTrigger) -> Result<()>

Transition the component with the state trigger.

fn register( &mut self, _trader_id: TraderId, _clock: Rc<RefCell<dyn Clock>>, _cache: Rc<RefCell<Cache>>, ) -> Result<()>

Registers the component with a system.

fn on_start(&mut self) -> Result<()>

Actions to be performed on start.

fn on_stop(&mut self) -> Result<()>

Actions to be performed on stop.

fn on_reset(&mut self) -> Result<()>

Actions to be performed on reset.

fn on_dispose(&mut self) -> Result<()>

Actions to be performed on dispose.

fn is_ready(&self) -> bool

Returns whether the component is ready.

fn not_running(&self) -> bool

Returns whether the component is not running.

fn is_running(&self) -> bool

Returns whether the component is running.

fn is_stopped(&self) -> bool

Returns whether the component is stopped.

fn is_degraded(&self) -> bool

Returns whether the component has been degraded.

fn is_faulted(&self) -> bool

Returns whether the component has been faulted.

fn is_disposed(&self) -> bool

Returns whether the component has been disposed.

fn initialize(&mut self) -> Result<(), Error>

Initializes the component.

fn start(&mut self) -> Result<(), Error>

Starts the component.

fn stop(&mut self) -> Result<(), Error>

Stops the component.

fn resume(&mut self) -> Result<(), Error>

Resumes the component.

fn degrade(&mut self) -> Result<(), Error>

Degrades the component.

fn fault(&mut self) -> Result<(), Error>

Faults the component.

fn reset(&mut self) -> Result<(), Error>

Resets the component to its initial state.

fn dispose(&mut self) -> Result<(), Error>

Disposes of the component, releasing any resources.

fn on_resume(&mut self) -> Result<(), Error>

Actions to be performed on resume.

fn on_degrade(&mut self) -> Result<(), Error>

Actions to be performed on degrade.

fn on_fault(&mut self) -> Result<(), Error>

Actions to be performed on fault.

impl Debug for Trader

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

Formats the value using the given formatter.