Struct cloudevents::Event

pub struct Event { /* fields omitted */ }

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.

You can build events using super::EventBuilder

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

// Create an event using the Default trait
let mut e = Event::default();
e.write_data(
    "application/json",
    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)

Implementations

impl Event

pub fn remove_data(&mut self)

Remove data, dataschema and datacontenttype from this Event

pub fn write_data(
    &mut self,
    datacontenttype: impl Into<String>,
    data: impl Into<Data>
)

Write data into this Event with the specified datacontenttype.

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

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

pub fn write_data_with_schema(
    &mut self,
    datacontenttype: impl Into<String>,
    dataschema: impl Into<Url>,
    data: impl Into<Data>
)

Write data into this Event with the specified datacontenttype and dataschema.

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

let mut e = Event::default();
e.write_data_with_schema(
    "application/json",
    Url::parse("http://myapplication.com/schema").unwrap(),
    json!({})
)

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

Get data from this Event

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

Try to get data from this Event

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

Transform this Event into the content of data

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

Get the extension named extension_name

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

Get all the extensions

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

Set the extension named extension_name with extension_value

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

Remove the extension named extension_name

Trait Implementations

impl AttributesReader for Event

fn get_id(&self) -> &str

Get the id.

fn get_source(&self) -> &Url

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<&Url>

Get the dataschema.

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

Get the subject.

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

Get the time.

impl AttributesWriter for Event

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

Set the id.

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

Set the source.

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

Set the type.

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

Set the subject.

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

Set the time.

impl BinaryDeserializer for Event

fn deserialize_binary<R: Sized, V: BinarySerializer<R>>(
    self,
    visitor: V
) -> Result<R>

Deserialize the message to BinarySerializer

fn into_event(self) -> Result<Event>

Convert this Message to Event

impl BinarySerializer<Event> for Event

fn set_spec_version(self, spec_version: SpecVersion) -> Result<Self>

fn set_attribute(self, name: &str, value: MessageAttributeValue) -> Result<Self>

fn set_extension(self, name: &str, value: MessageAttributeValue) -> Result<Self>

fn end_with_data(self, bytes: Vec<u8>) -> Result<Event>

fn end(self) -> Result<Event>

impl Clone for Event

fn clone(&self) -> Event

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Event

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

Formats the value using the given formatter.

impl Default for Event

fn default() -> Self

Returns the "default value" for a type.

impl<'de> Deserialize<'de> for Event

fn deserialize<D>(
    deserializer: D
) -> Result<Self, <D as Deserializer<'de>>::Error> where
    D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<Event> for Event

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl Serialize for Event

fn serialize<S>(
    &self,
    serializer: S
) -> Result<<S as Serializer>::Ok, <S as Serializer>::Error> where
    S: Serializer, 

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Event

impl StructuredDeserializer for Event

fn deserialize_structured<R, V: StructuredSerializer<R>>(
    self,
    visitor: V
) -> Result<R>

Deserialize the message to StructuredSerializer

fn into_event(self) -> Result<Event>

Convert this Message to Event

impl StructuredSerializer<Event> for Event

fn set_structured_event(self, bytes: Vec<u8>) -> Result<Event>