Trait CheckpointStreamingClient 

pub trait CheckpointStreamingClient {
    // Required method
    fn connect<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<CheckpointStream>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

    // Provided method
    fn latest_checkpoint_number<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait { ... }
}

Trait representing a client for streaming checkpoint data.

Required Methods

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

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

Returns the CheckpointStream and chain id.

Provided Methods

fn latest_checkpoint_number<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: Sync + 'async_trait, 'life0: 'async_trait,

Returns the latest checkpoint number available from the streaming source.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl CheckpointStreamingClient for GrpcStreamingClient