Trait RecencyTarget 

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

The upstream’s end at one instant.

Required Methods

fn covered_by<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint: &'life1 SourceCheckpoint, deadline: Instant, ) -> Pin<Box<dyn Future<Output = Result<bool, ConnectorError>> + Send + 'async_trait>>

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

Whether checkpoint, a committed checkpoint of this source, holds every record before this end. Positions only grow, so a later checkpoint of a covering one also covers it.

Errors

Returns an error when checkpoint is not this connector’s, or coverage cannot be decided before deadline.

Dyn Compatibility

This trait is dyn compatible.

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

Implementors