Struct BlockchainDataClient

Source

pub struct BlockchainDataClient {
    pub chain: SharedChain,
    pub config: BlockchainDataClientConfig,
    pub core_client: Option<BlockchainDataClientCore>,
    /* private fields */
}

Expand description

A comprehensive client for interacting with blockchain data from multiple sources.

The BlockchainDataClient serves as a facade that coordinates between different blockchain data providers, caching mechanisms, and contract interactions. It provides a unified interface for retrieving and processing blockchain data, particularly focused on DeFi protocols.

This client supports two primary data sources:

Direct RPC connections to blockchain nodes (via WebSocket).
HyperSync API for efficient historical data queries.

Fields§

§chain: SharedChain

The blockchain being targeted by this client instance.

§config: BlockchainDataClientConfig

Configuration parameters for the blockchain data client.

§core_client: Option<BlockchainDataClientCore>

The core client instance that handles blockchain operations. Wrapped in Option to allow moving it into the background processing task.

Struct BlockchainDataClient Copy item path

Fields§

Implementations§

impl BlockchainDataClient

pub fn new(config: BlockchainDataClientConfig) -> Self

pub async fn await_process_task_close(&mut self)

Trait Implementations§

impl DataClient for BlockchainDataClient

fn client_id(&self) -> ClientId

fn venue(&self) -> Option<Venue>

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

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

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

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

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn is_connected(&self) -> bool

fn is_disconnected(&self) -> bool

fn subscribe_blocks(&mut self, cmd: &SubscribeBlocks) -> Result<()>

fn subscribe_pool(&mut self, cmd: &SubscribePool) -> Result<()>

fn subscribe_pool_swaps(&mut self, cmd: &SubscribePoolSwaps) -> Result<()>

fn subscribe_pool_liquidity_updates( &mut self, cmd: &SubscribePoolLiquidityUpdates, ) -> Result<()>

fn subscribe_pool_fee_collects( &mut self, cmd: &SubscribePoolFeeCollects, ) -> Result<()>

fn subscribe_pool_flash_events( &mut self, cmd: &SubscribePoolFlashEvents, ) -> Result<()>

fn unsubscribe_blocks(&mut self, cmd: &UnsubscribeBlocks) -> Result<()>

fn unsubscribe_pool(&mut self, cmd: &UnsubscribePool) -> Result<()>

fn unsubscribe_pool_swaps(&mut self, cmd: &UnsubscribePoolSwaps) -> Result<()>

fn unsubscribe_pool_liquidity_updates( &mut self, cmd: &UnsubscribePoolLiquidityUpdates, ) -> Result<()>

fn unsubscribe_pool_fee_collects( &mut self, cmd: &UnsubscribePoolFeeCollects, ) -> Result<()>

fn unsubscribe_pool_flash_events( &mut self, cmd: &UnsubscribePoolFlashEvents, ) -> Result<()>

fn request_pool_snapshot(&self, cmd: &RequestPoolSnapshot) -> Result<()>

fn subscribe(&mut self, cmd: &SubscribeCustomData) -> Result<(), Error>

fn subscribe_instruments( &mut self, cmd: &SubscribeInstruments, ) -> Result<(), Error>

fn subscribe_instrument( &mut self, cmd: &SubscribeInstrument, ) -> Result<(), Error>

fn subscribe_book_deltas( &mut self, cmd: &SubscribeBookDeltas, ) -> Result<(), Error>

fn subscribe_book_depth10( &mut self, cmd: &SubscribeBookDepth10, ) -> Result<(), Error>

fn subscribe_book_snapshots( &mut self, cmd: &SubscribeBookSnapshots, ) -> Result<(), Error>

fn subscribe_quotes(&mut self, cmd: &SubscribeQuotes) -> Result<(), Error>

fn subscribe_trades(&mut self, cmd: &SubscribeTrades) -> Result<(), Error>

fn subscribe_mark_prices( &mut self, cmd: &SubscribeMarkPrices, ) -> Result<(), Error>

fn subscribe_index_prices( &mut self, cmd: &SubscribeIndexPrices, ) -> Result<(), Error>

fn subscribe_funding_rates( &mut self, cmd: &SubscribeFundingRates, ) -> Result<(), Error>

fn subscribe_bars(&mut self, cmd: &SubscribeBars) -> Result<(), Error>

fn subscribe_instrument_status( &mut self, cmd: &SubscribeInstrumentStatus, ) -> Result<(), Error>

fn subscribe_instrument_close( &mut self, cmd: &SubscribeInstrumentClose, ) -> Result<(), Error>

fn unsubscribe(&mut self, cmd: &UnsubscribeCustomData) -> Result<(), Error>

fn unsubscribe_instruments( &mut self, cmd: &UnsubscribeInstruments, ) -> Result<(), Error>

fn unsubscribe_instrument( &mut self, cmd: &UnsubscribeInstrument, ) -> Result<(), Error>

fn unsubscribe_book_deltas( &mut self, cmd: &UnsubscribeBookDeltas, ) -> Result<(), Error>

fn unsubscribe_book_depth10( &mut self, cmd: &UnsubscribeBookDepth10, ) -> Result<(), Error>

fn unsubscribe_book_snapshots( &mut self, cmd: &UnsubscribeBookSnapshots, ) -> Result<(), Error>

fn unsubscribe_quotes(&mut self, cmd: &UnsubscribeQuotes) -> Result<(), Error>

fn unsubscribe_trades(&mut self, cmd: &UnsubscribeTrades) -> Result<(), Error>

fn unsubscribe_mark_prices( &mut self, cmd: &UnsubscribeMarkPrices, ) -> Result<(), Error>

fn unsubscribe_index_prices( &mut self, cmd: &UnsubscribeIndexPrices, ) -> Result<(), Error>

fn unsubscribe_funding_rates( &mut self, cmd: &UnsubscribeFundingRates, ) -> Result<(), Error>

fn unsubscribe_bars(&mut self, cmd: &UnsubscribeBars) -> Result<(), Error>

fn unsubscribe_instrument_status( &mut self, cmd: &UnsubscribeInstrumentStatus, ) -> Result<(), Error>

fn unsubscribe_instrument_close( &mut self, cmd: &UnsubscribeInstrumentClose, ) -> Result<(), Error>

fn request_data(&self, request: &RequestCustomData) -> Result<(), Error>

fn request_instruments(&self, request: &RequestInstruments) -> Result<(), Error>

fn request_instrument(&self, request: &RequestInstrument) -> Result<(), Error>

fn request_book_snapshot( &self, request: &RequestBookSnapshot, ) -> Result<(), Error>

fn request_quotes(&self, request: &RequestQuotes) -> Result<(), Error>

fn request_trades(&self, request: &RequestTrades) -> Result<(), Error>

fn request_bars(&self, request: &RequestBars) -> Result<(), Error>

fn request_book_depth(&self, request: &RequestBookDepth) -> Result<(), Error>

impl Debug for BlockchainDataClient

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

Auto Trait Implementations§

impl Freeze for BlockchainDataClient

impl !RefUnwindSafe for BlockchainDataClient

impl Send for BlockchainDataClient

impl Sync for BlockchainDataClient

impl Unpin for BlockchainDataClient

impl UnsafeUnpin for BlockchainDataClient

impl !UnwindSafe for BlockchainDataClient

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Struct BlockchainDataClient

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> Ungil for T
where T: Send,