(
&self,
collection: &Collection,
op: VectorOp,
)
| 246 | } |
| 247 | |
| 248 | pub fn append_to_wal( |
| 249 | &self, |
| 250 | collection: &Collection, |
| 251 | op: VectorOp, |
| 252 | ) -> Result<(), WaCustomError> { |
| 253 | let data = self.init(collection)?; |
| 254 | data.channel.send(op).unwrap(); |
| 255 | Ok(()) |
| 256 | } |
| 257 | |
| 258 | pub fn pre_commit(self, collection: &Collection, config: &Config) -> Result<(), WaCustomError> { |
| 259 | let Some(data) = self.data.into_inner() else { |
no test coverage detected