Trait cloudevents::message::BinarySerializer
source · pub trait BinarySerializer<RETURN: Sized>where
Self: Sized,{
// Required methods
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<RETURN>;
fn end(self) -> Result<RETURN>;
}
Expand description
Serializer for binary mode messages.
Required Methods§
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<RETURN>
fn end(self) -> Result<RETURN>
Implementations on Foreign Types§
source§impl<T> BinarySerializer<Request<Option<T>>> for Builderwhere
T: TryFrom<Vec<u8>>,
<T as TryFrom<Vec<u8>>>::Error: Debug,
Available on crate features http-binding
or actix
or warp
or reqwest
or axum
or poem
only.
impl<T> BinarySerializer<Request<Option<T>>> for Builderwhere T: TryFrom<Vec<u8>>, <T as TryFrom<Vec<u8>>>::Error: Debug,
Available on crate features
http-binding
or actix
or warp
or reqwest
or axum
or poem
only.fn set_spec_version(self, sv: 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<Request<Option<T>>>
fn end(self) -> Result<Request<Option<T>>>
Implementors§
impl BinarySerializer<MessageRecord> for MessageRecord
Available on crate feature
rdkafka
only.impl BinarySerializer<RequestBuilder> for RequestSerializer
Available on crate feature
reqwest
only.impl<T> BinarySerializer<T> for Serializer<T>
Available on crate features
http-binding
or actix
or warp
or reqwest
or axum
or poem
only.