Struct libocc::Projector

pub struct Projector<T> where
    T: Clone + PartialEq,  { /* fields omitted */ }

Projects events from an event log

Manages several segments internally

Implementations

impl<T> Projector<T> where
    T: Clone + PartialEq, 

pub fn new() -> Projector<T>

Generates a new projector for a given type

pub fn get_projection(&self) -> &Vec<T>

Returns the current (cached) projection as a shared reference

pub fn project_at(&self, timestamp: &Timestamp) -> Option<Vec<T>>

Performs a projection using a copy of the previous segments’ snapshot if available

pub fn push(&mut self, event: Event<T>) -> Result<()>

Pushes an event onto the latest segment, updating the projection

pub fn make_snapshot(&mut self)

Makes a new snapshot of the projector by creating a new segment

pub fn merge_at(&mut self, timestamp: &Timestamp) -> Result<()>

Attempts to merge two segments/snapshots.
The one including the timestamp and the one before it (if any)

Trait Implementations

impl<T: Clone> Clone for Projector<T> where
    T: Clone + PartialEq, 

fn clone(&self) -> Projector<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Projector<T> where
    T: Clone + PartialEq, 

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for Projector<T> where
    T: Clone + PartialEq,
    T: Deserialize<'de>, 

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for Projector<T> where
    T: Clone + PartialEq,
    T: Serialize, 

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.