Struct KernelEventWriter 

pub struct KernelEventWriter { /* private fields */ }

Owns the channel sender, shared DB handle, and the background drain task handle.

Drop shuts down the drain loop (sender closed → task exits after flushing).

Implementations

impl KernelEventWriter

pub fn try_open_default() -> Option<KernelEventWriter>

Open the default ~/.zagens/sessions/sessions.db and start draining. Returns None when the sessions directory cannot be resolved (e.g. headless CI without home dir) — double-write is silently disabled.

pub fn try_open(db_path: &Path) -> Result<KernelEventWriter, Error>

Open (or create) db_path and start the drain task.

pub fn load_turn_events_sync( &self, turn_id: &str, ) -> Result<Vec<KernelEvent>, Error>

Load all persisted events for turn_id (blocking read on the shared DB).

pub fn verify_persisted_turn_matches( &self, turn_id: &str, in_memory: &[KernelEvent], ) -> Option<String>

Compare in-memory turn events with the SQLite log (Phase 3b replay gate).

pub fn sink(&self) -> UnboundedSender<KernelEvent>

pub fn tx(&self) -> &UnboundedSender<KernelEvent>

Borrow the live sender (for TurnLoopHost::kernel_event_sink).