Struct BlockchainDataClient

Source

pub struct BlockchainDataClient {
    pub chain: SharedChain,
    pub config: BlockchainDataClientConfig,
    /* 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

The configuration for the data client.

Struct BlockchainDataClientCopy item path

Fields§

Implementations§

impl BlockchainDataClient

pub fn new(config: BlockchainDataClientConfig) -> Self

§Panics

pub async fn initialize_cache_database( &mut self, pg_connect_options: Option<PostgresConnectOptions>, )

pub async fn sync_blocks(&mut self, from_block: Option<u64>) -> Result<()>

pub async fn sync_pool_swaps( &mut self, dex_id: &str, pool_address: String, from_block: Option<u64>, to_block: Option<u64>, ) -> Result<()>

pub async fn sync_pool_mints( &self, dex_id: &str, pool_address: String, from_block: Option<u64>, to_block: Option<u64>, ) -> Result<()>

pub async fn sync_pool_burns( &self, dex_id: &str, pool_address: String, from_block: Option<u64>, to_block: Option<u64>, ) -> Result<()>

pub async fn sync_exchange_pools( &mut self, dex_id: &str, from_block: Option<u64>, to_block: Option<u64>, ) -> Result<()>

pub async fn process_token(&mut self, token_address: String) -> Result<()>

§Errors

pub async fn register_exchange(&mut self, dex: DexExtended) -> Result<()>

pub async fn process_hypersync_messages(&mut self)

pub async fn process_rpc_messages(&mut self)

pub async fn subscribe_blocks_async(&mut self) -> Result<()>

pub async fn subscribe_pool_swaps_async(&mut self) -> Result<()>

pub async fn unsubscribe_blocks_async(&mut self) -> Result<()>

pub async fn unsubscribe_pool_swaps_async(&mut self) -> Result<()>

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<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '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 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 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_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_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>

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

Struct BlockchainDataClient

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

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '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>,

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

impl<T> ErasedDestructor for T
where T: 'static,

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