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

Method write

src/txn-wal/src/txn_write.rs:90–96  ·  view source on GitHub ↗
(&mut self, data_id: &ShardId, key: K, val: V, diff: D)

Source from the content-addressed store, hash-verified

88 /// make the ts rewrite op efficient.
89 #[allow(clippy::unused_async)]
90 pub async fn write(&mut self, data_id: &ShardId, key: K, val: V, diff: D) {
91 self.writes
92 .entry(*data_id)
93 .or_default()
94 .writes
95 .push((key, val, diff))
96 }
97
98 /// Stage a [`Batch`] to the in-progress txn.
99 ///

Callers 5

commit_atFunction · 0.45
apply_and_tidyFunction · 0.45
conflicting_writesFunction · 0.45
commit_retryFunction · 0.45

Calls 2

pushMethod · 0.45
entryMethod · 0.45

Tested by

no test coverage detected