pub trait DataClient {
Show 41 methods
// Required methods
fn client_id(&self) -> ClientId;
fn venue(&self) -> Option<Venue>;
fn start(&self);
fn stop(&self);
fn reset(&self);
fn dispose(&self);
fn is_connected(&self) -> bool;
fn is_disconnected(&self) -> bool;
fn request_data(&self, request: RequestData) -> Result<()>;
// Provided methods
fn subscribe(&mut self, cmd: SubscribeData) -> Result<()> { ... }
fn subscribe_instruments(&mut self, cmd: SubscribeInstruments) -> Result<()> { ... }
fn subscribe_instrument(&mut self, cmd: SubscribeInstrument) -> Result<()> { ... }
fn subscribe_book_deltas(&mut self, cmd: SubscribeBookDeltas) -> Result<()> { ... }
fn subscribe_book_depth10(
&mut self,
cmd: SubscribeBookDepth10,
) -> Result<()> { ... }
fn subscribe_book_snapshots(
&mut self,
cmd: SubscribeBookSnapshots,
) -> Result<()> { ... }
fn subscribe_quotes(&mut self, cmd: SubscribeQuotes) -> Result<()> { ... }
fn subscribe_trades(&mut self, cmd: SubscribeTrades) -> Result<()> { ... }
fn subscribe_mark_prices(&mut self, cmd: SubscribeMarkPrices) -> Result<()> { ... }
fn subscribe_index_prices(
&mut self,
cmd: SubscribeIndexPrices,
) -> Result<()> { ... }
fn subscribe_bars(&mut self, cmd: SubscribeBars) -> Result<()> { ... }
fn subscribe_instrument_status(
&mut self,
cmd: SubscribeInstrumentStatus,
) -> Result<()> { ... }
fn subscribe_instrument_close(
&mut self,
cmd: SubscribeInstrumentClose,
) -> Result<()> { ... }
fn unsubscribe(&mut self, cmd: UnsubscribeData) -> Result<()> { ... }
fn unsubscribe_instruments(
&mut self,
cmd: UnsubscribeInstruments,
) -> Result<()> { ... }
fn unsubscribe_instrument(
&mut self,
cmd: UnsubscribeInstrument,
) -> Result<()> { ... }
fn unsubscribe_book_deltas(
&mut self,
cmd: UnsubscribeBookDeltas,
) -> Result<()> { ... }
fn unsubscribe_book_depth10(
&mut self,
cmd: UnsubscribeBookDepth10,
) -> Result<()> { ... }
fn unsubscribe_book_snapshots(
&mut self,
cmd: UnsubscribeBookSnapshots,
) -> Result<()> { ... }
fn unsubscribe_quotes(&mut self, cmd: UnsubscribeQuotes) -> Result<()> { ... }
fn unsubscribe_trades(&mut self, cmd: UnsubscribeTrades) -> Result<()> { ... }
fn unsubscribe_mark_prices(
&mut self,
cmd: UnsubscribeMarkPrices,
) -> Result<()> { ... }
fn unsubscribe_index_prices(
&mut self,
cmd: UnsubscribeIndexPrices,
) -> Result<()> { ... }
fn unsubscribe_bars(&mut self, cmd: UnsubscribeBars) -> Result<()> { ... }
fn unsubscribe_instrument_status(
&mut self,
cmd: UnsubscribeInstrumentStatus,
) -> Result<()> { ... }
fn unsubscribe_instrument_close(
&mut self,
cmd: UnsubscribeInstrumentClose,
) -> Result<()> { ... }
fn request_instruments(&self, request: RequestInstruments) -> Result<()> { ... }
fn request_instrument(&self, request: RequestInstrument) -> Result<()> { ... }
fn request_book_snapshot(&self, request: RequestBookSnapshot) -> Result<()> { ... }
fn request_quotes(&self, request: RequestQuotes) -> Result<()> { ... }
fn request_trades(&self, request: RequestTrades) -> Result<()> { ... }
fn request_bars(&self, request: RequestBars) -> Result<()> { ... }
}Required Methods§
fn client_id(&self) -> ClientId
fn venue(&self) -> Option<Venue>
fn start(&self)
fn stop(&self)
fn reset(&self)
fn dispose(&self)
fn is_connected(&self) -> bool
fn is_disconnected(&self) -> bool
fn request_data(&self, request: RequestData) -> Result<()>
Provided Methods§
fn subscribe(&mut self, cmd: SubscribeData) -> Result<()>
fn subscribe_instruments(&mut self, cmd: SubscribeInstruments) -> Result<()>
fn subscribe_instrument(&mut self, cmd: SubscribeInstrument) -> Result<()>
fn subscribe_book_deltas(&mut self, cmd: SubscribeBookDeltas) -> Result<()>
fn subscribe_book_depth10(&mut self, cmd: SubscribeBookDepth10) -> Result<()>
fn subscribe_book_snapshots( &mut self, cmd: SubscribeBookSnapshots, ) -> Result<()>
fn subscribe_quotes(&mut self, cmd: SubscribeQuotes) -> Result<()>
fn subscribe_trades(&mut self, cmd: SubscribeTrades) -> Result<()>
fn subscribe_mark_prices(&mut self, cmd: SubscribeMarkPrices) -> Result<()>
fn subscribe_index_prices(&mut self, cmd: SubscribeIndexPrices) -> Result<()>
fn subscribe_bars(&mut self, cmd: SubscribeBars) -> Result<()>
fn subscribe_instrument_status( &mut self, cmd: SubscribeInstrumentStatus, ) -> Result<()>
fn subscribe_instrument_close( &mut self, cmd: SubscribeInstrumentClose, ) -> Result<()>
fn unsubscribe(&mut self, cmd: UnsubscribeData) -> Result<()>
fn unsubscribe_instruments(&mut self, cmd: UnsubscribeInstruments) -> Result<()>
fn unsubscribe_instrument(&mut self, cmd: UnsubscribeInstrument) -> Result<()>
fn unsubscribe_book_deltas(&mut self, cmd: UnsubscribeBookDeltas) -> Result<()>
fn unsubscribe_book_depth10( &mut self, cmd: UnsubscribeBookDepth10, ) -> Result<()>
fn unsubscribe_book_snapshots( &mut self, cmd: UnsubscribeBookSnapshots, ) -> Result<()>
fn unsubscribe_quotes(&mut self, cmd: UnsubscribeQuotes) -> Result<()>
fn unsubscribe_trades(&mut self, cmd: UnsubscribeTrades) -> Result<()>
fn unsubscribe_mark_prices(&mut self, cmd: UnsubscribeMarkPrices) -> Result<()>
fn unsubscribe_index_prices( &mut self, cmd: UnsubscribeIndexPrices, ) -> Result<()>
fn unsubscribe_bars(&mut self, cmd: UnsubscribeBars) -> Result<()>
fn unsubscribe_instrument_status( &mut self, cmd: UnsubscribeInstrumentStatus, ) -> Result<()>
fn unsubscribe_instrument_close( &mut self, cmd: UnsubscribeInstrumentClose, ) -> Result<()>
Sourcefn request_instruments(&self, request: RequestInstruments) -> Result<()>
fn request_instruments(&self, request: RequestInstruments) -> Result<()>
Requests instruments data from the data provider.
Sourcefn request_instrument(&self, request: RequestInstrument) -> Result<()>
fn request_instrument(&self, request: RequestInstrument) -> Result<()>
Requests instrument data from the data provider.
Sourcefn request_book_snapshot(&self, request: RequestBookSnapshot) -> Result<()>
fn request_book_snapshot(&self, request: RequestBookSnapshot) -> Result<()>
Requests a book snapshot from the data provider.
Sourcefn request_quotes(&self, request: RequestQuotes) -> Result<()>
fn request_quotes(&self, request: RequestQuotes) -> Result<()>
Requests quotes data from the data provider.
Sourcefn request_trades(&self, request: RequestTrades) -> Result<()>
fn request_trades(&self, request: RequestTrades) -> Result<()>
Requests trades data from the data provider.
Sourcefn request_bars(&self, request: RequestBars) -> Result<()>
fn request_bars(&self, request: RequestBars) -> Result<()>
Requests bars data from the data provider.