MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / shared_upper

Method shared_upper

src/persist-client/src/write.rs:267–269  ·  view source on GitHub ↗

A less-stale cached version of the shard-global `upper` frontier. This is the most recently known upper for this shard process-wide, but unlike [Self::upper] it requires a mutex and a clone. This will always be less or equal to the shard-global `upper`.

(&self)

Source from the content-addressed store, hash-verified

265 /// unlike [Self::upper] it requires a mutex and a clone. This will always be
266 /// less or equal to the shard-global `upper`.
267 pub fn shared_upper(&self) -> Antichain<T> {
268 self.machine.applier.clone_upper()
269 }
270
271 /// Fetches and returns a recent shard-global `upper`. Importantly, this operation is
272 /// linearized with write operations.

Callers 15

advance_upperMethod · 0.80
sink_collectionFunction · 0.80
commit_to_icebergFunction · 0.80
monotonic_appendFunction · 0.80
registerMethod · 0.80
forgetMethod · 0.80
forget_allMethod · 0.80
forget_at_innerFunction · 0.80
write_directMethod · 0.80
commit_atMethod · 0.80

Calls 1

clone_upperMethod · 0.80

Tested by

no test coverage detected