Skip to navigation

Generated from cargo doc --no-deps -p nemo-relay-builtins -p nemo-relay-diagnostics -p nemo-relay-logging -p nemo-relay-plugin-host -p nemo-relay-codecs -p nemo-relay -p nemo-relay-runtime -p nemo-relay-model-pricing -p nemo-relay-resource-metrics -p nemo-relay-observability -p nemo-relay-adaptive -p nemo-relay-pii-redaction -p nemo-relay-ffi -p nemo-relay-types -p nemo-relay-plugin -p nemo-relay-worker-proto -p nemo-relay-worker.

pub struct BaseEvent {
    pub atof_version: String,
    pub parent_uuid: Option<String>,
    pub propagation_root_uuid: Option<String>,
    pub propagation_parent_uuid: Option<String>,
    pub propagation_traceparent: Option<String>,
    pub propagation_tracestate: Option<String>,
    pub uuid: String,
    pub time: Option<Timestamp>,
    pub name: String,
    pub data: Option<JsonValue>,
    pub data_schema: Option<DataSchema>,
    pub metadata: Option<JsonValue>,
}

Common ATOF identity, propagation, timing, and application payload fields.

Fields

atof_version: String

ATOF’s own version, independent of the transport contract.

parent_uuid: Option<String>

UUID of the parent scope, if any.

propagation_root_uuid: Option<String>

Stable causal root imported or resolved when the event was emitted.

propagation_parent_uuid: Option<String>

Parent imported through propagation context. The runtime uses this field to distinguish imported parents from Relay-created parents. It does not change the ATOF wire format.

propagation_traceparent: Option<String>

W3C traceparent imported or derived from the local parent. Runtime-only.

propagation_tracestate: Option<String>

W3C tracestate imported or inherited from the local parent. Runtime-only.

uuid: String

Unique identifier for the event or span.

time: Option<Timestamp>

Event timestamp in UTC.

name: String

Human-readable event name.

data: Option<JsonValue>

Application-defined payload.

data_schema: Option<DataSchema>

Optional schema identifier for data.

metadata: Option<JsonValue>

Optional tracing/correlation metadata.

Implementations

impl BaseEvent

impl BaseEvent

parent_uuid

pub fn parent_uuid(&self) -> &str

Returns the value of parent_uuid, or the default value if parent_uuid is unset.

propagation_root_uuid

pub fn propagation_root_uuid(&self) -> &str

Returns the value of propagation_root_uuid, or the default value if propagation_root_uuid is unset.

propagation_parent_uuid

pub fn propagation_parent_uuid(&self) -> &str

Returns the value of propagation_parent_uuid, or the default value if propagation_parent_uuid is unset.

propagation_traceparent

pub fn propagation_traceparent(&self) -> &str

Returns the value of propagation_traceparent, or the default value if propagation_traceparent is unset.

propagation_tracestate

pub fn propagation_tracestate(&self) -> &str

Returns the value of propagation_tracestate, or the default value if propagation_tracestate is unset.

Trait Implementations

impl Clone for BaseEvent

impl Clone for BaseEvent

clone

fn clone(&self) -> BaseEvent

clone_from

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

impl Debug for BaseEvent

impl Debug for BaseEvent

fmt

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

impl Default for BaseEvent

impl Default for BaseEvent

default

fn default() -> Self

impl Hash for BaseEvent

impl Hash for BaseEvent

hash

fn hash<__H: Hasher>(&self, state: &mut __H)

hash_slice

fn hash_slice<H>(data: &[Self], state: &mut H)where
    H: Hasher,
    Self: Sized,

impl Message for BaseEvent

impl Message for BaseEvent

encoded_len

fn encoded_len(&self) -> usize

clear

fn clear(&mut self)

encode

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
    Self: Sized,

encode_to_vec

fn encode_to_vec(&self) -> Vec<u8> where
    Self: Sized,

encode_length_delimited

fn encode_length_delimited(
    &self,
    buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
    Self: Sized,

encode_length_delimited_to_vec

fn encode_length_delimited_to_vec(&self) -> Vec<u8> where
    Self: Sized,

decode

fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
    Self: Default,

decode_length_delimited

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
    Self: Default,

merge

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
    Self: Sized,

merge_length_delimited

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
    Self: Sized,

impl Name for BaseEvent

impl Name for BaseEvent

NAME

const NAME: &'static str = "BaseEvent"

PACKAGE

const PACKAGE: &'static str = "nvidia.nemo.relay.worker.v1"

full_name

fn full_name() -> String

type_url

fn type_url() -> String

impl PartialEq for BaseEvent

impl PartialEq for BaseEvent

eq

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

ne

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

impl WireValue<BaseEvent> for BaseEvent

impl WireValue<BaseEvent> for BaseEvent

to_wire

fn to_wire(self) -> Result<BaseEvent>

from_wire

fn from_wire(value: BaseEvent) -> Result<Self>

impl Eq for BaseEvent

impl Eq for BaseEvent

impl StructuralPartialEq for BaseEvent

impl StructuralPartialEq for BaseEvent