Struct RagClient 

pub struct RagClient { /* private fields */ }

HTTP client for one vault’s collection on a RAG server.

Implementations

impl RagClient

pub fn new( base_url: impl Into<String>, token: Option<String>, vault_id: impl Into<String>, ) -> Self

base_url like http://host:7573; token is the bearer token if the server requires one; vault_id selects this vault’s collection.

pub async fn health(&self) -> Result<Health, RagError>

Probes GET /health for reachability + capabilities.

pub async fn push_docs(&self, docs: Vec<WireDoc>) -> Result<String, RagError>

Pushes documents to this vault’s collection; returns the server’s job id.

pub async fn delete_paths(&self, paths: Vec<String>) -> Result<(), RagError>

Deletes notes by path from this vault’s collection.

pub async fn server_hashes(&self) -> Result<HashMap<String, String>, RagError>

The server’s {note-path → hash} set for this vault (reconcile input).

vault_id is interpolated into the URL path un-encoded; this is safe because it is always a UUID (from .kimun/vault-id) and thus URL-safe. If that ever changes, percent-encode the segment here.

pub async fn search( &self, query: &str, context_size: Option<ContextSize>, ) -> Result<Vec<ChunkResult>, RagError>

Semantic search: returns the matching chunks (no LLM). context_size omitted uses the server’s configured default.

pub async fn ask( &self, query: &str, history: &[(String, String)], context_size: Option<ContextSize>, ) -> Result<AnswerResult, RagError>

Submits a question, polls the job to completion, and returns the LLM answer plus its cited source chunks.

Trait Implementations

impl Clone for RagClient

fn clone(&self) -> RagClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl RagTransport for RagClient

fn push_docs<'life0, 'async_trait>( &'life0 self, docs: Vec<WireDoc>, ) -> Pin<Box<dyn Future<Output = Result<(), RagError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn delete_paths<'life0, 'async_trait>( &'life0 self, paths: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<(), RagError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn server_hashes<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, String>, RagError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,