walrus_rust/wal/runtime/
walrus_write.rs

1use super::Walrus;
2
3impl Walrus {
4    pub fn append_for_topic(&self, col_name: &str, raw_bytes: &[u8]) -> std::io::Result<()> {
5        let writer = self.get_or_create_writer(col_name)?;
6        writer.write(raw_bytes)
7    }
8
9    pub fn batch_append_for_topic(&self, col_name: &str, batch: &[&[u8]]) -> std::io::Result<()> {
10        let writer = self.get_or_create_writer(col_name)?;
11        writer.batch_write(batch)
12    }
13}