Struct IntegratedVectorStore 

pub struct IntegratedVectorStore { /* private fields */ }

Integrated vector store with advanced capabilities

Implementations

impl IntegratedVectorStore

pub fn new( config: StoreIntegrationConfig, embedding_strategy: EmbeddingStrategy, ) -> Result<Self>

pub fn begin_transaction( &self, isolation_level: IsolationLevel, ) -> Result<TransactionId>

Begin a new transaction

pub fn commit_transaction(&self, transaction_id: TransactionId) -> Result<()>

Commit a transaction

pub fn abort_transaction(&self, transaction_id: TransactionId) -> Result<()>

Abort a transaction

pub fn transactional_insert( &self, transaction_id: TransactionId, uri: String, vector: Vector, embedding_content: Option<EmbeddableContent>, ) -> Result<()>

Insert vector within a transaction

pub fn stream_insert( &self, uri: String, vector: Vector, priority: Priority, ) -> Result<()>

Stream-based insert for high throughput

pub fn batch_insert( &self, items: Vec<(String, Vector)>, auto_commit: bool, ) -> Result<TransactionId>

Batch insert with automatic transaction management

pub fn consistent_search( &self, query: &Vector, k: usize, consistency_level: Option<ConsistencyLevel>, ) -> Result<Vec<(String, f32)>>

Search with caching and consistency guarantees

pub fn rdf_vector_search( &self, rdf_term: &str, k: usize, graph_context: Option<&str>, ) -> Result<Vec<(String, f32)>>

RDF-aware vector search

pub fn sparql_vector_search( &self, _query: &str, bindings: &HashMap<String, String>, ) -> Result<Vec<HashMap<String, String>>>

SPARQL-integrated vector search

pub fn subscribe_to_changes( &self, subscriber: Arc<dyn ChangeSubscriber>, ) -> Result<()>

Add change subscriber for real-time notifications

pub fn get_metrics(&self) -> StoreMetrics

Get store metrics

pub fn health_check(&self) -> Result<HealthStatus>

Health check for the integrated store