Struct HybridSearchEngine 

pub struct HybridSearchEngine { /* private fields */ }

HybridSearchEngine - Orchestrates semantic and keyword search

Features:

• Combines VectorSearchEngine (semantic) and KeywordSearchEngine (keyword)
• Score fusion using Reciprocal Rank Fusion (RRF)
• Metadata filtering for event_type, entity_id, and time range
• Configurable search modes and weights

Implementations

impl HybridSearchEngine

pub fn new( vector_engine: Arc<VectorSearchEngine>, keyword_engine: Arc<KeywordSearchEngine>, ) -> Self

Create a new HybridSearchEngine with existing engines

pub fn with_config( vector_engine: Arc<VectorSearchEngine>, keyword_engine: Arc<KeywordSearchEngine>, config: HybridSearchEngineConfig, ) -> Self

Create a new HybridSearchEngine with custom configuration

pub fn config(&self) -> &HybridSearchEngineConfig

Get the engine configuration

pub fn store_metadata(&self, event_id: Uuid, metadata: EventMetadata)

Store metadata for an event (for post-search filtering)

pub async fn index_event( &self, event_id: Uuid, _tenant_id: &str, event_type: &str, entity_id: Option<&str>, _payload: &Value, timestamp: DateTime<Utc>, ) -> Result<()>

Stub for when features are not enabled

pub fn commit(&self) -> Result<()>

pub fn search(&self, query: &SearchQuery) -> Result<Vec<HybridSearchResult>>

Perform a search using the configured mode

This is the main entry point for searching. It:

1. Runs semantic search (if natural language query and mode allows)
2. Runs keyword search (if keywords present and mode allows)
3. Combines and re-ranks scores using RRF
4. Applies metadata filters
5. Returns top-k results

pub fn stats(&self) -> (u64, u64, u64, u64)

Get engine statistics

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

Health check for both engines

pub fn cached_metadata_count(&self) -> usize

Get the number of events in the metadata cache

pub fn clear_metadata_cache(&self)

Clear the metadata cache