Struct actyx_sdk::OffsetMap

pub struct OffsetMap(_);

Multi-dimensional cursor for event streams: an OffsetMap describes the set of events given by the event streams of each included source up to the associated Offset.

All stream delivery modes supported by the Event Service respect the order of offsets of the events published by each single Actyx node. This order is consistent with the Lamport timestamp order because both numbers are assigned to published events in strictly monotonically increasing fashion, i.e. greater offset implies greater Lamport timestamp and vice versa.

Note that if the OffsetMap contains offset 42 for StreamId "abc.0" it denotes that events with offsets 0 through 42 (inclusive) are included within the OffsetMap.

A common usage pattern is to store the OffsetMap describing the events already consumed from an event stream together with the computation results from processing those events (preferably within the same database transaction, if applicable). When restarting the process, this OffsetMap can be read and the stream can be resumed from where the process left off previously.

Arithmetics

OffsetMap has a partial order: when the set of events described by one is a strict subset of the set of events described by another, then one is said to be smaller than the other. It may be that one OffsetMap contains events that the other does not and vice versa, in which case they are incomparable (partial_cmp will return None).

An event may be added into an OffsetMap to denote that from the event’s stream all events up to this one shall be included in the OffsetMap.

The difference of two offset maps yields the number of events contained within the first but not within the second one (i.e. it counts the size of the difference set).

Deserialization

An OffsetMap only contains valid offsets (non-negative numbers), but during deserialization negative values are tolerated and ignored. This is to keep compatibility with previously documented API endpoints.

Implementations

impl OffsetMap

pub fn empty() -> Self

The empty OffsetMap is equivalent to the beginning of time, it does not contain any event.

pub fn is_empty(&self) -> bool

Returns true if this OffsetMap does not contain any events

pub fn contains<T>(&self, event: &Event<T>) -> bool

Check whether the given Event’s offset and source ID are contained within this OffsetMap.

pub fn contains_stream(&self, stream: &StreamId) -> bool

Check whether the given stream contributes to the set of events in this OffsetMap

pub fn offset(&self, stream: impl Into<StreamId>) -> OffsetOrMin

Retrieve the offset stored for the given source

The returned value is OffsetOrMin::MIN if nothing is stored for the given source.

pub fn get(&self, stream: impl Into<StreamId>) -> Option<Offset>

Retrieves the offset stored for the given source

pub fn size(&self) -> u64

Counts the number of offsets spanned by this OffsetMap.

pub fn union_with(&mut self, other: &OffsetMap)

Merge the other OffsetMap into this one, taking the union of their event sets.

pub fn union(&self, other: &OffsetMap) -> OffsetMap

Compute the union of two sets of events described by OffsetMaps

pub fn intersection_with(&mut self, other: &OffsetMap)

Compute the intersection of two sets of events described by OffsetMaps

pub fn intersection(&self, other: &OffsetMap) -> OffsetMap

Compute the intersection of two sets of events described by OffsetMaps

pub fn into_inner(self) -> BTreeMap<StreamId, Offset>

pub fn streams(&self) -> impl Iterator<Item = StreamId> + '_

An iterator over all streams that contribute events to this OffsetMap

pub fn stream_iter(&self) -> impl Iterator<Item = (StreamId, Offset)> + '_

An iterator over all streams that contribute events to this OffsetMap including their offset

pub fn update(
    &mut self,
    stream: impl Into<StreamId>,
    offset: Offset
) -> Option<OffsetOrMin>

Update entry for source if the given offset is larger than the stored one and return the previous offset for this source

Trait Implementations

impl<T> AddAssign<&'_ Event<T>> for OffsetMap

fn add_assign(&mut self, other: &Event<T>)

Performs the += operation.

impl AddAssign<&'_ EventKey> for OffsetMap

fn add_assign(&mut self, other: &EventKey)

Performs the += operation.

impl AsRef<BTreeMap<StreamId, Offset>> for OffsetMap

fn as_ref(&self) -> &BTreeMap<StreamId, Offset>

Performs the conversion.

impl BitAnd<&'_ OffsetMap> for &OffsetMap

type Output = OffsetMap

The resulting type after applying the & operator.

fn bitand(self, rhs: Self) -> Self::Output

Performs the & operation.

impl BitAnd<OffsetMap> for OffsetMap

type Output = OffsetMap

The resulting type after applying the & operator.

fn bitand(self, rhs: Self) -> Self::Output

Performs the & operation.

impl BitAndAssign<OffsetMap> for OffsetMap

fn bitand_assign(&mut self, rhs: Self)

Performs the &= operation.

impl BitOr<&'_ OffsetMap> for &OffsetMap

type Output = OffsetMap

The resulting type after applying the | operator.

fn bitor(self, rhs: Self) -> Self::Output

Performs the | operation.

impl BitOr<OffsetMap> for OffsetMap

type Output = OffsetMap

The resulting type after applying the | operator.

fn bitor(self, rhs: Self) -> Self::Output

Performs the | operation.

impl BitOrAssign<OffsetMap> for OffsetMap

fn bitor_assign(&mut self, rhs: Self)

Performs the |= operation.

impl Clone for OffsetMap

fn clone(&self) -> OffsetMap

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for OffsetMap

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

Formats the value using the given formatter.

impl Decode<DagCborCodec> for OffsetMap

fn decode<R: Read + Seek>(c: DagCborCodec, r: &mut R) -> Result<Self>

Decode from an impl Read.

impl Default for OffsetMap

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for OffsetMap

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

Deserialize this value from the given Serde deserializer.

impl Encode<DagCborCodec> for OffsetMap

fn encode<W: Write>(&self, c: DagCborCodec, w: &mut W) -> Result<()>

Encodes into a impl Write.

impl From<BTreeMap<StreamId, Offset>> for OffsetMap

fn from(map: BTreeMap<StreamId, Offset>) -> Self

Performs the conversion.

impl From<BTreeMap<StreamId, OffsetOrMin>> for OffsetMap

fn from(map: BTreeMap<StreamId, OffsetOrMin>) -> Self

Performs the conversion.

impl FromIterator<(StreamId, Offset)> for OffsetMap

fn from_iter<T: IntoIterator<Item = (StreamId, Offset)>>(iter: T) -> Self

Creates a value from an iterator.

impl PartialEq<OffsetMap> for OffsetMap

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl PartialOrd<OffsetMap> for OffsetMap

fn partial_cmp(&self, rhs: &Self) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

This method tests less than (for self and other) and is used by the < operator.

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

This method tests less than or equal to (for self and other) and is used by the <= operator.

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

This method tests greater than (for self and other) and is used by the > operator.

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

This method tests greater than or equal to (for self and other) and is used by the >= operator.

impl Serialize for OffsetMap

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

Serialize this value into the given Serde serializer.

impl Sub<&'_ OffsetMap> for &OffsetMap

type Output = u64

The resulting type after applying the - operator.

fn sub(self, other: &OffsetMap) -> u64

Performs the - operation.

impl Sub<OffsetMap> for OffsetMap

type Output = u64

The resulting type after applying the - operator.

fn sub(self, other: Self) -> u64

Performs the - operation.

impl<T> SubAssign<&'_ Event<T>> for OffsetMap

fn sub_assign(&mut self, other: &Event<T>)

Ensure that the given event is no longer contained within this OffsetMap.

impl SubAssign<&'_ EventKey> for OffsetMap

fn sub_assign(&mut self, other: &EventKey)

Ensure that the given event is no longer contained within this OffsetMap.

impl Eq for OffsetMap

impl StructuralEq for OffsetMap

impl StructuralPartialEq for OffsetMap