Struct LlmQueryService 

pub struct LlmQueryService { /* private fields */ }

Service for LLM-based query analysis and summarization

Implementations

impl LlmQueryService

pub fn new(config: IngestionConfig) -> Result<Self, String>

Create a new LLM query service

pub async fn analyze_query( &self, user_query: &str, schemas: &[SchemaWithState], ) -> Result<QueryPlan, String>

Analyze a natural language query and create an execution plan

pub async fn summarize_results( &self, original_query: &str, results: &[Value], ) -> Result<String, String>

Summarize query results

pub async fn answer_question( &self, original_query: &str, results: &[Value], conversation_history: &[Message], question: &str, ) -> Result<String, String>

Answer a follow-up question based on context

pub async fn analyze_followup_question( &self, original_query: &str, results: &[Value], question: &str, schemas: &[SchemaWithState], ) -> Result<FollowupAnalysis, String>

Analyze if a follow-up question needs a new query or can be answered from existing results

pub async fn generate_native_index_query_terms( &self, user_query: &str, schemas: &[SchemaWithState], ) -> Result<Vec<String>, String>

Generate query terms for native index search based on a natural language query

pub async fn execute_ai_native_index_query( &self, user_query: &str, schemas: &[SchemaWithState], db_ops: &DbOperations, ) -> Result<String, String>

Execute a complete AI-native index query workflow

pub async fn execute_ai_native_index_query_with_results( &self, user_query: &str, schemas: &[SchemaWithState], db_ops: &DbOperationsV2, ) -> Result<(String, Vec<IndexResult>), String>

Execute a complete AI-native index query workflow and return both AI interpretation and raw results

pub async fn suggest_alternative_query( &self, original_user_query: &str, failed_query: &Query, schemas: &[SchemaWithState], previous_attempts: &[String], ) -> Result<Option<QueryPlan>, String>

Suggest alternative query strategies when results are empty