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

Method read_frontier

src/compute-client/src/controller/instance.rs:2648–2651  ·  view source on GitHub ↗

Reports the current read frontier.

(&self)

Source from the content-addressed store, hash-verified

2646
2647 /// Reports the current read frontier.
2648 fn read_frontier(&self) -> Antichain<Timestamp> {
2649 self.shared
2650 .lock_read_capabilities(|c| c.frontier().to_owned())
2651 }
2652
2653 /// Reports the current write frontier.
2654 fn write_frontier(&self) -> Antichain<Timestamp> {

Callers 5

add_replica_stateMethod · 0.80
refresh_wallclock_lagMethod · 0.80
allow_writesMethod · 0.80

Calls 3

to_ownedMethod · 0.45
frontierMethod · 0.45

Tested by

no test coverage detected