rivven-core 0.0.15

Core library for Rivven distributed event streaming platform
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use super::traits::StorageBackend;

/// In-memory storage (no persistence)
pub struct MemoryStorage;

impl StorageBackend for MemoryStorage {
    fn store(
        &self,
        _topic: &str,
        _partition: u32,
        _offset: u64,
        _data: &[u8],
    ) -> crate::Result<()> {
        // No-op for memory storage
        Ok(())
    }

    fn retrieve(
        &self,
        _topic: &str,
        _partition: u32,
        _start_offset: u64,
        _max_messages: usize,
    ) -> crate::Result<Vec<(u64, Vec<u8>)>> {
        Ok(Vec::new())
    }

    fn trim(&self, _topic: &str, _partition: u32, _before_offset: u64) -> crate::Result<()> {
        Ok(())
    }
}