Struct fireblocks_sdk::PagedClient

pub struct PagedClient {
    pub client: Arc<Client>,
}

Fields

client: Arc<Client>

Implementations

impl PagedClient

pub const fn new(client: Arc<Client>) -> Self

pub fn vaults(&self, batch_size: u16) -> VaultStream

Stream the vault accounts based on batch size

use std::sync::Arc;
use futures::TryStreamExt;
use fireblocks_sdk::{Client, PagedClient};

async fn vault_accounts(c: Client) -> color_eyre::Result<()> {
  let pc = PagedClient::new(Arc::new(c));
  let mut vault_stream = pc.vaults(100);
  while let Ok(Some(result)) = vault_stream.try_next().await {
    tracing::info!("accounts {}", result.0.accounts.len());
    tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
   }
  Ok(())
}

see Client::vaults

pub fn transactions_from_source( &self, vault_id: i32, batch_size: u16, after: Option<Epoch> ) -> TransactionStream

Stream all the transactions from source vault account id and after some date

Default date is 2022-04-06 if None provided

use std::sync::Arc;
use futures::TryStreamExt;
use fireblocks_sdk::{Client, PagedClient};

async fn transactions_paged(c: Client) -> color_eyre::Result<()> {
  let pc = PagedClient::new(Arc::new(c));
  let mut ts = pc.transactions_from_source(0, 100, None);
  while let Ok(Some(result)) = ts.try_next().await {
    tracing::info!("transactions {}", result.0.len());
   }
  Ok(())
}

see

• Client::transactions

pub fn transactions_from_destination( &self, vault_id: i32, batch_size: u16, after: Option<Epoch> ) -> TransactionStream

Stream all the transactions from destination vault account id See [self.transactions_from_source]

Trait Implementations

impl Clone for PagedClient

fn clone(&self) -> PagedClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.