Struct mz_compute_client::controller::instance::ReplicaCollectionState

struct ReplicaCollectionState<T: ComputeControllerTimestamp> {
    write_frontier: Antichain<T>,
    input_frontier: Antichain<T>,
    output_frontier: Antichain<T>,
    metrics: Option<ReplicaCollectionMetrics>,
    created_at: Instant,
    as_of: Antichain<T>,
    hydrated: bool,
    introspection: ReplicaCollectionIntrospection<T>,
    input_read_holds: Vec<ReadHold<T>>,
    wallclock_lag_max: Duration,
}

Fields

write_frontier: Antichain<T>

The replica write frontier of this collection.

See FrontiersResponse::write_frontier.

input_frontier: Antichain<T>

The replica input frontier of this collection.

See FrontiersResponse::input_frontier.

output_frontier: Antichain<T>

The replica output frontier of this collection.

See FrontiersResponse::output_frontier.

metrics: Option<ReplicaCollectionMetrics>

Metrics tracked for this collection.

If this is None, no metrics are collected.

created_at: Instant

Time at which this collection was installed.

as_of: Antichain<T>

As-of frontier with which this collection was installed on the replica.

hydrated: bool

Whether the collection is hydrated.

introspection: ReplicaCollectionIntrospection<T>

Tracks introspection state for this collection.

input_read_holds: Vec<ReadHold<T>>

Read holds on storage inputs to this collection.

These read holds are kept to ensure that the replica is able to read from storage inputs at all times it hasn’t read yet. We only need to install read holds for storage inputs since compaction of compute inputs is implicitly held back by Timely/DD.

wallclock_lag_max: Duration

Maximum frontier wallclock lag since the last introspection update.

Implementations

impl<T: ComputeControllerTimestamp> ReplicaCollectionState<T>

fn new( metrics: Option<ReplicaCollectionMetrics>, as_of: Antichain<T>, introspection: ReplicaCollectionIntrospection<T>, input_read_holds: Vec<ReadHold<T>>, ) -> Self

fn hydrated(&self) -> bool

Returns whether this collection is hydrated.

fn set_hydrated(&mut self)

Marks the collection as hydrated and updates metrics and introspection accordingly.

fn update_write_frontier(&mut self, new_frontier: Antichain<T>)

Updates the replica write frontier of this collection.

fn update_input_frontier(&mut self, new_frontier: Antichain<T>)

Updates the replica input frontier of this collection.

fn update_output_frontier(&mut self, new_frontier: Antichain<T>)

Updates the replica output frontier of this collection.

Trait Implementations

impl<T: Debug + ComputeControllerTimestamp> Debug for ReplicaCollectionState<T>

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

Formats the value using the given formatter.