Struct Client

pub struct Client<T> {
    pub inner: T,
}

Fields

inner: T

Implementations

impl<T> Client<T>

where T: Provider,

pub fn new(inner: T) -> Self

pub async fn get_status(&self) -> StreamResponse<Status>

impl Client<WsProvider>

pub async fn raw_request( &self, operation: Operation, params: impl Serialize, format: Format, deltas: bool, ) -> StreamResponse<Vec<u8>>

Trait Implementations

impl<T> BtcProvider for Client<T>

where T: BtcProvider + Send + Sync,

fn get_btc_blocks_by_format<'life0, 'async_trait>( &'life0 self, request: GetBtcBlocksRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_btc_txs_by_format<'life0, 'async_trait>( &'life0 self, request: GetBtcTxsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<T> ChainProvider for Client<T>

where T: ChainProvider + Send + Sync,

fn get_blocks_by_format<'life0, 'async_trait>( &'life0 self, request: GetBlocksRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_logs_by_format<'life0, 'async_trait>( &'life0 self, request: GetLogsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_txs_by_format<'life0, 'async_trait>( &'life0 self, request: GetTxsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_transfers_by_format<'life0, 'async_trait>( &'life0 self, request: GetTransfersRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<T> CurveProvider for Client<T>

where T: CurveProvider + Send + Sync,

fn get_tokens_by_format<'life0, 'async_trait>( &'life0 self, request: GetCrvTokenRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_pools_by_format<'life0, 'async_trait>( &'life0 self, request: GetCrvPoolRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_prices_by_format<'life0, 'async_trait>( &'life0 self, request: GetCrvPriceRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<T> Erc20Provider for Client<T>

where T: Erc20Provider + Send + Sync,

fn get_erc20_by_format<'life0, 'async_trait>( &'life0 self, request: GetErc20Request, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_erc20_approval_by_format<'life0, 'async_trait>( &'life0 self, request: GetErc20ApprovalsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_erc20_transfers_by_format<'life0, 'async_trait>( &'life0 self, request: GetErc20TransferssRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<T> MoveProvider for Client<T>

where T: MoveProvider + Send + Sync,

fn get_move_logs_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveLogsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_logs_decoded_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveLogsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_txs_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveTxsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_txs_decoded_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveTxsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_receipts_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveReceiptsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_modules_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveReceiptsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_receipts_decoded_by_format<'life0, 'async_trait>( &'life0 self, request: GetMoveReceiptsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_fa_tokens_by_format<'life0, 'async_trait>( &'life0 self, request: GetTokensRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_coins_by_format<'life0, 'async_trait>( &'life0 self, request: GetTokensRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_interest_v1_pools_by_format<'life0, 'async_trait>( &'life0 self, request: GetPoolsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_interest_v1_liquidity_by_format<'life0, 'async_trait>( &'life0 self, request: GetLiquidityRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_interest_v1_swaps_by_format<'life0, 'async_trait>( &'life0 self, request: GetSwapsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_arche_collaterals_by_format<'life0, 'async_trait>( &'life0 self, request: GetCollateralsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_arche_loans_by_format<'life0, 'async_trait>( &'life0 self, request: GetLoansRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_arche_positions_by_format<'life0, 'async_trait>( &'life0 self, request: GetPositionsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_pyth_by_format<'life0, 'async_trait>( &'life0 self, request: GetPricesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_move_balances_by_format<'life0, 'async_trait>( &'life0 self, request: GetBalancesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

const MOVE_VALID_CHAINS: [ChainId; 3] = _

fn check_chain(&self, chains: &HashSet<ChainId>) -> Result<()>

impl<T> UniswapV2Provider for Client<T>

where T: UniswapV2Provider + Send + Sync,

fn get_pairs_by_format<'life0, 'async_trait>( &'life0 self, request: GetPairsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_prices_by_format<'life0, 'async_trait>( &'life0 self, request: GetPricesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<T> UniswapV3Provider for Client<T>

where T: UniswapV3Provider + Send + Sync,

fn get_fees_by_format<'life0, 'async_trait>( &'life0 self, request: GetFeesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_pools_by_format<'life0, 'async_trait>( &'life0 self, request: GetPoolsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_prices_by_format<'life0, 'async_trait>( &'life0 self, request: GetPricesRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_positions_by_format<'life0, 'async_trait>( &'life0 self, request: GetPositionsRequest, format: Format, deltas: bool, ) -> Pin<Box<dyn Future<Output = StreamResponse<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,