Struct data_streaming_service::streaming_client::StreamingServiceClient

pub struct StreamingServiceClient { /* private fields */ }

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,
    known_version: u64,
    known_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 known_version + 1 (inclusive) and known_epoch, where the known_epoch is expected to be the epoch that contains known_version + 1, i.e., any epoch change at known_version must be noted by the client. 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,
    known_version: u64,
    known_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 known_version + 1 (inclusive) and known_epoch, where the known_epoch is expected to be the epoch that contains known_version + 1, i.e., any epoch change at known_version must be noted by the client. Transaction proof versions are tied to ledger infos within the same epoch, otherwise epoch ending ledger infos will signify epoch changes.

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.