Struct CloudEvent 

pub struct CloudEvent {
    pub specversion: String,
    pub id: String,
    pub source: String,
    pub event_type: String,
    pub datacontenttype: Option<String>,
    pub dataschema: Option<String>,
    pub subject: Option<String>,
    pub time: Option<String>,
    pub data: Option<Value>,
    pub extensions: HashMap<String, Value>,
}

CloudEvents v1.0 envelope

Required attributes: specversion, id, source, type. Optional attributes: datacontenttype, dataschema, subject, time. Extension attributes stored in extensions.

Fields

specversion: String

CloudEvents spec version (always “1.0”)

id: String

Event identifier (maps to Event.id)

source: String

Event source (maps to Event.source)

event_type: String

Event type (maps to Event.event_type, or “a3s.event” for untyped)

datacontenttype: Option<String>

Data content type

dataschema: Option<String>

Data schema URI

subject: Option<String>

Event subject (maps to Event.subject)

time: Option<String>

Timestamp in RFC 3339 format

data: Option<Value>

Event payload

extensions: HashMap<String, Value>

Extension attributes (includes a3s-prefixed fields)

Implementations

impl CloudEvent

pub fn new( id: impl Into<String>, source: impl Into<String>, event_type: impl Into<String>, ) -> Self

Create a new CloudEvent with required attributes

pub fn with_data(self, data: Value) -> Self

Set the data payload

pub fn with_subject(self, subject: impl Into<String>) -> Self

Set the subject

pub fn with_time(self, time: impl Into<String>) -> Self

Set the time

pub fn with_extension( self, key: impl Into<String>, value: impl Into<Value>, ) -> Self

Add an extension attribute

Trait Implementations

impl Clone for CloudEvent

fn clone(&self) -> CloudEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CloudEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CloudEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<Event> for CloudEvent

Convert an A3S Event to a CloudEvent (lossless)

A3S-specific fields are stored as extension attributes:

• a3scategory — Event.category
• a3sversion — Event.version
• a3ssummary — Event.summary
• a3stimestamp — Event.timestamp (Unix ms)
• a3smeta_<key> — each metadata entry

fn from(event: Event) -> Self

Converts to this type from the input type.

impl PartialEq for CloudEvent

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for CloudEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<CloudEvent> for Event

Convert a CloudEvent back to an A3S Event

Extracts A3S-specific fields from extension attributes. Fails if required A3S extensions are missing.

type Error = EventError

The type returned in the event of a conversion error.

fn try_from(ce: CloudEvent) -> Result<Self>

Performs the conversion.

impl StructuralPartialEq for CloudEvent