Struct mz_persist_client::batch::PartDeletes

pub(crate) struct PartDeletes<T> {
    blob_keys: BTreeSet<PartialBatchKey>,
    hollow_runs: BTreeMap<PartialBatchKey, HollowRunRef<T>>,
}

Fields

blob_keys: BTreeSet<PartialBatchKey>

Keys to hollow parts or runs that we’re ready to delete.

hollow_runs: BTreeMap<PartialBatchKey, HollowRunRef<T>>

Keys to hollow runs that may not have had all their parts deleted (or added to blob_keys) yet.

Implementations

impl<T: Timestamp> PartDeletes<T>

pub fn add(&mut self, part: &RunPart<T>) -> bool

pub fn contains(&self, part: &RunPart<T>) -> bool

pub fn is_empty(&self) -> bool

pub fn len(&self) -> usize

pub async fn delete( self, blob: &dyn Blob, shard_id: ShardId, concurrency: usize, metrics: &Metrics, delete_metrics: &RetryMetrics, )

where T: Codec64,

Trait Implementations

impl<T: Debug> Debug for PartDeletes<T>

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

Formats the value using the given formatter.

impl<T> Default for PartDeletes<T>

fn default() -> Self

Returns the “default value” for a type.