Struct mz_persist_client::internal::maintenance::WriterMaintenance

pub struct WriterMaintenance<T> {
    pub(crate) routine: RoutineMaintenance,
    pub(crate) compaction: Vec<CompactReq<T>>,
}

Writers may be asked to perform additional tasks beyond the routine maintenance common to all handles. It is expected that writers always perform maintenance.

Fields

routine: RoutineMaintenance

compaction: Vec<CompactReq<T>>

Implementations

impl<T> WriterMaintenance<T>

where T: Timestamp + Lattice + Codec64 + Sync,

pub(crate) fn start_performing<K, V, D>( self, machine: &Machine<K, V, T, D>, gc: &GarbageCollector<K, V, T, D>, compactor: Option<&Compactor<K, V, T, D>>, )

where K: Debug + Codec, V: Debug + Codec, D: Semigroup + Ord + Codec64 + Send + Sync,

Initiates any writer maintenance necessary in background tasks

pub(crate) async fn perform<K, V, D>( self, machine: &Machine<K, V, T, D>, gc: &GarbageCollector<K, V, T, D>, compactor: Option<&Compactor<K, V, T, D>>, )

where K: Debug + Codec, V: Debug + Codec, D: Semigroup + Ord + Codec64 + Send + Sync,

Performs any writer maintenance necessary. Returns when all background tasks have completed and the maintenance is done.

Trait Implementations

impl<T: Debug> Debug for WriterMaintenance<T>

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

Formats the value using the given formatter.

impl<T> Default for WriterMaintenance<T>

fn default() -> Self

Returns the “default value” for a type.