Trait DataActor 

pub trait DataActor {
    // Provided methods
    fn actor_id(&self) -> ActorId
       where Self: DataActorNative { ... }
    fn trader_id(&self) -> Option<TraderId>
       where Self: DataActorNative { ... }
    fn is_registered(&self) -> bool
       where Self: DataActorNative { ... }
    fn config(&self) -> &DataActorConfig
       where Self: DataActorNative { ... }
    fn on_save(&self) -> Result<IndexMap<String, Vec<u8>>> { ... }
    fn on_load(&mut self, state: IndexMap<String, Vec<u8>>) -> Result<()> { ... }
    fn on_start(&mut self) -> Result<()> { ... }
    fn on_stop(&mut self) -> Result<()> { ... }
    fn on_resume(&mut self) -> Result<()> { ... }
    fn on_reset(&mut self) -> Result<()> { ... }
    fn on_dispose(&mut self) -> Result<()> { ... }
    fn on_degrade(&mut self) -> Result<()> { ... }
    fn on_fault(&mut self) -> Result<()> { ... }
    fn on_time_event(&mut self, event: &TimeEvent) -> Result<()> { ... }
    fn on_data(&mut self, data: &CustomData) -> Result<()> { ... }
    fn on_signal(&mut self, signal: &Signal) -> Result<()> { ... }
    fn on_queue_state(&mut self, event: &QueueStateChanged) -> Result<()> { ... }
    fn on_socket_state(&mut self, event: &SocketStateChanged) -> Result<()> { ... }
    fn on_instrument(&mut self, instrument: &InstrumentAny) -> Result<()> { ... }
    fn on_book_deltas(&mut self, deltas: &OrderBookDeltas) -> Result<()> { ... }
    fn on_book_depth(&mut self, depth: &OrderBookDepth10) -> Result<()> { ... }
    fn on_book(&mut self, order_book: &OrderBook) -> Result<()> { ... }
    fn on_quote(&mut self, quote: &QuoteTick) -> Result<()> { ... }
    fn on_trade(&mut self, tick: &TradeTick) -> Result<()> { ... }
    fn on_bar(&mut self, bar: &Bar) -> Result<()> { ... }
    fn on_mark_price(&mut self, mark_price: &MarkPriceUpdate) -> Result<()> { ... }
    fn on_index_price(&mut self, index_price: &IndexPriceUpdate) -> Result<()> { ... }
    fn on_funding_rate(
        &mut self,
        funding_rate: &FundingRateUpdate,
    ) -> Result<()> { ... }
    fn on_option_greeks(&mut self, greeks: &OptionGreeks) -> Result<()> { ... }
    fn on_option_chain(&mut self, slice: &OptionChainSlice) -> Result<()> { ... }
    fn on_instrument_status(&mut self, data: &InstrumentStatus) -> Result<()> { ... }
    fn on_instrument_close(&mut self, update: &InstrumentClose) -> Result<()> { ... }
    fn on_block(&mut self, block: &Block) -> Result<()> { ... }
    fn on_pool(&mut self, pool: &Pool) -> Result<()> { ... }
    fn on_pool_swap(&mut self, swap: &PoolSwap) -> Result<()> { ... }
    fn on_pool_liquidity_update(
        &mut self,
        update: &PoolLiquidityUpdate,
    ) -> Result<()> { ... }
    fn on_pool_fee_collect(&mut self, collect: &PoolFeeCollect) -> Result<()> { ... }
    fn on_pool_flash(&mut self, flash: &PoolFlash) -> Result<()> { ... }
    fn on_historical_data(&mut self, data: &dyn Any) -> Result<()> { ... }
    fn on_historical_book_deltas(
        &mut self,
        deltas: &[OrderBookDelta],
    ) -> Result<()> { ... }
    fn on_historical_book_depth(
        &mut self,
        depths: &[OrderBookDepth10],
    ) -> Result<()> { ... }
    fn on_historical_quotes(&mut self, quotes: &[QuoteTick]) -> Result<()> { ... }
    fn on_historical_trades(&mut self, trades: &[TradeTick]) -> Result<()> { ... }
    fn on_historical_bars(&mut self, bars: &[Bar]) -> Result<()> { ... }
    fn on_historical_mark_prices(
        &mut self,
        mark_prices: &[MarkPriceUpdate],
    ) -> Result<()> { ... }
    fn on_historical_index_prices(
        &mut self,
        index_prices: &[IndexPriceUpdate],
    ) -> Result<()> { ... }
    fn on_historical_funding_rates(
        &mut self,
        funding_rates: &[FundingRateUpdate],
    ) -> Result<()> { ... }
    fn clock(&self) -> ClockApi<'_>
       where Self: DataActorNative { ... }
    fn cache(&self) -> CacheApi<'_>
       where Self: DataActorNative { ... }
    fn shutdown_system(&self, reason: Option<String>)
       where Self: DataActorNative { ... }
    fn publish_data(&self, data_type: &DataType, data: &CustomData)
       where Self: DataActorNative { ... }
    fn publish_signal(&self, name: &str, value: String, ts_event: UnixNanos)
       where Self: DataActorNative { ... }
    fn add_synthetic(&self, synthetic: SyntheticInstrument) -> Result<()>
       where Self: DataActorNative { ... }
    fn update_synthetic(&self, synthetic: SyntheticInstrument) -> Result<()>
       where Self: DataActorNative { ... }
    fn handle_time_event(&mut self, event: &TimeEvent)
       where Self: Component { ... }
    fn handle_data(&mut self, data: &CustomData)
       where Self: Component { ... }
    fn handle_signal(&mut self, signal: &Signal)
       where Self: Component { ... }
    fn handle_queue_state(&mut self, event: &QueueStateChanged)
       where Self: Component { ... }
    fn handle_socket_state(&mut self, event: &SocketStateChanged)
       where Self: Component { ... }
    fn handle_instrument(&mut self, instrument: &InstrumentAny)
       where Self: Component { ... }
    fn handle_book_deltas(&mut self, deltas: &OrderBookDeltas)
       where Self: Component { ... }
    fn handle_book_depth(&mut self, depth: &OrderBookDepth10)
       where Self: Component { ... }
    fn handle_book(&mut self, book: &OrderBook)
       where Self: Component { ... }
    fn handle_quote(&mut self, quote: &QuoteTick)
       where Self: DataActorNative + Component { ... }
    fn handle_trade(&mut self, trade: &TradeTick)
       where Self: DataActorNative + Component { ... }
    fn handle_bar(&mut self, bar: &Bar)
       where Self: DataActorNative + Component { ... }
    fn handle_mark_price(&mut self, mark_price: &MarkPriceUpdate)
       where Self: Component { ... }
    fn handle_index_price(&mut self, index_price: &IndexPriceUpdate)
       where Self: Component { ... }
    fn handle_funding_rate(&mut self, funding_rate: &FundingRateUpdate)
       where Self: Component { ... }
    fn handle_option_greeks(&mut self, greeks: &OptionGreeks)
       where Self: Component { ... }
    fn handle_option_chain(&mut self, slice: &OptionChainSlice)
       where Self: Component { ... }
    fn handle_instrument_status(&mut self, status: &InstrumentStatus)
       where Self: Component { ... }
    fn handle_instrument_close(&mut self, close: &InstrumentClose)
       where Self: Component { ... }
    fn handle_block(&mut self, block: &Block)
       where Self: Component { ... }
    fn handle_pool(&mut self, pool: &Pool)
       where Self: Component { ... }
    fn handle_pool_swap(&mut self, swap: &PoolSwap)
       where Self: Component { ... }
    fn handle_pool_liquidity_update(&mut self, update: &PoolLiquidityUpdate)
       where Self: Component { ... }
    fn handle_pool_fee_collect(&mut self, collect: &PoolFeeCollect)
       where Self: Component { ... }
    fn handle_pool_flash(&mut self, flash: &PoolFlash)
       where Self: Component { ... }
    fn handle_historical_data(&mut self, data: &dyn Any) { ... }
    fn handle_data_response(&mut self, resp: &CustomDataResponse) { ... }
    fn handle_instrument_response(&mut self, resp: &InstrumentResponse) { ... }
    fn handle_instruments_response(&mut self, resp: &InstrumentsResponse) { ... }
    fn handle_book_response(&mut self, resp: &BookResponse) { ... }
    fn handle_book_deltas_response(&mut self, resp: &BookDeltasResponse) { ... }
    fn handle_book_depth_response(&mut self, resp: &BookDepthResponse) { ... }
    fn handle_quotes_response(&mut self, resp: &QuotesResponse)
       where Self: DataActorNative { ... }
    fn handle_trades_response(&mut self, resp: &TradesResponse)
       where Self: DataActorNative { ... }
    fn handle_bars_response(&mut self, resp: &BarsResponse)
       where Self: DataActorNative { ... }
    fn handle_funding_rates_response(&mut self, resp: &FundingRatesResponse) { ... }
    fn subscribe_data(
        &mut self,
        data_type: DataType,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_signal(&mut self, name: &str, priority: Option<u32>)
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_queue_state(&mut self, priority: Option<u32>)
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_socket_state(&mut self, priority: Option<u32>)
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_quotes(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_instruments(
        &mut self,
        venue: Venue,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_instrument(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_book_deltas(
        &mut self,
        instrument_id: InstrumentId,
        book_type: BookType,
        depth: Option<NonZeroUsize>,
        client_id: Option<ClientId>,
        managed: bool,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_book_depth10(
        &mut self,
        instrument_id: InstrumentId,
        book_type: BookType,
        client_id: Option<ClientId>,
        managed: bool,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_book_at_interval(
        &mut self,
        instrument_id: InstrumentId,
        book_type: BookType,
        depth: Option<NonZeroUsize>,
        interval_ms: NonZeroUsize,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_trades(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_bars(
        &mut self,
        bar_type: BarType,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_mark_prices(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_index_prices(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_funding_rates(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_option_greeks(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_instrument_status(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_instrument_close(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_option_chain(
        &mut self,
        series_id: OptionSeriesId,
        strike_range: StrikeRange,
        snapshot_interval_ms: Option<u64>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_blocks(
        &mut self,
        chain: Blockchain,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_pool(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_pool_swaps(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_pool_liquidity_updates(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_pool_fee_collects(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn subscribe_pool_flash_events(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_data(
        &mut self,
        data_type: DataType,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_signal(&mut self, name: &str)
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_queue_state(&mut self)
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_socket_state(&mut self)
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_instruments(
        &mut self,
        venue: Venue,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_instrument(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_book_deltas(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_book_depth10(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_book_at_interval(
        &mut self,
        instrument_id: InstrumentId,
        interval_ms: NonZeroUsize,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_quotes(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_trades(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_bars(
        &mut self,
        bar_type: BarType,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_mark_prices(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_index_prices(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_funding_rates(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_option_greeks(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_instrument_status(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_instrument_close(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_option_chain(
        &mut self,
        series_id: OptionSeriesId,
        client_id: Option<ClientId>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_blocks(
        &mut self,
        chain: Blockchain,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_pool(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_pool_swaps(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_pool_liquidity_updates(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_pool_fee_collects(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn unsubscribe_pool_flash_events(
        &mut self,
        instrument_id: InstrumentId,
        client_id: Option<ClientId>,
        params: Option<Params>,
    )
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_data(
        &mut self,
        data_type: DataType,
        client_id: ClientId,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        limit: Option<NonZeroUsize>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_instrument(
        &mut self,
        instrument_id: InstrumentId,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_instruments(
        &mut self,
        venue: Option<Venue>,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_book_snapshot(
        &mut self,
        instrument_id: InstrumentId,
        depth: Option<NonZeroUsize>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_book_deltas(
        &mut self,
        instrument_id: InstrumentId,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        limit: Option<NonZeroUsize>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_book_depth(
        &mut self,
        instrument_id: InstrumentId,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        limit: Option<NonZeroUsize>,
        depth: Option<NonZeroUsize>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_quotes(
        &mut self,
        instrument_id: InstrumentId,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        limit: Option<NonZeroUsize>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_trades(
        &mut self,
        instrument_id: InstrumentId,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        limit: Option<NonZeroUsize>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_bars(
        &mut self,
        bar_type: BarType,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        limit: Option<NonZeroUsize>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn request_funding_rates(
        &mut self,
        instrument_id: InstrumentId,
        start: Option<Timestamp>,
        end: Option<Timestamp>,
        limit: Option<NonZeroUsize>,
        client_id: Option<ClientId>,
        params: Option<Params>,
    ) -> Result<UUID4>
       where Self: DataActorNative + 'static + Debug + Sized { ... }
    fn reconnect_socket(
        &self,
        client_id: ClientId,
        endpoint: &str,
    ) -> Result<()>
       where Self: DataActorNative { ... }
}

Defines lifecycle callbacks, data handlers, and subscription/request methods for data actors.

Default methods that read or mutate native runtime state carry explicit DataActorNative and Component bounds. Implementations that only need behavioral callbacks do not own or implement native runtime state.

Provided Methods

fn actor_id(&self) -> ActorId

where Self: DataActorNative,

Returns the actor ID.

fn trader_id(&self) -> Option<TraderId>

where Self: DataActorNative,

Returns the trader ID this actor is registered to.

fn is_registered(&self) -> bool

where Self: DataActorNative,

Returns whether the actor is registered with a trader.

fn config(&self) -> &DataActorConfig

where Self: DataActorNative,

Returns the actor configuration.

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

Actions to be performed when the actor state is saved.

Errors

Returns an error if saving the actor state fails.

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

Actions to be performed when the actor state is loaded.

Errors

Returns an error if loading the actor state fails.

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

Actions to be performed on start.

Errors

Returns an error if starting the actor fails.

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

Actions to be performed on stop.

Errors

Returns an error if stopping the actor fails.

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

Actions to be performed on resume.

Errors

Returns an error if resuming the actor fails.

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

Actions to be performed on reset.

Errors

Returns an error if resetting the actor fails.

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

Actions to be performed on dispose.

Errors

Returns an error if disposing the actor fails.

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

Actions to be performed on degrade.

Errors

Returns an error if degrading the actor fails.

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

Actions to be performed on fault.

Errors

Returns an error if faulting the actor fails.

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

Actions to be performed when receiving a time event.

Errors

Returns an error if handling the time event fails.

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

Actions to be performed when receiving custom data.

Errors

Returns an error if handling the data fails.

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

Actions to be performed when receiving a signal.

Errors

Returns an error if handling the signal fails.

fn on_queue_state(&mut self, event: &QueueStateChanged) -> Result<()>

Actions to be performed when receiving a queue state change.

Errors

Returns an error if handling the queue state change fails.

fn on_socket_state(&mut self, event: &SocketStateChanged) -> Result<()>

Actions to be performed when receiving a socket state change.

Errors

Returns an error if handling the socket state change fails.

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

Actions to be performed when receiving an instrument.

Errors

Returns an error if handling the instrument fails.

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

Actions to be performed when receiving order book deltas.

Errors

Returns an error if handling the book deltas fails.

fn on_book_depth(&mut self, depth: &OrderBookDepth10) -> Result<()>

Actions to be performed when receiving an order book depth10 snapshot.

Errors

Returns an error if handling the book depth fails.

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

Actions to be performed when receiving an order book.

Errors

Returns an error if handling the book fails.

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

Actions to be performed when receiving a quote.

Errors

Returns an error if handling the quote fails.

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

Actions to be performed when receiving a trade.

Errors

Returns an error if handling the trade fails.

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

Actions to be performed when receiving a bar.

Errors

Returns an error if handling the bar fails.

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

Actions to be performed when receiving a mark price update.

Errors

Returns an error if handling the mark price update fails.

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

Actions to be performed when receiving an index price update.

Errors

Returns an error if handling the index price update fails.

fn on_funding_rate(&mut self, funding_rate: &FundingRateUpdate) -> Result<()>

Actions to be performed when receiving a funding rate update.

Errors

Returns an error if handling the funding rate update fails.

fn on_option_greeks(&mut self, greeks: &OptionGreeks) -> Result<()>

Actions to be performed when receiving exchange-provided option greeks.

Errors

Returns an error if handling the option greeks fails.

fn on_option_chain(&mut self, slice: &OptionChainSlice) -> Result<()>

Actions to be performed when receiving an option chain slice snapshot.

Errors

Returns an error if handling the option chain slice fails.

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

Actions to be performed when receiving an instrument status update.

Errors

Returns an error if handling the instrument status update fails.

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

Actions to be performed when receiving an instrument close update.

Errors

Returns an error if handling the instrument close update fails.

fn on_block(&mut self, block: &Block) -> Result<()>

Actions to be performed when receiving a block.

Errors

Returns an error if handling the block fails.

fn on_pool(&mut self, pool: &Pool) -> Result<()>

Actions to be performed when receiving a pool.

Errors

Returns an error if handling the pool fails.

fn on_pool_swap(&mut self, swap: &PoolSwap) -> Result<()>

Actions to be performed when receiving a pool swap.

Errors

Returns an error if handling the pool swap fails.

fn on_pool_liquidity_update( &mut self, update: &PoolLiquidityUpdate, ) -> Result<()>

Actions to be performed when receiving a pool liquidity update.

Errors

Returns an error if handling the pool liquidity update fails.

fn on_pool_fee_collect(&mut self, collect: &PoolFeeCollect) -> Result<()>

Actions to be performed when receiving a pool fee collect event.

Errors

Returns an error if handling the pool fee collect fails.

fn on_pool_flash(&mut self, flash: &PoolFlash) -> Result<()>

Actions to be performed when receiving a pool flash event.

Errors

Returns an error if handling the pool flash fails.

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

Actions to be performed when receiving historical custom data.

The callback runs once per response. A scalar [CustomData] remains scalar, while a Vec<CustomData> batch remains intact, including when empty.

Errors

Returns an error if handling the historical data fails.

fn on_historical_book_deltas(&mut self, deltas: &[OrderBookDelta]) -> Result<()>

Actions to be performed when receiving historical book deltas.

Errors

Returns an error if handling the historical book deltas fails.

fn on_historical_book_depth( &mut self, depths: &[OrderBookDepth10], ) -> Result<()>

Actions to be performed when receiving historical book depth.

Errors

Returns an error if handling the historical book depth fails.

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

Actions to be performed when receiving historical quotes.

Errors

Returns an error if handling the historical quotes fails.

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

Actions to be performed when receiving historical trades.

Errors

Returns an error if handling the historical trades fails.

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

Actions to be performed when receiving historical bars.

Errors

Returns an error if handling the historical bars fails.

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

Actions to be performed when receiving historical mark prices.

Errors

Returns an error if handling the historical mark prices fails.

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

Actions to be performed when receiving historical index prices.

Errors

Returns an error if handling the historical index prices fails.

fn on_historical_funding_rates( &mut self, funding_rates: &[FundingRateUpdate], ) -> Result<()>

Actions to be performed when receiving historical funding rates.

Errors

Returns an error if handling the historical funding rates fails.

fn clock(&self) -> ClockApi<'_>

where Self: DataActorNative,

Returns the user-facing clock API.

fn cache(&self) -> CacheApi<'_>

where Self: DataActorNative,

Returns the user-facing cache API.

fn shutdown_system(&self, reason: Option<String>)

where Self: DataActorNative,

Sends a shutdown command to the system with an optional reason.

Panics

Panics if the actor is not registered or has no trader ID.

fn publish_data(&self, data_type: &DataType, data: &CustomData)

where Self: DataActorNative,

Publishes data on the message bus under the topic derived from data_type.

data_type is kept as an explicit parameter to allow callers to override the routing topic from the payload’s intrinsic type.

Panics

Panics if the actor is not registered with a trader.

fn publish_signal(&self, name: &str, value: String, ts_event: UnixNanos)

where Self: DataActorNative,

Publishes a Signal constructed from name and value.

Panics

Panics if the actor is not registered with a trader.

fn add_synthetic(&self, synthetic: SyntheticInstrument) -> Result<()>

where Self: DataActorNative,

Adds the synthetic instrument to the cache.

Errors

Returns an error if a synthetic with the same ID already exists, or if the backing cache fails to persist it.

Panics

Panics if the actor is not registered with a trader.

fn update_synthetic(&self, synthetic: SyntheticInstrument) -> Result<()>

where Self: DataActorNative,

Updates the synthetic instrument in the cache, replacing the existing entry.

Errors

Returns an error if no synthetic with the same ID already exists, or if the backing cache fails to persist the replacement.

Panics

Panics if the actor is not registered with a trader.

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

where Self: Component,

Handles a received time event.

fn handle_data(&mut self, data: &CustomData)

where Self: Component,

Handles a received custom data point.

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

where Self: Component,

Handles a received signal.

fn handle_queue_state(&mut self, event: &QueueStateChanged)

where Self: Component,

Handles a received queue state change.

fn handle_socket_state(&mut self, event: &SocketStateChanged)

where Self: Component,

Handles a received socket state change.

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

where Self: Component,

Handles a received instrument.

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

where Self: Component,

Handles received order book deltas.

fn handle_book_depth(&mut self, depth: &OrderBookDepth10)

where Self: Component,

Handles a received order book depth10 snapshot.

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

where Self: Component,

Handles a received order book reference.

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

where Self: DataActorNative + Component,

Handles a received quote.

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

where Self: DataActorNative + Component,

Handles a received trade.

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

where Self: DataActorNative + Component,

Handles a receiving bar.

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

where Self: Component,

Handles a received mark price update.

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

where Self: Component,

Handles a received index price update.

fn handle_funding_rate(&mut self, funding_rate: &FundingRateUpdate)

where Self: Component,

Handles a received funding rate update.

fn handle_option_greeks(&mut self, greeks: &OptionGreeks)

where Self: Component,

Handles a received option greeks update.

fn handle_option_chain(&mut self, slice: &OptionChainSlice)

where Self: Component,

Handles a received option chain slice snapshot.

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

where Self: Component,

Handles a received instrument status.

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

where Self: Component,

Handles a received instrument close.

fn handle_block(&mut self, block: &Block)

where Self: Component,

Handles a received block.

fn handle_pool(&mut self, pool: &Pool)

where Self: Component,

Handles a received pool definition update.

fn handle_pool_swap(&mut self, swap: &PoolSwap)

where Self: Component,

Handles a received pool swap.

fn handle_pool_liquidity_update(&mut self, update: &PoolLiquidityUpdate)

where Self: Component,

Handles a received pool liquidity update.

fn handle_pool_fee_collect(&mut self, collect: &PoolFeeCollect)

where Self: Component,

Handles a received pool fee collect.

fn handle_pool_flash(&mut self, flash: &PoolFlash)

where Self: Component,

Handles a received pool flash event.

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

Handles received historical data.

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

Handles a data response.

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

Handles an instrument response.

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

Handles an instruments response.

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

Handles a book response.

fn handle_book_deltas_response(&mut self, resp: &BookDeltasResponse)

Handles a book deltas response.

fn handle_book_depth_response(&mut self, resp: &BookDepthResponse)

Handles a book depth response.

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

where Self: DataActorNative,

Handles a quotes response.

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

where Self: DataActorNative,

Handles a trades response.

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

where Self: DataActorNative,

Handles a bars response.

fn handle_funding_rates_response(&mut self, resp: &FundingRatesResponse)

Handles a funding rates response.

fn subscribe_data( &mut self, data_type: DataType, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming data_type data.

fn subscribe_signal(&mut self, name: &str, priority: Option<u32>)

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to Signal data by name.

An empty name subscribes to every signal.

Parameters

• name: signal name to subscribe to.
• priority: optional dispatch priority. Pass None for default ordering (by pattern then handler ID). Pass Some(p) when actors sharing a signal need deterministic ordering: higher-priority handlers receive the message before lower-priority handlers.

Re-subscribing does not update an existing priority; call unsubscribe_signal first.

fn subscribe_queue_state(&mut self, priority: Option<u32>)

where Self: DataActorNative + 'static + Debug + Sized,

Subscribes to QueueStateChanged events.

priority controls dispatch order when multiple actors subscribe to the event. Higher values receive the event first. Re-subscribing does not update an existing priority; call unsubscribe_queue_state first.

fn subscribe_socket_state(&mut self, priority: Option<u32>)

where Self: DataActorNative + 'static + Debug + Sized,

Subscribes to SocketStateChanged events.

priority controls dispatch order when multiple actors subscribe to the event. Higher values receive the event first. Re-subscribing does not update an existing priority; call unsubscribe_socket_state first.

fn subscribe_quotes( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [QuoteTick] data for the instrument_id.

fn subscribe_instruments( &mut self, venue: Venue, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [InstrumentAny] data for the venue.

fn subscribe_instrument( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [InstrumentAny] data for the instrument_id.

fn subscribe_book_deltas( &mut self, instrument_id: InstrumentId, book_type: BookType, depth: Option<NonZeroUsize>, client_id: Option<ClientId>, managed: bool, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [OrderBookDeltas] data for the instrument_id.

When managed is true, the data engine maintains an [OrderBook] in the cache for each instrument the subscription resolves to, applying each batch of deltas as it arrives. A parent subscription resolves to every matching underlying instrument.

fn subscribe_book_depth10( &mut self, instrument_id: InstrumentId, book_type: BookType, client_id: Option<ClientId>, managed: bool, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [OrderBookDepth10] data for the instrument_id.

When managed is true, the data engine maintains an [OrderBook] in the cache for each instrument the subscription resolves to, applying each update as it arrives. A parent subscription resolves to every matching underlying instrument.

fn subscribe_book_at_interval( &mut self, instrument_id: InstrumentId, book_type: BookType, depth: Option<NonZeroUsize>, interval_ms: NonZeroUsize, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to [OrderBook] snapshots at a specified interval for the instrument_id.

fn subscribe_trades( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [TradeTick] data for the instrument_id.

fn subscribe_bars( &mut self, bar_type: BarType, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [Bar] data for the bar_type.

fn subscribe_mark_prices( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [MarkPriceUpdate] data for the instrument_id.

fn subscribe_index_prices( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [IndexPriceUpdate] data for the instrument_id.

fn subscribe_funding_rates( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [FundingRateUpdate] data for the instrument_id.

fn subscribe_option_greeks( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [OptionGreeks] data for the instrument_id.

fn subscribe_instrument_status( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [InstrumentStatus] data for the instrument_id.

fn subscribe_instrument_close( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [InstrumentClose] data for the instrument_id.

fn subscribe_option_chain( &mut self, series_id: OptionSeriesId, strike_range: StrikeRange, snapshot_interval_ms: Option<u64>, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [OptionChainSlice] snapshots for the option series_id.

The ATM price is always derived from the exchange-provided forward price embedded in each option greeks/ticker update.

fn subscribe_blocks( &mut self, chain: Blockchain, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [Block] data for the chain.

fn subscribe_pool( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [Pool] definition updates for the AMM pool at the instrument_id.

fn subscribe_pool_swaps( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [PoolSwap] data for the instrument_id.

fn subscribe_pool_liquidity_updates( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [PoolLiquidityUpdate] data for the instrument_id.

fn subscribe_pool_fee_collects( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [PoolFeeCollect] data for the instrument_id.

fn subscribe_pool_flash_events( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Subscribe to streaming [PoolFlash] events for the given instrument_id.

fn unsubscribe_data( &mut self, data_type: DataType, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming data_type data.

fn unsubscribe_signal(&mut self, name: &str)

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from Signal data by name.

fn unsubscribe_queue_state(&mut self)

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribes from QueueStateChanged events.

fn unsubscribe_socket_state(&mut self)

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribes from SocketStateChanged events.

fn unsubscribe_instruments( &mut self, venue: Venue, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [InstrumentAny] data for the venue.

fn unsubscribe_instrument( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [InstrumentAny] data for the instrument_id.

fn unsubscribe_book_deltas( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [OrderBookDeltas] data for the instrument_id.

fn unsubscribe_book_depth10( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [OrderBookDepth10] data for the instrument_id.

fn unsubscribe_book_at_interval( &mut self, instrument_id: InstrumentId, interval_ms: NonZeroUsize, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from [OrderBook] snapshots at a specified interval for the instrument_id.

fn unsubscribe_quotes( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [QuoteTick] data for the instrument_id.

fn unsubscribe_trades( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [TradeTick] data for the instrument_id.

fn unsubscribe_bars( &mut self, bar_type: BarType, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [Bar] data for the bar_type.

fn unsubscribe_mark_prices( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [MarkPriceUpdate] data for the instrument_id.

fn unsubscribe_index_prices( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [IndexPriceUpdate] data for the instrument_id.

fn unsubscribe_funding_rates( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [FundingRateUpdate] data for the instrument_id.

fn unsubscribe_option_greeks( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [OptionGreeks] data for the instrument_id.

fn unsubscribe_instrument_status( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [InstrumentStatus] data for the instrument_id.

fn unsubscribe_instrument_close( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [InstrumentClose] data for the instrument_id.

fn unsubscribe_option_chain( &mut self, series_id: OptionSeriesId, client_id: Option<ClientId>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [OptionChainSlice] snapshots for the option series_id.

fn unsubscribe_blocks( &mut self, chain: Blockchain, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [Block] data for the chain.

fn unsubscribe_pool( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [Pool] definition updates for the AMM pool at the instrument_id.

fn unsubscribe_pool_swaps( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [PoolSwap] data for the instrument_id.

fn unsubscribe_pool_liquidity_updates( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [PoolLiquidityUpdate] data for the instrument_id.

fn unsubscribe_pool_fee_collects( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [PoolFeeCollect] data for the instrument_id.

fn unsubscribe_pool_flash_events( &mut self, instrument_id: InstrumentId, client_id: Option<ClientId>, params: Option<Params>, )

where Self: DataActorNative + 'static + Debug + Sized,

Unsubscribe from streaming [PoolFlash] events for the given instrument_id.

fn request_data( &mut self, data_type: DataType, client_id: ClientId, start: Option<Timestamp>, end: Option<Timestamp>, limit: Option<NonZeroUsize>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical custom data of the given data_type.

Errors

Returns an error if input parameters are invalid.

fn request_instrument( &mut self, instrument_id: InstrumentId, start: Option<Timestamp>, end: Option<Timestamp>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical InstrumentResponse data for the given instrument_id.

Errors

Returns an error if input parameters are invalid.

fn request_instruments( &mut self, venue: Option<Venue>, start: Option<Timestamp>, end: Option<Timestamp>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical InstrumentsResponse definitions for the optional venue.

Errors

Returns an error if input parameters are invalid.

fn request_book_snapshot( &mut self, instrument_id: InstrumentId, depth: Option<NonZeroUsize>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request an [OrderBook] snapshot for the given instrument_id.

Errors

Returns an error if input parameters are invalid.

fn request_book_deltas( &mut self, instrument_id: InstrumentId, start: Option<Timestamp>, end: Option<Timestamp>, limit: Option<NonZeroUsize>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical [OrderBookDelta] data for the given instrument_id.

Errors

Returns an error if input parameters are invalid.

fn request_book_depth( &mut self, instrument_id: InstrumentId, start: Option<Timestamp>, end: Option<Timestamp>, limit: Option<NonZeroUsize>, depth: Option<NonZeroUsize>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical [OrderBookDepth10] data for the given instrument_id.

Errors

Returns an error if input parameters are invalid.

fn request_quotes( &mut self, instrument_id: InstrumentId, start: Option<Timestamp>, end: Option<Timestamp>, limit: Option<NonZeroUsize>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical [QuoteTick] data for the given instrument_id.

Errors

Returns an error if input parameters are invalid.

fn request_trades( &mut self, instrument_id: InstrumentId, start: Option<Timestamp>, end: Option<Timestamp>, limit: Option<NonZeroUsize>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical [TradeTick] data for the given instrument_id.

Errors

Returns an error if input parameters are invalid.

fn request_bars( &mut self, bar_type: BarType, start: Option<Timestamp>, end: Option<Timestamp>, limit: Option<NonZeroUsize>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical [Bar] data for the given bar_type.

Errors

Returns an error if input parameters are invalid.

fn request_funding_rates( &mut self, instrument_id: InstrumentId, start: Option<Timestamp>, end: Option<Timestamp>, limit: Option<NonZeroUsize>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<UUID4>

where Self: DataActorNative + 'static + Debug + Sized,

Request historical [FundingRateUpdate] data for the given instrument_id.

Errors

Returns an error if input parameters are invalid.

fn reconnect_socket(&self, client_id: ClientId, endpoint: &str) -> Result<()>

where Self: DataActorNative,

Requests reconnect of one socket endpoint owned by client_id.

This is a fire-and-observe command. A successful return means the live runner queued the request. SocketStateChanged events for the same endpoint report whether the transport enters reconnect mode and later recovers.

Errors

Returns an error if the actor is not registered, the endpoint label is invalid, the live runner is unavailable, or the runner command channel is closed.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl DataActor for PyDataActorInner