Trait SourceRecency 

pub trait SourceRecency:
    Send
    + Sync
    + Debug {
    // Required method
    fn upstream_end<'life0, 'async_trait>(
        &'life0 self,
        deadline: Instant,
    ) -> Pin<Box<dyn Future<Output = Result<Box<dyn RecencyTarget>, ConnectorError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Reports how far a source’s upstream has been written. It is built from the source’s configuration on any node and never touches the running reader or its position.

Required Methods

fn upstream_end<'life0, 'async_trait>( &'life0 self, deadline: Instant, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn RecencyTarget>, ConnectorError>> + Send + 'async_trait>>

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

The upstream’s end now: every record a reader of this source could see.

Errors

Returns an error when the upstream cannot be reached or described before deadline.

Dyn Compatibility

This trait is dyn compatible.

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

Implementors