Struct StreamingTemporalHnsw

pub struct StreamingTemporalHnsw<D: DistanceMetric + Clone> {
    buffer: HotBuffer,
    compacted: PartitionedTemporalHnsw<D>,
    config: StreamingConfig,
    metric: D,
    next_global_id: u32,
    compaction_count: usize,
}

Streaming temporal index that combines a hot buffer with a compacted partitioned HNSW index.

Fields

buffer: HotBuffer

Hot buffer for recent writes.

compacted: PartitionedTemporalHnsw<D>

Compacted partitioned index.

config: StreamingConfig

Configuration.

metric: D

Metric instance.

next_global_id: u32

Next global ID to assign.

compaction_count: usize

Number of compactions performed.

Implementations

impl<D: DistanceMetric + Clone> StreamingTemporalHnsw<D>

pub fn new(config: StreamingConfig, metric: D) -> Self

Create a new streaming index.

pub fn insert(&mut self, entity_id: u64, timestamp: i64, vector: &[f32]) -> u32

Insert a point. Goes into the hot buffer first.

Triggers compaction if the buffer exceeds capacity.

pub fn compact(&mut self)

Manually trigger compaction: flush buffer into the partitioned index.

pub fn search( &self, query: &[f32], k: usize, filter: TemporalFilter, alpha: f32, query_timestamp: i64, ) -> Vec<(u32, f32)>

Search across both buffer and compacted index.

pub fn trajectory( &self, entity_id: u64, filter: TemporalFilter, ) -> Vec<(i64, u32)>

Retrieve trajectory across buffer and compacted index.

pub fn vector(&self, global_id: u32) -> Vec<f32>

Get vector by global node ID (checks buffer first, then compacted).

pub fn entity_id(&self, global_id: u32) -> u64

Get entity ID by global node ID.

pub fn timestamp(&self, global_id: u32) -> i64

Get timestamp by global node ID.

pub fn len(&self) -> usize

Total number of indexed points (buffer + compacted).

pub fn is_empty(&self) -> bool

Whether the index is empty.

pub fn buffer_len(&self) -> usize

Number of points in the hot buffer.

pub fn compacted_len(&self) -> usize

Number of points in the compacted index.

pub fn compaction_count(&self) -> usize

Number of compactions performed.

pub fn save(&mut self, dir: &Path) -> Result<()>

Save the compacted index (buffer should be compacted first).

Trait Implementations

impl<D: DistanceMetric + Clone> TemporalIndexAccess for StreamingTemporalHnsw<D>

fn search_raw( &self, query: &[f32], k: usize, filter: TemporalFilter, alpha: f32, query_timestamp: i64, ) -> Vec<(u32, f32)>

Search with temporal filtering, returning (node_id, score) pairs.

fn trajectory(&self, entity_id: u64, filter: TemporalFilter) -> Vec<(i64, u32)>

Retrieve trajectory for an entity: (timestamp, node_id) pairs.

fn vector(&self, node_id: u32) -> Vec<f32>

Get the vector for a node. Returns owned vec for thread safety.

fn entity_id(&self, node_id: u32) -> u64

Get the entity_id for a node.

fn timestamp(&self, node_id: u32) -> i64

Get the timestamp for a node.

fn len(&self) -> usize

Number of points in the index.

fn is_empty(&self) -> bool

Whether the index is empty.

fn regions(&self, _level: usize) -> Vec<(u32, Vec<f32>, usize)>

Get semantic regions at a given HNSW level (RFC-004). Returns (hub_node_id, hub_vector, n_assigned) per region.

fn region_members( &self, _region_hub: u32, _level: usize, _filter: TemporalFilter, ) -> Vec<(u32, u64, i64)>

Get points belonging to a specific region, optionally time-filtered (RFC-005). Returns (node_id, entity_id, timestamp) per member.

fn region_assignments( &self, _level: usize, _filter: TemporalFilter, ) -> HashMap<u32, Vec<(u64, i64)>>

Assign all nodes to regions in a single O(N) pass, optionally time-filtered. Returns HashMap<hub_id, Vec<(entity_id, timestamp)>>.

fn region_trajectory( &self, _entity_id: u64, _level: usize, _window_days: i64, _alpha: f32, ) -> Vec<(i64, Vec<f32>)>

Smoothed region-distribution trajectory for an entity (RFC-004).

fn metadata(&self, _node_id: u32) -> HashMap<String, String>

Get metadata for a node. Returns empty map if not available.

fn search_with_metadata( &self, query: &[f32], k: usize, filter: TemporalFilter, alpha: f32, query_timestamp: i64, metadata_filter: &MetadataFilter, ) -> Vec<(u32, f32)>

Search with metadata filtering (post-filter on search results). Default: ignores metadata filter and delegates to search_raw.