Struct StateStrategy 

pub struct StateStrategy { /* private fields */ }

Strategy with observable state lifecycle callbacks.

Implementations

impl StateStrategy

pub fn new( strategy_id: StrategyId, control: TestCacheDatabaseControl, state_save: IndexMap<String, Vec<u8>>, ) -> Self

Creates a stateful strategy.

pub const fn with_fail_load(self) -> Self

Configures the strategy load callback to fail.

pub const fn with_fail_save(self) -> Self

Configures the strategy save callback to fail.

pub const fn with_fail_start(self) -> Self

Configures the strategy start callback to fail.

pub const fn state_load(&self) -> Option<&IndexMap<String, Vec<u8>>>

Returns the state received by the load callback.

impl StateStrategy

pub fn config(&self) -> &StrategyConfig

Returns the strategy configuration.

Trait Implementations

impl DataActor for StateStrategy

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_save(&self) -> Result<IndexMap<String, Vec<u8>>>

Actions to be performed when the actor state is saved.

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

Actions to be performed on resume.

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

Actions to be performed on reset.

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

Actions to be performed on dispose.

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.

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

Actions to be performed when receiving a time event.

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

Actions to be performed when receiving custom data.

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

Actions to be performed when receiving a signal.

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

Actions to be performed when receiving a queue state change.

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

Actions to be performed when receiving a socket state change.

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

Actions to be performed when receiving an instrument.

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

Actions to be performed when receiving order book deltas.

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

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

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

Actions to be performed when receiving an order book.

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

Actions to be performed when receiving a quote.

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

Actions to be performed when receiving a trade.

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

Actions to be performed when receiving a bar.

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

Actions to be performed when receiving a mark price update.

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

Actions to be performed when receiving an index price update.

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

Actions to be performed when receiving a funding rate update.

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

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

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

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

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

Actions to be performed when receiving an instrument status update.

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

Actions to be performed when receiving an instrument close update.

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

Actions to be performed when receiving a block.

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

Actions to be performed when receiving a pool.

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

Actions to be performed when receiving a pool swap.

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

Actions to be performed when receiving a pool liquidity update.

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

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

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

Actions to be performed when receiving a pool flash event.

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

Actions to be performed when receiving historical custom data.

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

Actions to be performed when receiving historical book deltas.

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

Actions to be performed when receiving historical book depth.

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

Actions to be performed when receiving historical quotes.

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

Actions to be performed when receiving historical trades.

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

Actions to be performed when receiving historical bars.

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

Actions to be performed when receiving historical mark prices.

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

Actions to be performed when receiving historical index prices.

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

Actions to be performed when receiving historical funding rates.

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.

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.

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

where Self: DataActorNative,

Publishes a [Signal] constructed from name and value.

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

where Self: DataActorNative,

Adds the synthetic instrument to the cache.

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

where Self: DataActorNative,

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

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 + 'static))

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 + Sized + 'static + Debug,

Subscribe to streaming data_type data.

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

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

Subscribe to [Signal] data by name.

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

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

Subscribes to [QueueStateChanged] events.

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

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

Subscribes to [SocketStateChanged] events.

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

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

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

Subscribe to streaming [InstrumentAny] data for the instrument_id.

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

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

Subscribe to streaming [OrderBookDeltas] data for the instrument_id.

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

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

Subscribe to streaming [OrderBookDepth10] data for the instrument_id.

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

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

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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

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

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

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

Unsubscribe from streaming data_type data.

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

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

Unsubscribe from [Signal] data by name.

fn unsubscribe_queue_state(&mut self)

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

Unsubscribes from [QueueStateChanged] events.

fn unsubscribe_socket_state(&mut self)

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

Unsubscribes from [SocketStateChanged] events.

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

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

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

Unsubscribe from streaming [OrderBookDepth10] data for the instrument_id.

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

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

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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 + Sized + 'static + Debug,

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<NonZero<usize>>, params: Option<Params>, ) -> Result<UUID4, Error>

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

Request historical custom data of the given data_type.

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

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

Request historical [InstrumentResponse] data for the given instrument_id.

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

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

Request historical [InstrumentsResponse] definitions for the optional venue.

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

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

Request an [OrderBook] snapshot for the given instrument_id.

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

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

Request historical [OrderBookDelta] data for the given instrument_id.

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

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

Request historical [OrderBookDepth10] data for the given instrument_id.

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

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

Request historical [QuoteTick] data for the given instrument_id.

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

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

Request historical [TradeTick] data for the given instrument_id.

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

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

Request historical [Bar] data for the given bar_type.

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

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

Request historical [FundingRateUpdate] data for the given instrument_id.

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

