Trait BinarySerializer 

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>;
}

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>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<T> BinarySerializer<Request<Option<T>>> for Builder

where T: TryFrom<Vec<u8>>, <T as TryFrom<Vec<u8>>>::Error: Debug,

Available on crate features http-binding 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>>>

impl<T> BinarySerializer<Request<Option<T>>> for Builder

where T: TryFrom<Vec<u8>>, <T as TryFrom<Vec<u8>>>::Error: Debug,

Available on crate features http-0-2-binding or actix or warp 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 cloudevents::binding::http::Serializer<T>

Available on crate features http-binding or reqwest or axum or poem only.

impl<T> BinarySerializer<T> for cloudevents::binding::http_0_2::Serializer<T>

Available on crate features http-0-2-binding or actix or warp only.