Struct mz_adapter_types::compaction::ReadCapability

pub struct ReadCapability<T = Timestamp>
where
    T: Timestamp,
{
    pub base_policy: ReadPolicy<T>,
    pub holds: MutableAntichain<T>,
}

Information about the read capability requirements of a collection.

This type tracks both a default policy, as well as various holds that may be expressed, as by transactions to ensure collections remain readable.

Fields

base_policy: ReadPolicy<T>

The default read policy for the collection when no holds are present.

holds: MutableAntichain<T>

Holds expressed by transactions, that should prevent compaction.

Implementations

impl<T: Timestamp> ReadCapability<T>

pub fn policy(&self) -> ReadPolicy<T>

Acquires the effective read policy, reflecting both the base policy and any holds.

Trait Implementations

impl<T> Debug for ReadCapability<T>

where T: Timestamp + Debug,

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

Formats the value using the given formatter.

impl From<CompactionWindow> for ReadCapability<Timestamp>

fn from(value: CompactionWindow) -> Self

Converts to this type from the input type.

impl<T: Timestamp> From<ReadPolicy<T>> for ReadCapability<T>

fn from(base_policy: ReadPolicy<T>) -> Self

Converts to this type from the input type.

impl<T> Serialize for ReadCapability<T>

where T: Timestamp + Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.