Enum akka_persistence_rs::Offset
source · pub enum Offset {
Sequence(u64),
Timestamp(TimestampOffset),
}
Variants§
Sequence(u64)
Corresponds to an ordered sequence number for the events. Note that the corresponding offset of each event is provided in an Envelope, which makes it possible to resume the stream at a later point from a given offset.
The offset
is exclusive, i.e. the event with the exact same sequence number will not be included
in the returned stream. This means that you can use the offset that is returned in an Envelope
as the offset
parameter in a subsequent query.
Timestamp(TimestampOffset)
Timestamp based offset. Since there can be several events for the same timestamp it keeps track of what sequence numbers for every persistence id that have been seen at this specific timestamp.
The offset
is exclusive, i.e. the event with the exact same sequence number will not be included
in the returned stream. This means that you can use the offset that is returned in EventEnvelope
as the offset
parameter in a subsequent query.
Trait Implementations§
source§impl<'de> Deserialize<'de> for Offset
impl<'de> Deserialize<'de> for Offset
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,
source§impl PartialEq for Offset
impl PartialEq for Offset
source§impl PartialOrd for Offset
impl PartialOrd for Offset
1.0.0 · source§fn le(&self, other: &Rhs) -> bool
fn le(&self, other: &Rhs) -> bool
self
and other
) and is used by the <=
operator. Read more