Struct data_streaming_service::streaming_client::StreamingServiceClient

pub struct StreamingServiceClient { /* fields omitted */ }

The streaming service client that talks to the streaming service.

Implementations

impl StreamingServiceClient

pub fn new(request_sender: UnboundedSender<StreamRequestMessage>) -> Self

Trait Implementations

impl Clone for StreamingServiceClient

fn clone(&self) -> StreamingServiceClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl DataStreamingClient for StreamingServiceClient

fn get_all_accounts<'life0, 'async_trait>(
    &'life0 self,
    version: u64,
    start_index: Option<u64>
) -> Pin<Box<dyn Future<Output = Result<DataStreamListener, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Fetches the account states at the specified version. If start_index is specified, the account states will be fetched starting at the start_index (inclusive). Otherwise, the start index will 0. The specified version must be an epoch ending version, otherwise an error will be returned. Account state proofs are at the same version.

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

Fetches all epoch ending ledger infos starting at start_epoch (inclusive) and ending at the last known epoch advertised in the network.

fn get_all_transaction_outputs<'life0, 'async_trait>(
    &'life0 self,
    start_version: u64,
    end_version: u64,
    proof_version: u64
) -> Pin<Box<dyn Future<Output = Result<DataStreamListener, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Fetches all transaction outputs with proofs from start_version to end_version (inclusive) at the specified proof_version.

fn get_all_transactions<'life0, 'async_trait>(
    &'life0 self,
    start_version: u64,
    end_version: u64,
    proof_version: u64,
    include_events: bool
) -> Pin<Box<dyn Future<Output = Result<DataStreamListener, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Fetches all transactions with proofs from start_version to end_version (inclusive) at the specified proof_version. If include_events is true, events are also included in the proofs.

fn continuously_stream_transaction_outputs<'life0, 'async_trait>(
    &'life0 self,
    start_version: u64,
    start_epoch: u64,
    target: Option<LedgerInfoWithSignatures>
) -> Pin<Box<dyn Future<Output = Result<DataStreamListener, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Continuously streams transaction outputs with proofs as the blockchain grows. The stream starts at start_version and start_epoch (inclusive). Transaction output proof versions are tied to ledger infos within the same epoch, otherwise epoch ending ledger infos will signify epoch changes.

fn continuously_stream_transactions<'life0, 'async_trait>(
    &'life0 self,
    start_version: u64,
    start_epoch: u64,
    include_events: bool,
    target: Option<LedgerInfoWithSignatures>
) -> Pin<Box<dyn Future<Output = Result<DataStreamListener, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Continuously streams transactions with proofs as the blockchain grows. The stream starts at start_version and start_epoch (inclusive). Transaction proof versions are tied to ledger infos within the same epoch, otherwise epoch ending ledger infos will signify epoch changes. If include_events is true, events are also included in the proofs.

fn terminate_stream_with_feedback<'life0, 'async_trait>(
    &'life0 self,
    notification_id: u64,
    notification_feedback: NotificationFeedback
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Terminates the stream that sent the notification with the given notification_id and provides feedback for the termination reason.