Struct HotStore

pub struct HotStore {
    db: DBWithThreadMode<SingleThreaded>,
}

RocksDB-backed persistent storage for the hot tier.

Implements StorageBackend with data surviving process restarts.

Example

use cvx_core::{StorageBackend, TemporalPoint};
use cvx_storage::hot::HotStore;

let store = HotStore::open("/tmp/cvx-test").unwrap();
let point = TemporalPoint::new(42, 1000, vec![0.1, 0.2, 0.3]);
store.put(0, &point).unwrap();

let retrieved = store.get(42, 0, 1000).unwrap();
assert_eq!(retrieved, Some(point));

Fields

db: DBWithThreadMode<SingleThreaded>

Implementations

impl HotStore

pub fn open<P: AsRef<Path>>(path: P) -> Result<Self, StorageError>

Open or create a HotStore at the given path.

fn vectors_cf_options() -> Options

Configure the vectors column family.

fn timelines_cf_options() -> Options

Configure the timelines column family.

fn vectors_cf(&self) -> &ColumnFamily

Get the CF handle for vectors.

fn timelines_cf(&self) -> &ColumnFamily

Get the CF handle for timelines.

fn serialize_vector(vector: &[f32]) -> Vec<u8>

Serialize a vector to raw bytes (native f32 layout).

fn deserialize_vector(bytes: &[u8]) -> Vec<f32>

Deserialize raw bytes back to a vector.

fn update_timeline( &self, entity_id: u64, space_id: u32, timestamp: i64, ) -> Result<(), StorageError>

Update the timeline metadata for an entity after a put.

pub fn get_timeline( &self, entity_id: u64, space_id: u32, ) -> Result<Option<EntityTimeline>, StorageError>

Get the timeline metadata for an entity in a space.

Trait Implementations

impl StorageBackend for HotStore

fn get( &self, entity_id: u64, space_id: u32, timestamp: i64, ) -> Result<Option<TemporalPoint>, StorageError>

Retrieve a single point by entity, space, and timestamp.

fn put(&self, space_id: u32, point: &TemporalPoint) -> Result<(), StorageError>

Store a temporal point.

fn range( &self, entity_id: u64, space_id: u32, start: i64, end: i64, ) -> Result<Vec<TemporalPoint>, StorageError>

Retrieve all points for an entity in a time range, ordered by timestamp.

fn delete( &self, entity_id: u64, space_id: u32, timestamp: i64, ) -> Result<(), StorageError>

Delete a specific point.