Enum actyxos_sdk::event_service::Order

pub enum Order {
    Lamport,
    LamportReverse,
    SourceOrdered,
}

The order in which you want to receive events for a query

Event streams can be request with different ordering requirements from the Event Service:

• in strict forward Lamport order
• in strict backwards Lamport order (only possible when requesting with an upper bound OffsetMap)
• ordered in forward order per source (ActyxOS node), but not between sources

Variants

Lamport

Events are sorted by ascending Lamport timestamp and source ID, which defines a total order. If the subscription does not restrict the set of source IDs then a new source appearing with old events will lead to these old events only being delivered if they are younger than the youngest already delivered event.

Requesting this order will stall the stream’s delivery while one of the contained sources stops sending events (for example when it goes offline or is destroyed).

LamportReverse

Events are sorted by descending Lamport timestamp and descending source ID, which is the exact reverse of the Lamport ordering. Requests with this ordering will only be successful if they include an upper bound OffsetMap and if that map is less than or equal to the OffsetMap obtained with the get_offsets method.

SourceOrdered

Events are sorted within each stream by ascending Lamport timestamp, with streams from different sources interleaved in an undefined order.

This is the preferred ordering for live streams as it permits new information to be made available as soon as it is delivered to the ActyxOS node, without needing to wait for all other sources to confirm the ordering first.

Trait Implementations

impl Clone for Order

fn clone(&self) -> Order

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Order

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Order

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

Deserialize this value from the given Serde deserializer.

impl PartialEq<Order> for Order

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

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

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

This method tests for !=.

impl Serialize for Order

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

Serialize this value into the given Serde serializer.

impl Eq for Order

impl StructuralEq for Order

impl StructuralPartialEq for Order