Struct RagController 

pub struct RagController { /* private fields */ }

Sends commands to the Ragrig worker and mirrors its state for widgets.

Implementations

impl RagController

pub fn new(setup: RagSetup, cx: &mut Context<'_, Self>) -> Result<Self, String>

Spawn the worker and start mirroring its events.

Returns an error when the worker thread cannot be created; an agent that fails to build is reported later through RagEvent::AgentFailed.

pub fn ask( &mut self, prompt: impl Into<String>, attachments: Vec<PendingAttachment>, cx: &mut Context<'_, Self>, ) -> Result<RequestId, String>

Ask one question and return the request identity.

pub fn ask_with_retrieval( &mut self, prompt: impl Into<String>, retrieval: Option<String>, attachments: Vec<PendingAttachment>, cx: &mut Context<'_, Self>, ) -> Result<RequestId, String>

Ask one question whose retrieval is enriched with retrieval.

The worker prepends retrieval to the prompt before embedding and searching, so a marked passage drives the similarity search as well as the question. An empty or whitespace-only enrichment is ignored. The host transcript still echoes only the prompt.

pub fn stop(&mut self, id: RequestId, cx: &mut Context<'_, Self>)

Stop one running generation.

pub fn new_session(&mut self, cx: &mut Context<'_, Self>)

Start an empty conversation.

pub fn load_session( &mut self, id: impl Into<String>, cx: &mut Context<'_, Self>, )

Continue a saved conversation.

pub fn refresh_sessions(&mut self, cx: &mut Context<'_, Self>)

Re-read the session store.

pub fn refresh_library(&mut self, cx: &mut Context<'_, Self>)

Re-read the vector store.

pub fn sync_corpus( &mut self, name: impl Into<String>, folder: impl Into<PathBuf>, cx: &mut Context<'_, Self>, ) -> Result<RequestId, String>

Index a folder as a named corpus.

pub fn stop_sync(&mut self, cx: &mut Context<'_, Self>)

Stop the running ingestion.

pub fn apply(&mut self, setup: RagSetup, cx: &mut Context<'_, Self>)

Rebuild the agent with new configuration.

pub fn sessions(&self) -> &[SessionEntry]

Saved conversations, newest first.

pub fn current_session(&self) -> Option<&str>

The active conversation id, when known.

pub fn library(&self) -> &LibrarySnapshot

The last library snapshot.

pub fn agent(&self) -> Option<&AgentInfo>

The active agent, once it built successfully.

pub fn ingest_progress(&self) -> Option<&IngestProgress>

The running ingestion, if any.

pub fn is_busy(&self) -> bool

Whether an answer is streaming.

pub fn is_ingesting(&self) -> bool

Whether a corpus is being indexed.

pub fn error(&self) -> Option<&str>

The last fatal error.

pub fn status_line(&self) -> String

One line for a status bar.

pub fn memory_enabled(&self) -> bool

Whether conversation memory is on.

pub fn hybrid(&self) -> bool

Whether hybrid retrieval (embeddings) is on.

pub fn agent_components(&self) -> Vec<AgentComponent>

Pipeline components for AgentBar.

Trait Implementations

impl Drop for RagController

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl EventEmitter<RagEvent> for RagController