Struct EventStoreSession 

pub struct EventStoreSession { /* private fields */ }

Live event-store session owned by the kernel between start() and finalize_stop().

Implementations

impl EventStoreSession

pub const fn manifest(&self) -> &RunManifest

Returns the captured manifest as it was written to disk at run start.

The high-watermark and end_ts_init advance after seal; the snapshot here is frozen at boot time.

pub fn run_id(&self) -> &str

Returns the run id of the currently open run.

pub fn parent_run_id(&self) -> Option<&str>

Returns the parent run id for the current run.

pub fn is_halted(&self) -> bool

Returns whether the writer has fail-stopped.

pub fn high_watermark(&self) -> u64

Returns the writer’s current durable high-watermark.

Returns 0 when the writer has been consumed by a prior close.

pub fn snapshot_anchorer(&self) -> Option<SnapshotAnchorer>

Returns a snapshot anchorer bound to the open writer.

The execution engine installs this callback while the run is open. The callback records the cache-owned snapshot reference against the writer’s durable high-watermark after flushing earlier captured entries.

pub fn adapter(&self) -> Option<&Arc<BusCaptureAdapter>>

Returns the live bus capture adapter, when one was wired into this run.

None after Self::close consumes the writer.

pub fn close(&mut self, ts_init: UnixNanos) -> Result<(), EventStoreError>

Submits the terminal RunEnded entry, drains pending entries, and seals the manifest as RunStatus::Ended.

Consumes the inner writer; subsequent calls return without effect.

Errors

Returns EventStoreError if the writer fails to commit the final batch, the seal step fails, or the writer Arc has outstanding clones (the bus tap must be cleared before close to release the adapter’s writer reference).

Trait Implementations

impl Debug for EventStoreSession

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

Formats the value using the given formatter.

impl Drop for EventStoreSession

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.