Trait VectorSink 

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

    // Provided method
    fn nearest_similarity<'a>(
        &'a self,
        _session_id: &'a str,
        _vector: &'a [f32],
    ) -> VectorSearchFuture<'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.

Implementors

impl VectorSink for NoopVectorSink

impl VectorSink for QdrantVectorSink

Available on crate feature qdrant only.