Struct mz_storage_client::controller::persist_handles::PersistMonotonicWriteWorker

pub struct PersistMonotonicWriteWorker<T: Timestamp + Lattice + Codec64 + TimestampManipulation> {
    inner: Arc<PersistMonotonicWriteWorkerInner<T>>,
}

Fields

inner: Arc<PersistMonotonicWriteWorkerInner<T>>

Implementations

impl<T: Timestamp + Lattice + Codec64 + TimestampManipulation> PersistMonotonicWriteWorker<T>

pub(crate) fn new( frontier_responses: UnboundedSender<StorageResponse<T>> ) -> Self

pub(crate) fn register( &self, id: GlobalId, write_handle: WriteHandle<SourceData, (), T, Diff> )

pub(crate) fn update( &self, id: GlobalId, write_handle: WriteHandle<SourceData, (), T, Diff> )

Update the existing write handle associated with id to write_handle.

Note that this should only be called when updating a write handle; to initially associate an id to a write handle, use Self::register.

Panics

• If id is not currently associated with any write handle.

pub(crate) fn monotonic_append( &self, updates: Vec<(GlobalId, Vec<TimestamplessUpdate>, T)> ) -> Receiver<Result<(), StorageError>>

Appends values to collections associated with GlobalId, but lets the persist worker chose timestamps guaranteed to be monotonic and that the time will be at least T.

This lets the writer influence how far forward the timestamp will be advanced, while still guaranteeing that it will advance.

Note it is still possible for the append operation to fail in the face of contention from other writers.

Panics

• If appending non-empty TimelessUpdate to closed collections (i.e. those with empty uppers), whose uppers cannot be monotonically increased.

  Collections with empty uppers can continue receiving empty updates, i.e. those used soley to advance collections’ uppers.

pub(crate) fn drop_handle(&self, id: GlobalId)

Drops the handle associated with id from this worker.

Note that this does not perform any other cleanup, such as finalizing the handle’s shard.

fn send(&self, cmd: PersistMonotonicWriteCmd<T>)

Trait Implementations

impl<T: Clone + Timestamp + Lattice + Codec64 + TimestampManipulation> Clone for PersistMonotonicWriteWorker<T>

fn clone(&self) -> PersistMonotonicWriteWorker<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + Timestamp + Lattice + Codec64 + TimestampManipulation> Debug for PersistMonotonicWriteWorker<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.