Enum ObservationIngressPayload 

pub enum ObservationIngressPayload {
    Observations {
        address: ObservationTarget,
        observations: Vec<ObservationV1>,
    },
    ManagedRecordUpserted {
        link: ManagedRecordLink,
    },
    ManagedRecordRemoved {
        key: ManagedSessionKey,
    },
    ResyncRequired {
        oldest: NodeCursor,
    },
    CursorOnly,
}

Variants

Observations

The observations one node event projected to, applied atomically at the event’s cursor. An observation addressed to a runtime session also reaches every managed record currently linked to it.

Fields

address: ObservationTarget

observations: Vec<ObservationV1>

ManagedRecordUpserted

Fields

link: ManagedRecordLink

ManagedRecordRemoved

Fields

key: ManagedSessionKey

ResyncRequired

Fields

oldest: NodeCursor

CursorOnly

Implementations

impl ObservationIngressPayload

pub fn validate_route( &self, node_id: &NodeId, cursor: NodeCursor, ) -> Result<(), ObservationApiError>

Trait Implementations

impl Clone for ObservationIngressPayload

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObservationIngressPayload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ObservationIngressPayload

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ObservationIngressPayload

impl PartialEq for ObservationIngressPayload

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ObservationIngressPayload

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ObservationIngressPayload