Trait mz_storage_client::util::remap_handle::RemapHandle

pub trait RemapHandle: RemapHandleReader {
    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