where Self: DataActorNative,

Requests reconnect of one socket endpoint owned by client_id.

impl DataActorNative for StateStrategy

fn core(&self) -> &DataActorCore

Returns the actor core.

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

Returns the mutable actor core.

fn clock_mut(&mut self) -> RefMut<'_, dyn Clock + 'static>

Returns the mutable clock borrow for the actor.

fn clock_rc(&self) -> Rc<RefCell<dyn Clock>>

Returns a clone of the reference-counted clock.

fn cache_ref(&self) -> Ref<'_, Cache>

Returns a read-only cache borrow.

fn cache_rc(&self) -> Rc<RefCell<Cache>>

Returns a clone of the reference-counted cache.

impl Debug for StateStrategy

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

Formats the value using the given formatter.

impl Strategy for StateStrategy

fn external_order_claims(&self) -> Option<Vec<InstrumentId>>

Returns the external order claims for this strategy.

fn strategy_id(&self) -> Option<StrategyId>

where Self: StrategyNative,

Returns the runtime strategy ID, when configured or registered.

fn order(&self) -> OrderApi<'_>

where Self: StrategyNative,

Returns the user-facing order creation API.

fn portfolio(&self) -> PortfolioApi<'_>

where Self: StrategyNative,

Returns the user-facing portfolio read API.

