Struct mz_storage::controller::persist_read_handles::PersistWorker

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

A wrapper that holds on to backing persist shards/collections that the storage controller is aware of. The handles hold back the since frontier and we need to downgrade them when the read capabilities change.

Internally, this has an async task and the methods for registering a handle and downgrading sinces add commands to a queue that this task is working off. This makes the methods non-blocking and moves the work outside the main coordinator task, meaning the coordinator is spending less time waiting on persist calls.

Fields

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

Implementations

impl<T: Timestamp + Lattice + Codec64> PersistWorker<T>

pub(crate) fn new() -> Self

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

pub(crate) fn downgrade(&self, frontiers: BTreeMap<GlobalId, Antichain<T>>)

pub(crate) fn snapshot(
    &self,
    id: GlobalId,
    since: Antichain<T>
) -> Receiver<Result<Vec<(Row, Diff)>, StorageError>>

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

Trait Implementations

impl<T: Debug + Timestamp + Lattice + Codec64> 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,

fn drop(&mut self)

Executes the destructor for this type.