Trait mz_storage_client::util::remap_handle::RemapHandle

pub trait RemapHandle: RemapHandleReader {
    // Required methods
    fn compare_and_append<'life0, 'async_trait>(
        &'life0 mut self,
        updates: Vec<(Self::FromTime, Self::IntoTime, Diff)>,
        upper: Antichain<Self::IntoTime>,
        new_upper: Antichain<Self::IntoTime>,
    ) -> Pin<Box<dyn Future<Output = Result<(), UpperMismatch<Self::IntoTime>>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn upper(&self) -> &Antichain<Self::IntoTime>;
}

A handle that can be used to durably persist a remap collection translating FromTime to IntoTime.

Required Methods

fn compare_and_append<'life0, 'async_trait>( &'life0 mut self, updates: Vec<(Self::FromTime, Self::IntoTime, Diff)>, upper: Antichain<Self::IntoTime>, new_upper: Antichain<Self::IntoTime>, ) -> Pin<Box<dyn Future<Output = Result<(), UpperMismatch<Self::IntoTime>>> + 'async_trait>>

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

Attempt to write the batch of remap collection updates to the collection. If the remap collection was already written by some other process an error will return with the current upper.

fn upper(&self) -> &Antichain<Self::IntoTime>

Implementors