Struct cloudevents::Event

pub struct Event {
    pub attributes: Attributes,
    pub data: Option<Data>,
}

Data structure that represents a CloudEvent. It provides methods to get the attributes through AttributesReader and write them through AttributesWriter. It also provides methods to read and write the event data

use cloudevents::Event;
use cloudevents::event::AttributesReader;

// Create an event using the Default trait
let mut e = Event::default();
e.write_data(
    "application/json",
    None,
    serde_json::json!({"hello": "world"})
);

// Print the event id
println!("Event id: {}", e.get_id());

// Get the event data
let data: serde_json::Value = e.try_get_data().unwrap().unwrap();
println!("Event data: {}", data)

Fields

attributes: Attributes

data: Option<Data>

Methods

impl Event

pub fn remove_data(&mut self)

pub fn write_data<S: Into<String>, D: Into<Data>>(
    &mut self,
    content_type: S,
    schema: Option<S>,
    value: D
)

Write data into the Event. You must provide a content_type and you can optionally provide a schema.

use cloudevents::Event;
use serde_json::json;
use std::convert::Into;

let mut e = Event::default();
e.write_data("application/json", None, json!({}))

pub fn get_data<T: Sized + From<Data>>(&self) -> Option<T>

pub fn try_get_data<T: Sized + TryFrom<Data, Error = E>, E: Error>(
    &self
) -> Option<Result<T, E>>

pub fn into_data<T: Sized + TryFrom<Data, Error = E>, E: Error>(
    self
) -> Option<Result<T, E>>

Trait Implementations

impl AttributesReader for Event

fn get_id(&self) -> &str

Get the id.

fn get_source(&self) -> &str

Get the source.

fn get_specversion(&self) -> SpecVersion

Get the specversion.

fn get_type(&self) -> &str

Get the type.

fn get_datacontenttype(&self) -> Option<&str>

Get the datacontenttype.

fn get_dataschema(&self) -> Option<&str>

Get the dataschema.

fn get_subject(&self) -> Option<&str>

Get the subject.

fn get_time(&self) -> Option<&DateTime<FixedOffset>>

Get the time.

fn get_extension(&self, extension_name: &str) -> Option<&ExtensionValue>

Get the extension named extension_name

fn get_extensions(&self) -> Vec<(&str, &ExtensionValue)>

Get all the extensions

impl AttributesWriter for Event

fn set_id(&mut self, id: impl Into<String>)

fn set_source(&mut self, source: impl Into<String>)

fn set_type(&mut self, ty: impl Into<String>)

fn set_subject(&mut self, subject: Option<impl Into<String>>)

fn set_time(&mut self, time: Option<impl Into<DateTime<FixedOffset>>>)

fn set_extension<'name, 'event: 'name>(
    &'event mut self,
    extension_name: &'name str,
    extension_value: impl Into<ExtensionValue>
)

fn remove_extension<'name, 'event: 'name>(
    &'event mut self,
    extension_name: &'name str
) -> Option<ExtensionValue>

impl Default for Event

fn default() -> Self

Returns the "default value" for a type.