Struct MemoryProjection 

pub struct MemoryProjection { /* private fields */ }

Implementations

impl MemoryProjection

pub fn try_from_parts( nodes: Vec<MemoryNode>, facts: Vec<MemoryFact>, known_at: Timestamp, source_position: Option<u64>, ) -> Result<Self>

Builds a current projection from already extracted nodes and facts.

This bypasses event-envelope replay but retains domain, endpoint, uniqueness, evidence, and supersession validation. All nodes are treated as revisions recorded at known_at. Large fact sets are prepared in parallel using scoped standard-library threads.

Errors

Rejects duplicate identifiers, invalid nodes or facts, missing endpoints, facts recorded after known_at, and invalid supersession chains.

impl MemoryProjection

pub const fn last_global_position(&self) -> Option<u64>

pub fn superseded_by(&self, fact: &FactId) -> Option<&FactId>

pub fn view(&self, clock: ProjectionClock) -> MemoryView

pub fn view_ref(&self, clock: ProjectionClock) -> MemoryViewRef<'_>

Borrows a temporal view without cloning node, fact, or evidence payloads.

This is the preferred boundary for lexical and vector index providers that only need to read the current evidence projection.

Trait Implementations

impl Clone for MemoryProjection

fn clone(&self) -> MemoryProjection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryProjection

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

Formats the value using the given formatter.

impl Default for MemoryProjection

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MemoryProjection

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for MemoryProjection

impl PartialEq for MemoryProjection

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

Equality operator ==.

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

Inequality operator !=.

impl Projection<MemoryEvent> for MemoryProjection

fn prepare_replay(&mut self, events: &[StoredEvent<MemoryEvent>])

Reserves projection-specific capacity before a known replay batch.

fn apply(&mut self, event: &StoredEvent<MemoryEvent>) -> Result<()>

Applies one validated stored event.

fn apply_owned(&mut self, event: StoredEvent<MemoryEvent>) -> Result<()>

Applies one owned event. The default preserves the borrowed contract; projections may override it to move large payloads without cloning.

impl Serialize for MemoryProjection

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.