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

Method apply_write

src/timestamp-oracle/src/postgres_oracle.rs:959–971  ·  view source on GitHub ↗
(&self, write_ts: Timestamp)

Source from the content-addressed store, hash-verified

957
958 #[instrument]
959 async fn apply_write(&self, write_ts: Timestamp) {
960 let metrics = &self.metrics.retries.apply_write;
961
962 let res = retry_fallible(metrics, || {
963 self.metrics
964 .oracle
965 .apply_write
966 .run_op(|| self.fallible_apply_write(write_ts.clone()))
967 })
968 .await;
969
970 res
971 }
972}
973
974pub const INFO_MIN_ATTEMPTS: usize = 3;

Callers 1

Calls 4

retry_fallibleFunction · 0.85
fallible_apply_writeMethod · 0.80
run_opMethod · 0.45
cloneMethod · 0.45

Tested by

no test coverage detected