Struct PyDataActorInner

pub struct PyDataActorInner { /* private fields */ }

Inner actor that implements DataActor and can be used as the generic type parameter.

Holds the DataActorCore and implements the DataActor trait, allowing it to be used with the generic methods on DataActorCore.

Implementations

impl PyDataActorInner

pub fn new( config: DataActorConfig, cache: Rc<RefCell<Cache>>, clock: Rc<RefCell<dyn Clock>>, ) -> Self

pub fn core(&self) -> &DataActorCore

pub fn core_mut(&mut self) -> &mut DataActorCore

Trait Implementations

impl Actor for PyDataActorInner

fn id(&self) -> Ustr

The unique identifier for the actor.

fn handle(&mut self, msg: &dyn Any)

Handles the msg.

fn as_any(&self) -> &dyn Any

Returns a reference to self as Any, for downcasting support.

fn as_any_mut(&mut self) -> &mut dyn Any

where Self: Sized,

Returns a mutable reference to self as Any, for downcasting support.

impl DataActor for PyDataActorInner

fn state(&self) -> ComponentState

Returns the ComponentState of the actor.

fn is_ready(&self) -> bool

Returns true if the actor is in a Ready state.

fn is_running(&self) -> bool

Returns true if the actor is in a Running state.

fn is_stopped(&self) -> bool

Returns true if the actor is in a Stopped state.

fn is_disposed(&self) -> bool

Returns true if the actor is in a Disposed state.

fn is_degraded(&self) -> bool

Returns true if the actor is in a Degraded state.

fn is_faulted(&self) -> bool

Returns true if the actor is in a Faulted state.

fn on_save(&self) -> Result<IndexMap<String, Vec<u8>>>

Actions to be performed when the actor state is saved.

fn on_load(&mut self, state: IndexMap<String, Vec<u8>>) -> Result<()>

Actions to be performed when the actor state is loaded.

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_resume(&mut self) -> Result<()>

Actions to be performed on resume.

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 on_degrade(&mut self) -> Result<()>

Actions to be performed on degrade.

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

Actions to be performed on fault.

fn on_event(&mut self, event: &dyn Any) -> Result<()>

Actions to be performed when receiving an event.

fn on_time_event(&mut self, event: &TimeEvent) -> Result<()>

Actions to be performed when receiving a time event.

fn on_data(&mut self, data: &dyn Any) -> Result<()>

Actions to be performed when receiving custom data.

fn on_signal(&mut self, signal: &Signal) -> Result<()>

Actions to be performed when receiving a signal.

fn on_instrument(&mut self, instrument: &InstrumentAny) -> Result<()>

Actions to be performed when receiving an instrument.

fn on_book_deltas(&mut self, deltas: &OrderBookDeltas) -> Result<()>

Actions to be performed when receiving order book deltas.

fn on_book(&mut self, order_book: &OrderBook) -> Result<()>

Actions to be performed when receiving an order book.

fn on_quote(&mut self, quote: &QuoteTick) -> Result<()>

Actions to be performed when receiving a quote.

fn on_trade(&mut self, tick: &TradeTick) -> Result<()>

Actions to be performed when receiving a trade.

fn on_bar(&mut self, bar: &Bar) -> Result<()>

Actions to be performed when receiving a bar.

fn on_mark_price(&mut self, mark_price: &MarkPriceUpdate) -> Result<()>

Actions to be performed when receiving a mark price update.

fn on_index_price(&mut self, index_price: &IndexPriceUpdate) -> Result<()>

Actions to be performed when receiving an index price update.

fn on_instrument_status(&mut self, data: &InstrumentStatus) -> Result<()>

Actions to be performed when receiving an instrument status update.

fn on_instrument_close(&mut self, update: &InstrumentClose) -> Result<()>

Actions to be performed when receiving an instrument close update.

fn on_historical_data(&mut self, data: &dyn Any) -> Result<()>

Actions to be performed when receiving historical data.

fn on_historical_quotes(&mut self, quotes: &[QuoteTick]) -> Result<()>

Actions to be performed when receiving historical quotes.

fn on_historical_trades(&mut self, trades: &[TradeTick]) -> Result<()>

Actions to be performed when receiving historical trades.

fn on_historical_bars(&mut self, bars: &[Bar]) -> Result<()>

Actions to be performed when receiving historical bars.

fn on_historical_mark_prices( &mut self, mark_prices: &[MarkPriceUpdate], ) -> Result<()>

Actions to be performed when receiving historical mark prices.

fn on_historical_index_prices( &mut self, index_prices: &[IndexPriceUpdate], ) -> Result<()>

Actions to be performed when receiving historical index prices.

fn handle_data(&mut self, data: &dyn Any)

Handles a received custom data point.

fn handle_signal(&mut self, signal: &Signal)

Handles a received signal.

fn handle_instrument(&mut self, instrument: &InstrumentAny)

Handles a received instrument.

fn handle_book_deltas(&mut self, deltas: &OrderBookDeltas)

Handles received order book deltas.

fn handle_book(&mut self, book: &OrderBook)

Handles a received order book reference.

fn handle_quote(&mut self, quote: &QuoteTick)

Handles a received quote.

fn handle_trade(&mut self, trade: &TradeTick)

Handles a received trade.

fn handle_bar(&mut self, bar: &Bar)

Handles a receiving bar.

fn handle_mark_price(&mut self, mark_price: &MarkPriceUpdate)

Handles a received mark price update.

fn handle_index_price(&mut self, index_price: &IndexPriceUpdate)

Handles a received index price update.

fn handle_instrument_status(&mut self, status: &InstrumentStatus)

Handles a received instrument status.

fn handle_instrument_close(&mut self, close: &InstrumentClose)

Handles a received instrument close.

fn handle_historical_data(&mut self, data: &dyn Any)

Handles received historical data.

fn handle_time_event(&mut self, event: &TimeEvent)

Handles a received time event.

fn handle_event(&mut self, event: &dyn Any)

Handles a received event.

fn handle_data_response(&mut self, response: &CustomDataResponse)

Handles a data response.

fn handle_instrument_response(&mut self, response: &InstrumentResponse)

Handles an instrument response.

fn handle_instruments_response(&mut self, response: &InstrumentsResponse)

Handles an instruments response.

fn handle_book_response(&mut self, response: &BookResponse)

Handles a book response.

fn handle_quotes_response(&mut self, response: &QuotesResponse)

Handles a quotes response.

fn handle_trades_response(&mut self, response: &TradesResponse)

Handles a trades response.

fn handle_bars_response(&mut self, response: &BarsResponse)

Handles a bars response.

impl Debug for PyDataActorInner

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

Formats the value using the given formatter.