(
&self,
write_ts: Timestamp,
advance_to: Timestamp,
updates: Vec<(GlobalId, Vec<TableData>)>,
)
| 239 | } |
| 240 | |
| 241 | pub(crate) fn append( |
| 242 | &self, |
| 243 | write_ts: Timestamp, |
| 244 | advance_to: Timestamp, |
| 245 | updates: Vec<(GlobalId, Vec<TableData>)>, |
| 246 | ) -> tokio::sync::oneshot::Receiver<Result<(), StorageError>> { |
| 247 | let (tx, rx) = tokio::sync::oneshot::channel(); |
| 248 | // Always send the append command to the txn-wal layer, even for empty |
| 249 | // updates. The txn-wal commit advances the logical upper of ALL |
| 250 | // registered data shards, which is needed for periodic group commits |
| 251 | // that have no actual data writes. |
| 252 | self.send(PersistTableWriteCmd::Append { |
| 253 | write_ts, |
| 254 | advance_to, |
| 255 | updates, |
| 256 | tx, |
| 257 | }); |
| 258 | rx |
| 259 | } |
| 260 | |
| 261 | /// Drops the handles associated with `ids` from this worker. |
| 262 | /// |
no test coverage detected