Struct mz_dataflow_types::client::controller::storage::CollectionState

pub struct CollectionState<T> {
    pub read_capabilities: MutableAntichain<T>,
    pub implied_capability: Antichain<T>,
    pub read_policy: ReadPolicy<T>,
    pub write_frontier: MutableAntichain<T>,
    pub collection_metadata: CollectionMetadata,
    /* private fields */
}

State maintained about individual collections.

Fields

read_capabilities: MutableAntichain<T>

Accumulation of read capabilities for the collection.

This accumulation will always contain self.implied_capability, but may also contain capabilities held by others who have read dependencies on this collection.

implied_capability: Antichain<T>

The implicit capability associated with collection creation.

read_policy: ReadPolicy<T>

The policy to use to downgrade self.implied_capability.

write_frontier: MutableAntichain<T>

Reported progress in the write capabilities.

Importantly, this is not a write capability, but what we have heard about the write capabilities of others. All future writes will have times greater than or equal to write_frontier.frontier().

collection_metadata: CollectionMetadata

Implementations

impl<T: Timestamp> CollectionState<T>

pub fn new(
    description: CollectionDescription,
    since: Antichain<T>,
    metadata: CollectionMetadata
) -> Self

Creates a new collection state, with an initial read policy valid from since.

Trait Implementations

impl<T: Debug> Debug for CollectionState<T>

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

Formats the value using the given formatter.