Struct mz_storage_client::controller::persist_handles::PersistWriteWorker

pub struct PersistWriteWorker<T: Timestamp + Lattice + Codec64 + TimestampManipulation> {
    tx: UnboundedSender<(Span, PersistWriteWorkerCmd<T>)>,
}

Fields

tx: UnboundedSender<(Span, PersistWriteWorkerCmd<T>)>

Implementations

impl<T: Timestamp + Lattice + Codec64 + TimestampManipulation> PersistWriteWorker<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 append(
    &self,
    updates: Vec<(GlobalId, Vec<Update<T>>, T)>
) -> Receiver<Result<(), StorageError>>

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.

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

Trait Implementations

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

fn clone(&self) -> PersistWriteWorker<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 PersistWriteWorker<T>

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

Formats the value using the given formatter.

impl<T> Drop for PersistWriteWorker<T>where
    T: Timestamp + Lattice + Codec64 + TimestampManipulation,

fn drop(&mut self)

Executes the destructor for this type.