Struct DistillerEngine 

pub struct DistillerEngine { /* private fields */ }

Implementations

impl DistillerEngine

pub fn new( profile: DistillerProfile, config: DistillerConfig, handle: Arc<dyn DistillerClientHandle>, provider: Arc<dyn AgentMemoryProvider>, tombstones: Arc<dyn TombstoneSource>, transcripts: Arc<dyn TranscriptSource>, compaction: Option<Arc<dyn CompactionDiscardSource>>, tracker: Option<SessionTaintTracker>, realm: impl Into<String>, ) -> Self

pub fn set_event_sink(&self, sink: Arc<dyn MemoryEventSink>)

Wire the §9.3 timeline sink (skipped pre-rotation distillations, budget denials). Also threads it into the engine’s budget guard.

pub fn pre_rotation_timeout(&self) -> Duration

pub fn set_compaction_follow_up(&self, hook: CompactionFollowUp)

Wire the §8.6 post-compaction follow-up (the Hygienist). Invoked after every compaction-cause distillation attempt with its outcome.

pub fn set_compaction_observed(&self, hook: CompactionObserved)

Wire the synchronous compaction-observation hook (see CompactionObserved).

pub fn distilled_cursor(&self, identity: &str, session_key: &str) -> u64

Transcript index up to which interaction/rotation distillation has run for (identity, session_key) (§8.4 window cursor). 0 when the window was never distilled. Read-only: never creates window state.

pub fn note_session_generation( &self, identity: &str, session_key: &str, generation: u64, )

Session-context hint from the identity runtime (delivery and lifecycle paths): binds the continuity generation the session’s EvidenceRefs carry. Sessions only ever observed (never delivered to through the runtime) keep generation 0 — documented coarseness, resolved when an upstream generation fact exists on the stream.

pub async fn distill_now( self: &Arc<Self>, identity: &str, session_key: &str, cause: DistillCause, ) -> DistillOutcome

One extraction run over the window [cursor, end) of session_key’s transcript (or the compaction-discard harvest for DistillCause::Compaction). Budget-gated, mutually exclusive with Recorder writes, evidence-taint-aware through the store’s write gate.

pub async fn distill_before_rotation( self: &Arc<Self>, identity: &str, session_key: &str, cause: DistillCause, )

Pre-rotation hook body (respawn/retire/delete): bounded, best-effort — rotation proceeds on timeout with a loud skip.

pub async fn drop_orphaned_session_scope( self: &Arc<Self>, session_key: &str, cause: DistillCause, )

Ask 2 GC: reclaim a permanently-orphaned session’s semantic-memory rows after its knowledge has been distilled. Best-effort and bounded — a rotation must never fail on cleanup. Caller MUST have already run distill_before_rotation for this session and MUST only invoke this for causes that permanently abandon the session id (respawn/reset mint a fresh id; delete discards it) — never for resumable retires.

pub fn spawn_detached( self: &Arc<Self>, identity: &str, session_key: &str, cause: DistillCause, )

Detached distillation (reset / resume-fallback / compaction): never on any critical path. The session store outlives the session, so the read stays valid after teardown.

Trait Implementations

impl DistillationGate for DistillerEngine

fn distilled_through(&self, identity: &str, session_key: &str) -> u64

Transcript index up to which distillation has covered (identity, session_key).