Struct PromotionEngine 

pub struct PromotionEngine { /* private fields */ }

Background engine that scans episodic memory and promotes recurring patterns to skills.

Runs off the hot path, typically queued to a JoinSet at turn boundary.

Examples

use std::path::PathBuf;
use std::sync::Arc;
use zeph_memory::compression::promotion::{PromotionEngine, PromotionConfig};

let engine = PromotionEngine::new(
    Arc::new(MockWriter),
    PromotionConfig::default(),
    PathBuf::from("/tmp/skills"),
);

Implementations

impl PromotionEngine

pub fn new( writer: Arc<dyn SkillWriter>, config: PromotionConfig, output_dir: PathBuf, ) -> Self

Create a new promotion engine.

writer is injected from zeph-core and encapsulates SkillGenerator + optional SkillEvaluator. output_dir is where SKILL.md directories are created.

pub async fn scan( &self, window: &[PromotionInput], ) -> Result<Vec<PromotionCandidate>, MemoryError>

Scan a recent-episodic window and return clusters that qualify for promotion.

Clustering is greedy: each message is assigned to the first cluster whose centroid has cosine similarity ≥ config.cluster_threshold; if no cluster matches, a new cluster is created. A cluster qualifies when both min_occurrences and min_sessions are satisfied.

Messages without embeddings (embedding == None) are silently skipped.

Panics

Does not panic in practice — the unwrap on embedding is guarded by the filter(|p| p.embedding.is_some()) step immediately above.

Errors

Returns MemoryError::Promotion if embeddings have inconsistent dimensions.

pub async fn promote( &self, candidate: &PromotionCandidate, ) -> Result<(), MemoryError>

Generate and persist a SKILL.md for candidate. Idempotent by signature.

On evaluator rejection the method returns Ok(()) — rejection is a normal outcome.

Errors

Returns MemoryError::Promotion on generation, evaluator, or disk-write failure.