Struct SessionStoreSink 

pub struct SessionStoreSink { /* private fields */ }

Authoritative event sink for one canonical session store.

Events are accepted in order through one bounded, non-blocking queue owned by a blocking drain actor. The queue is bounded both by event count and by an estimated serialized payload budget, so a burst of large tool outputs cannot retain unbounded memory. If the queue or store fails, the sink fails closed and Self::close reports the loss. Call Self::close exactly once after the terminal event and propagate its error before reporting a successful run.

Implementations

impl SessionStoreSink

pub fn matrix_persistence(&self) -> MatrixPersistence

Ordered, acknowledged matrix writes and replay through this session drain.

pub fn decision_validator(&self) -> DecisionEvidenceValidator

Validate task-owned evidence after all previously accepted events.

pub async fn open(workspace: &Path, session_id: &str) -> Result<Self>

Open the canonical session store and start its bounded drain.

pub fn emit(&self, event: &ThreadEvent) -> Result<()>

Enqueue one event for canonical persistence.

pub fn event_sink(&self) -> EventSink

Return the callback form used by the core event recorder.

pub async fn explanation( &self, scope: ExplanationScope, ) -> Result<ExplanationModel>

Ordered query barrier; accepted events precede this retained snapshot.

pub async fn explanation_page( &self, scope: ExplanationScope, offset: usize, ) -> Result<ExplanationPage>

Return only a bounded page from the ordered cached projection.

pub async fn evidence( &self, reference: EvidenceRef, offset: usize, ) -> Result<EvidencePage>

Resolve a bounded evidence page through the same ordered barrier.

pub async fn close(&self) -> Result<()>

Drain and close the canonical persistence task.

Trait Implementations

impl Drop for SessionStoreSink

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.