cloudevents
/
sdk-rust
mirror of https://github.com/cloudevents/sdk-rust.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add AttributeValue::Binary; align order of AttributeValue with spec 

Signed-off-by: Bobby Calderwood <8336+bobby@users.noreply.github.com>
This commit is contained in:
Bobby Calderwood 2024-09-26 23:07:16 -05:00
parent bf45f01602
commit f9236c43f5
No known key found for this signature in database
GPG Key ID: 998AE286FCCF5E3F
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/event/attributes.rs
View File

@ -11,13 +11,14 @@ use url::Url;
/// This represents the types defined in the [CloudEvent spec type system](https://github.com/cloudevents/spec/blob/v1.0/spec.md#type-system) /// This represents the types defined in the [CloudEvent spec type system](https://github.com/cloudevents/spec/blob/v1.0/spec.md#type-system)
#[derive(Debug, PartialEq, Eq)] #[derive(Debug, PartialEq, Eq)]
pub enum AttributeValue<'a> { pub enum AttributeValue<'a> {
SpecVersion(SpecVersion),
String(&'a str),
URI(&'a Url),
URIRef(&'a UriReference),
Boolean(&'a bool), Boolean(&'a bool),
Integer(&'a i64), Integer(&'a i64),
String(&'a str),
Binary(&'a [u8]),
URI(&'a Url),
URIRef(&'a UriReference),
Time(&'a DateTime<Utc>), Time(&'a DateTime<Utc>),
SpecVersion(SpecVersion),
} }
impl<'a> From<&'a ExtensionValue> for AttributeValue<'a> { impl<'a> From<&'a ExtensionValue> for AttributeValue<'a> {
@ -33,13 +34,14 @@ impl<'a> From<&'a ExtensionValue> for AttributeValue<'a> {
impl fmt::Display for AttributeValue<'_> { impl fmt::Display for AttributeValue<'_> {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match self { match self {
AttributeValue::SpecVersion(s) => s.fmt(f), AttributeValue::Boolean(b) => f.serialize_bool(**b),
AttributeValue::Integer(i) => f.serialize_i64(**i),
AttributeValue::String(s) => f.write_str(s), AttributeValue::String(s) => f.write_str(s),
AttributeValue::Binary(b) => f.write_str(&base64::encode(b)),
AttributeValue::URI(s) => f.write_str(s.as_str()), AttributeValue::URI(s) => f.write_str(s.as_str()),
AttributeValue::URIRef(s) => f.write_str(s.as_str()), AttributeValue::URIRef(s) => f.write_str(s.as_str()),
AttributeValue::Time(s) => f.write_str(&s.to_rfc3339()), AttributeValue::Time(s) => f.write_str(&s.to_rfc3339()),
AttributeValue::Boolean(b) => f.serialize_bool(**b), AttributeValue::SpecVersion(s) => s.fmt(f),
AttributeValue::Integer(i) => f.serialize_i64(**i),
} }
} }
} }