Trait VectorSink 

pub trait VectorSink: Send + Sync {
    // Required method
    fn record<'a>(
        &'a self,
        session_id: &'a str,
        vector: &'a [f32],
    ) -> VectorSinkFuture<'a>;

    // Provided methods
    fn nearest_similarity<'a>(
        &'a self,
        _session_id: &'a str,
        _vector: &'a [f32],
    ) -> VectorSearchFuture<'a> { ... }
    fn delete_scope<'a>(
        &'a self,
        _session_scope: &'a str,
    ) -> VectorSinkFuture<'a> { ... }
}

Storage boundary for reasoning-step embeddings.

Required Methods

fn record<'a>( &'a self, session_id: &'a str, vector: &'a [f32], ) -> VectorSinkFuture<'a>

Persist one session vector without participating in the hot path.

Provided Methods

fn nearest_similarity<'a>( &'a self, _session_id: &'a str, _vector: &'a [f32], ) -> VectorSearchFuture<'a>

Return the highest cosine similarity among prior vectors for a session.

fn delete_scope<'a>(&'a self, _session_scope: &'a str) -> VectorSinkFuture<'a>

Delete every vector recorded under session_scope. Called best-effort when a session finalizes so the external store does not grow without bound — the id#generation scoping makes prior-generation points permanently unreachable dead weight otherwise. Default no-op for sinks without external state.

Implementors

impl VectorSink for NoopVectorSink

impl VectorSink for QdrantVectorSink

Available on crate feature qdrant only.