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".

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 axum or http-binding or poem or reqwest 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 actix or http-0-2-binding 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 axum or http-binding or poem or reqwest only.

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

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