Struct SessionSink 

pub struct SessionSink { /* private fields */ }

A write sink for session persistence. None means persistence is disabled; callers treat it as an append-only log.

Implementations

impl SessionSink

pub fn new(store: Arc<Store>, session_id: i64, ulid: String) -> Self

pub fn adapter(&self) -> SessionAdapter

Clone the shared handle so a SessionAdapter sees the same active ulid/row-id whenever /fork swaps it.

pub fn record(&self, entry: &LogEntry)

Record one log entry. Errors are logged but do not propagate — a DB hiccup must not deny the operator a visible render.

pub fn end(&self)

Close the originally-opened session row. Called during shutdown. Forks open their own rows but do not close on exit — a child session whose parent is still marked live is the honest representation of a crash-exit.

pub fn store(&self) -> &Store

The store this sink writes to. Exposed so a post-run caller (daily-wrap generator, milestone writer) can reach the same DB handle the sink has been using without the caller having to carry a separate Arc.

Returned as a shared reference — the caller must not mutate the Arc; the write path remains the sink itself.

pub fn session_id(&self) -> Option<i64>

Snapshot of the originally-opened row’s id. Returns None if the session was forked away and never forked back — today end() is still keyed on this same id, so None is only reachable via a /fork without a return, which the fork command never performs in M1.

pub fn ulid(&self) -> Option<String>

Snapshot of the current active ULID. Same caveat as Self::session_id.

Trait Implementations

impl Clone for SessionSink

fn clone(&self) -> SessionSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SessionSink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.