Struct BlockchainDataClient

Source

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

Struct BlockchainDataClientCopy item path

Fields§

Implementations§

impl BlockchainDataClient

pub fn new(chain: SharedChain, config: BlockchainAdapterConfig) -> Self

§Panics

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

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

pub fn disconnect(&mut self) -> Result<()>

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

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

pub async fn process_hypersync_message(&mut self)

pub async fn process_rpc_message(&mut self)

pub async fn subscribe_blocks(&mut self)

§Panics

pub async fn unsubscribe_blocks(&mut self)

§Panics

Trait Implementations§

impl DataClient for BlockchainDataClient

fn client_id(&self) -> ClientId

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

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

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

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

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

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

fn disconnect<'life0, 'async_trait>( &'life0 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(&mut self, _cmd: &SubscribeCustomData) -> Result<()>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

fn request_data(&self, request: &RequestCustomData) -> 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 !UnwindSafe for BlockchainDataClient

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

Struct BlockchainDataClient

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

fn disconnect<'life0, 'async_trait>( &'life0 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,