pub struct KernelEventWriter { /* private fields */ }Expand description
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§
Source§impl KernelEventWriter
impl KernelEventWriter
Sourcepub fn try_open_default() -> Option<Self>
pub fn try_open_default() -> Option<Self>
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.
Sourcepub fn try_open(db_path: &Path) -> Result<Self>
pub fn try_open(db_path: &Path) -> Result<Self>
Open (or create) db_path and start the drain task.
Sourcepub fn load_turn_events_sync(&self, turn_id: &str) -> Result<Vec<KernelEvent>>
pub fn load_turn_events_sync(&self, turn_id: &str) -> Result<Vec<KernelEvent>>
Load all persisted events for turn_id (blocking read on the shared DB).
Sourcepub fn verify_persisted_turn_matches(
&self,
turn_id: &str,
in_memory: &[KernelEvent],
) -> Option<String>
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) -> KernelEventSink
Sourcepub fn tx(&self) -> &KernelEventSink
pub fn tx(&self) -> &KernelEventSink
Borrow the live sender (for TurnLoopHost::kernel_event_sink).
Auto Trait Implementations§
impl Freeze for KernelEventWriter
impl RefUnwindSafe for KernelEventWriter
impl Send for KernelEventWriter
impl Sync for KernelEventWriter
impl Unpin for KernelEventWriter
impl UnsafeUnpin for KernelEventWriter
impl UnwindSafe for KernelEventWriter
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more