Struct ObservationEngine 

pub struct ObservationEngine { /* private fields */ }

Implementations

impl ObservationEngine

pub fn new() -> Self

pub fn projection( &self, target: &ObservationTarget, ) -> Option<&SessionProjection>

pub fn projection_count(&self) -> usize

pub fn projections( &self, ) -> impl Iterator<Item = (&ObservationTarget, &SessionProjection)>

pub fn managed_runtime( &self, key: &ManagedSessionKey, ) -> Option<&RuntimeSessionKey>

pub fn durable_resume_cursors(&self) -> Vec<(NodeId, NodeCursor)>

pub fn checkpoint(&self) -> ObservationEngineCheckpointV1

pub fn restore( checkpoint: ObservationEngineCheckpointV1, ) -> Result<Self, ObservationEngineError>

pub fn prepare( &self, envelope: ObservationIngressEnvelope, ) -> Result<PreparedBatch, ObservationEngineError>

pub fn prepare_batch( &self, envelopes: &[ObservationIngressEnvelope], ) -> Result<PreparedBatch, ObservationEngineError>

pub fn prepare_resync( &self, batch: &ObservationResyncBatch, ) -> Result<PreparedBatch, ObservationEngineError>

pub fn prepare_record_inventory( &self, node_id: &NodeId, incarnation_id: NodeIncarnationId, records: &[ManagedRecordLink], complete: bool, ) -> Result<PreparedBatch, ObservationEngineError>

Atomically applies a bounded inventory of managed records for one exact Node incarnation.

Inventory is record/link state, not transport recovery evidence. This operation deliberately never clears or creates an observation transport gap.

pub fn accept(&mut self, prepared: PreparedBatch)

Commits an already validated and fully reduced state without failure.

Trait Implementations

impl Clone for ObservationEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObservationEngine

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

Formats the value using the given formatter.

impl Default for ObservationEngine

fn default() -> Self

Returns the “default value” for a type.

impl Eq for ObservationEngine

impl PartialEq for ObservationEngine

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ObservationEngine