Struct PyDataActor

pub struct PyDataActor { /* private fields */ }

Provides a generic DataActor.

Implementations

impl PyDataActor

pub fn register( &mut self, trader_id: TraderId, cache: Rc<RefCell<Cache>>, clock: Rc<RefCell<dyn Clock>>, ) -> PyResult<()>

TODO: WIP This method should be called to properly initialize the actor with cache, clock and other components.

Errors

Returns an error if already registered.

Trait Implementations

impl Actor for PyDataActor

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 PyDataActor

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 PyDataActor

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

Formats the value using the given formatter.

impl IntoPy<Py<PyAny>> for PyDataActor

fn into_py(self, py: Python<'_>) -> PyObject

👎Deprecated since 0.23.0: IntoPy is going to be replaced by IntoPyObject. See the migration guide (https://pyo3.rs/v0.23.0/migration) for more information.

Performs the conversion.

impl<'py> IntoPyObject<'py> for PyDataActor

type Target = PyDataActor

The Python output type

type Output = Bound<'py, <PyDataActor as IntoPyObject<'py>>::Target>

The smart pointer type to use.

type Error = PyErr

The type returned in the event of a conversion error.

fn into_pyobject( self, py: Python<'py>, ) -> Result<<Self as IntoPyObject<'_>>::Output, <Self as IntoPyObject<'_>>::Error>

Performs the conversion.

impl PyClass for PyDataActor

type Frozen = False

Whether the pyclass is frozen.

impl PyClassImpl for PyDataActor

const IS_BASETYPE: bool = false

#[pyclass(subclass)]

const IS_SUBCLASS: bool = false

#[pyclass(extends=…)]

const IS_MAPPING: bool = false

#[pyclass(mapping)]

const IS_SEQUENCE: bool = false

#[pyclass(sequence)]

type BaseType = PyAny

Base class

type ThreadChecker = ThreadCheckerImpl

This handles following two situations:

type PyClassMutability = <<PyAny as PyClassBaseType>::PyClassMutability as PyClassMutability>::MutableChild

Immutable or mutable

type Dict = PyClassDummySlot

Specify this class has #[pyclass(dict)] or not.

type WeakRef = PyClassDummySlot

Specify this class has #[pyclass(weakref)] or not.

type BaseNativeType = PyAny

The closest native ancestor. This is PyAny by default, and when you declare #[pyclass(extends=PyDict)], it’s PyDict.

fn items_iter() -> PyClassItemsIter

fn doc(py: Python<'_>) -> PyResult<&'static CStr>

Rendered class doc

fn lazy_type_object() -> &'static LazyTypeObject<Self>

fn dict_offset() -> Option<isize>

fn weaklist_offset() -> Option<isize>

impl PyClassNewTextSignature<PyDataActor> for PyClassImplCollector<PyDataActor>

fn new_text_signature(self) -> Option<&'static str>

impl<'a, 'py> PyFunctionArgument<'a, 'py, false> for &'a PyDataActor

type Holder = Option<PyRef<'py, PyDataActor>>

fn extract( obj: &'a Bound<'py, PyAny>, holder: &'a mut Self::Holder, ) -> PyResult<Self>

impl<'a, 'py> PyFunctionArgument<'a, 'py, false> for &'a mut PyDataActor

type Holder = Option<PyRefMut<'py, PyDataActor>>

fn extract( obj: &'a Bound<'py, PyAny>, holder: &'a mut Self::Holder, ) -> PyResult<Self>

impl PyMethods<PyDataActor> for PyClassImplCollector<PyDataActor>

fn py_methods(self) -> &'static PyClassItems

impl PyTypeInfo for PyDataActor

const NAME: &'static str = "DataActor"

Class name.

const MODULE: Option<&'static str>

Module name, if any.

fn type_object_raw(py: Python<'_>) -> *mut PyTypeObject

Returns the PyTypeObject instance for this type.

fn type_object(py: Python<'_>) -> Bound<'_, PyType>

Returns the safe abstraction over the type object.

fn type_object_bound(py: Python<'_>) -> Bound<'_, PyType>

👎Deprecated since 0.23.0: renamed to PyTypeInfo::type_object

Deprecated name for [PyTypeInfo::type_object].

fn is_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type or a subclass of this type.

fn is_type_of_bound(object: &Bound<'_, PyAny>) -> bool

👎Deprecated since 0.23.0: renamed to PyTypeInfo::is_type_of

Deprecated name for [PyTypeInfo::is_type_of].

fn is_exact_type_of(object: &Bound<'_, PyAny>) -> bool

Checks if object is an instance of this type.

fn is_exact_type_of_bound(object: &Bound<'_, PyAny>) -> bool

👎Deprecated since 0.23.0: renamed to PyTypeInfo::is_exact_type_of

Deprecated name for [PyTypeInfo::is_exact_type_of].

impl DerefToPyAny for PyDataActor