Struct RKit 

pub struct RKit { /* private fields */ }

Implementations

impl RKit

pub fn new( db_engine: DbEngine, embeddings_provider: EmbeddingsProviderKind, ) -> Result<Self, RKitConfigError>

pub async fn init(&mut self) -> Result<(), RKitInitError>

pub fn is_initialized(&self) -> bool

pub fn db_engine_initialized(&self) -> bool

pub fn embeddings_provider_initialized(&self) -> bool

pub fn lancedb_backend(&self) -> Option<&LanceDbBackend>

pub fn ort_embedder(&self) -> Option<&OrtEmbedder>

pub fn ort_embedder_mut(&mut self) -> Option<&mut OrtEmbedder>

pub fn clear_initialized_state(&mut self)

pub fn db_engine_config(&self) -> &DbEngine

pub fn embeddings_provider_config(&self) -> &EmbeddingsProviderKind

pub fn chunking_config(&self) -> ChunkingConfig

pub fn set_chunking_config( &mut self, chunking_config: ChunkingConfig, ) -> Result<(), RKitConfigError>

pub fn select_db_engine( &mut self, db_engine: DbEngine, ) -> Result<(), RKitConfigError>

pub fn register_embeddings_provider( &mut self, embeddings_provider: EmbeddingsProviderKind, ) -> Result<(), RKitConfigError>

pub async fn ingest_document( &mut self, content: String, ) -> Result<IngestDocumentResult, IngestDocumentError>

pub async fn ingest_document_file<P: AsRef<Path>>( &mut self, path: P, ) -> Result<IngestDocumentResult, IngestDocumentError>

pub async fn upsert_document( &mut self, id: String, content: String, ) -> Result<IngestDocumentResult, IngestDocumentError>

pub async fn ingest_documents( &mut self, documents: Vec<String>, ) -> Result<Vec<IngestDocumentResult>, IngestDocumentError>

pub async fn ingest_document_files( &mut self, pattern: &str, ) -> Result<Vec<IngestDocumentResult>, IngestDocumentError>

pub async fn vector_search( &self, query: String, limit: usize, ) -> Result<Vec<VectorSearchResult>, VectorSearchError>

pub async fn keyword_search( &self, query: String, limit: usize, ) -> Result<Vec<KeywordSearchResult>, KeywordSearchError>

pub async fn list_documents( &self, ) -> Result<Vec<DocumentSummary>, DocumentError>

pub async fn get_document( &self, id: String, ) -> Result<Option<Document>, DocumentError>

pub async fn delete_document(&self, id: String) -> Result<(), DocumentError>

pub fn get_tool_definitions( &self, descriptions: Option<ToolDescriptions>, ) -> Vec<ToolDefinition>

pub async fn invoke_tool( &self, name: &str, arguments: Value, ) -> Result<Value, InvokeToolError>