Struct ObservationIngressEnvelope 

pub struct ObservationIngressEnvelope {
    pub node_id: NodeId,
    pub cursor: NodeCursor,
    pub received_at_ms: u64,
    pub transport: ObservationTransport,
    pub payload: ObservationIngressPayload,
}

Fields

node_id: NodeId

cursor: NodeCursor

received_at_ms: u64

transport: ObservationTransport

payload: ObservationIngressPayload

Implementations

impl ObservationIngressEnvelope

pub fn validate(&self) -> Result<(), ObservationApiError>

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

Equality of the Node-authoritative ingress fact.

Transport and local receive time are delivery metadata. They may differ when the same exact Node cursor is observed directly and through C2.

Trait Implementations

impl Clone for ObservationIngressEnvelope

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 ObservationIngressEnvelope

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ObservationIngressEnvelope

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ObservationIngressEnvelope

impl PartialEq for ObservationIngressEnvelope

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ObservationIngressEnvelope

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 ObservationIngressEnvelope