Struct mz_storage::controller::persist_write_handles::PersistWorker

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

Fields

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

Implementations

impl<T: Timestamp + Lattice + Codec64 + TimestampManipulation> PersistWorker<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 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: PersistWorkerCmd<T>)

Trait Implementations

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

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

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

Formats the value using the given formatter.

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

fn drop(&mut self)

Executes the destructor for this type.