fn submit_order( &mut self, order: OrderAny, position_id: Option<PositionId>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Submits an order.

fn submit_order_list( &mut self, orders: Vec<OrderAny>, position_id: Option<PositionId>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Submits an order list.

fn modify_order( &mut self, client_order_id: ClientOrderId, quantity: Option<Quantity>, price: Option<Price>, trigger_price: Option<Price>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Modifies an order.

fn modify_orders( &mut self, updates: Vec<(ClientOrderId, Option<Quantity>, Option<Price>, Option<Price>)>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Batch modifies multiple orders for the same instrument.

fn cancel_order( &mut self, client_order_id: ClientOrderId, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Cancels an order.

fn cancel_orders( &mut self, client_order_ids: Vec<ClientOrderId>, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Batch cancels multiple orders for the same instrument.

fn mark_order_pending_update(&mut self, order: &OrderAny) -> Result<bool, Error>

where Self: StrategyNative,

Marks an order as pending update locally before the modify command leaves the strategy.

fn mark_order_pending_cancel(&mut self, order: &OrderAny) -> Result<bool, Error>

where Self: StrategyNative,

Marks an order as pending cancel locally before the cancel command leaves the strategy.

fn generate_order_pending_update( &mut self, order: &OrderAny, ) -> OrderPendingUpdate

where Self: StrategyNative,

Generates an OrderPendingUpdate event for an order.

fn generate_order_pending_cancel( &mut self, order: &OrderAny, ) -> OrderPendingCancel

where Self: StrategyNative,

Generates an OrderPendingCancel event for an order.

fn cancel_all_orders( &mut self, instrument_id: InstrumentId, order_side: Option<OrderSide>, client_id: Option<ClientId>, strategy_only: bool, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Cancels all open orders for the given instrument.

fn close_position( &mut self, position: &Position, client_id: Option<ClientId>, tags: Option<Vec<Ustr>>, time_in_force: Option<TimeInForce>, reduce_only: Option<bool>, quote_quantity: Option<bool>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Closes a position by submitting a market order for the opposite side.

fn close_all_positions( &mut self, instrument_id: InstrumentId, position_side: Option<PositionSide>, client_id: Option<ClientId>, tags: Option<Vec<Ustr>>, time_in_force: Option<TimeInForce>, reduce_only: Option<bool>, quote_quantity: Option<bool>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Closes all open positions for the given instrument.

fn query_account( &mut self, account_id: AccountId, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Queries account state from the execution client.

fn query_order( &mut self, order: &OrderAny, client_id: Option<ClientId>, params: Option<Params>, ) -> Result<(), Error>

where Self: StrategyNative,

Queries order state from the execution client.

fn handle_order_event(&mut self, event: OrderEventAny)

where Self: StrategyNative,

Handles an order event, dispatching to the appropriate handler.

fn dispatch_manager_actions(&mut self, actions: Vec<OrderManagerAction>)

where Self: StrategyNative,

fn handle_position_event(&mut self, event: PositionEvent)

where Self: StrategyNative,

Handles a position event, dispatching to the appropriate handler.

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

where Self: StrategyNative,

Called when the strategy is started.

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

where Self: StrategyNative + Component,

Routes a time event through the framework-managed strategy handlers when called directly.

fn on_order_initialized(&mut self, event: OrderInitialized)

Called when an order is initialized.

fn on_order_event(&mut self, event: OrderEventAny)

Called when any order event is received after the specific order handler runs.

fn on_order_denied(&mut self, event: OrderDenied)

Called when an order is denied by the system.

fn on_order_emulated(&mut self, event: OrderEmulated)

Called when an order is emulated.

fn on_order_released(&mut self, event: OrderReleased)

Called when an order is released from emulation.

fn on_order_submitted(&mut self, event: OrderSubmitted)

Called when an order is submitted to the venue.

fn on_order_rejected(&mut self, event: OrderRejected)

Called when an order is rejected by the venue.

fn on_order_accepted(&mut self, event: OrderAccepted)

Called when an order is accepted by the venue.

fn on_order_expired(&mut self, event: OrderExpired)

Called when an order expires.

fn on_order_triggered(&mut self, event: OrderTriggered)

Called when an order is triggered.

fn on_order_pending_update(&mut self, event: OrderPendingUpdate)

Called when an order modification is pending.

fn on_order_pending_cancel(&mut self, event: OrderPendingCancel)

Called when an order cancellation is pending.

fn on_order_modify_rejected(&mut self, event: OrderModifyRejected)

Called when an order modification is rejected.

fn on_order_cancel_rejected(&mut self, event: OrderCancelRejected)

Called when an order cancellation is rejected.

fn on_order_updated(&mut self, event: OrderUpdated)

Called when an order is updated.

fn on_order_canceled(&mut self, event: &OrderCanceled)

Called when an order is canceled.

fn on_order_filled(&mut self, event: &OrderFilled)

Called when an order is filled.

fn on_order_fill_voided(&mut self, event: &OrderFillVoided)

Called when an applied order fill is partly or fully voided.

fn on_position_opened(&mut self, event: PositionOpened)

Called when a position is opened.

fn on_position_event(&mut self, event: PositionEvent)

Called after a position opened, changed, or closed handler runs.

fn on_position_changed(&mut self, event: PositionChanged)

Called when a position is changed (quantity or price updated).

fn on_position_closed(&mut self, event: PositionClosed)

Called when a position is closed.

fn on_market_exit(&mut self)

Called when a market exit has been initiated.

fn post_market_exit(&mut self)

Called after a market exit has completed.

fn is_exiting(&self) -> bool

where Self: StrategyNative,

Returns whether the strategy is currently executing a market exit.

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

where Self: StrategyNative,

Initiates an iterative market exit for the strategy.

fn check_market_exit(&mut self, _event: TimeEvent)

where Self: StrategyNative + Component,

Checks if the market exit is complete and finalizes if so.

fn finalize_market_exit(&mut self)

where Self: StrategyNative + Component,

Finalizes the market exit process.

fn cancel_market_exit(&mut self)

where Self: StrategyNative,

Cancels an active market exit without calling hooks.

fn stop(&mut self) -> bool

where Self: StrategyNative,

Stops the strategy with optional managed stop behavior.

fn deny_order(&mut self, order: &OrderAny, reason: Ustr)

where Self: StrategyNative,

Denies an order by generating an OrderDenied event.

fn deny_order_list(&mut self, orders: &[OrderAny], reason: Ustr)

where Self: StrategyNative,

Denies all orders in an order list.

fn set_gtd_expiry(&mut self, order: &OrderAny) -> Result<(), Error>

where Self: StrategyNative,

Sets a GTD expiry timer for an order.

fn cancel_gtd_expiry(&mut self, client_order_id: &ClientOrderId)

where Self: StrategyNative,

Cancels a GTD expiry timer for an order.

fn has_gtd_expiry_timer(&mut self, client_order_id: &ClientOrderId) -> bool

where Self: StrategyNative,

Checks if a GTD expiry timer exists for an order.

fn expire_gtd_order(&mut self, event: TimeEvent)

where Self: StrategyNative,

Handles GTD order expiry by canceling the order.

fn reactivate_gtd_timers(&mut self)

where Self: StrategyNative,

Reactivates GTD timers for open orders on strategy start.

impl StrategyNative for StateStrategy

fn strategy_core(&self) -> &StrategyCore

Returns the strategy core.

fn strategy_core_mut(&mut self) -> &mut StrategyCore

Returns the mutable strategy core.

fn order_factory(&mut self) -> RefMut<'_, OrderFactory>

Returns a mutable borrow of the order factory.

fn order_factory_rc(&self) -> Rc<RefCell<OrderFactory>>

Returns a clone of the reference-counted order factory.

fn portfolio_rc(&self) -> Rc<RefCell<Portfolio>>

Returns a clone of the reference-counted portfolio.