Struct AutoPilotEngine 

pub struct AutoPilotEngine {
    pub config: AutoPilotConfig,
}

Auto-Pilot engine that runs deduplication and consolidation as background tasks.

Fields

config: AutoPilotConfig

Implementations

impl AutoPilotEngine

pub fn new(config: AutoPilotConfig) -> Self

pub async fn run_dedup(&self, storage: &Arc<dyn VectorStorage>) -> DedupResult

Run deduplication across all agent namespaces.

For each _dakera_agent_* namespace, compares all memory pairs using cosine similarity on their stored embeddings. When a pair exceeds the threshold, the memory with the lower retention score is deleted.

pub async fn run_consolidation( &self, storage: &Arc<dyn VectorStorage>, ) -> ConsolidationResult

Run consolidation across all agent namespaces.

Finds clusters of 3+ memories sharing 2+ tags where ALL members have importance < 0.3, then merges each cluster into a single Semantic memory with combined content, union of tags, and max importance.

pub fn spawn( config: Arc<RwLock<AutoPilotConfig>>, storage: Arc<dyn VectorStorage>, metrics: Arc<BackgroundMetrics>, ) -> (JoinHandle<()>, JoinHandle<()>)

Spawn the auto-pilot as two background tokio tasks (dedup + consolidation).

Takes a shared Arc<RwLock<AutoPilotConfig>> so that config changes made at runtime via the PILOT-2 endpoint (PUT /admin/autopilot/config) take effect without a server restart. Each loop iteration re-reads the config before sleeping, so interval and threshold changes apply on the next cycle.