Trait cloudevents::message::MessageDeserializer

pub trait MessageDeserializerwhere
    Self: StructuredDeserializer + BinaryDeserializer + Sized,{
    // Required method
    fn encoding(&self) -> Encoding;

    // Provided methods
    fn into_event(self) -> Result<Event> { ... }
    fn deserialize_to_binary<R: Sized, T: BinarySerializer<R>>(
        self,
        serializer: T
    ) -> Result<R> { ... }
    fn deserialize_to_structured<R: Sized, T: StructuredSerializer<R>>(
        self,
        serializer: T
    ) -> Result<R> { ... }
    fn deserialize_to<R: Sized, T: BinarySerializer<R> + StructuredSerializer<R>>(
        self,
        serializer: T
    ) -> Result<R> { ... }
}

Deserializer trait for a Message that can be encoded both in structured mode or binary mode.

Required Methods

fn encoding(&self) -> Encoding

Get this message Encoding.

Provided Methods

fn into_event(self) -> Result<Event>

Convert this Message to Event.

fn deserialize_to_binary<R: Sized, T: BinarySerializer<R>>( self, serializer: T ) -> Result<R>

Deserialize the message to BinarySerializer.

fn deserialize_to_structured<R: Sized, T: StructuredSerializer<R>>( self, serializer: T ) -> Result<R>

Deserialize the message to StructuredSerializer.

fn deserialize_to<R: Sized, T: BinarySerializer<R> + StructuredSerializer<R>>( self, serializer: T ) -> Result<R>

Deserialize the message to a serializer, depending on the message encoding. You can use this method to transcode this message directly to another serializer, without going through Event.

Implementors

impl MessageDeserializer for ConsumerRecordDeserializer

Available on crate feature rdkafka only.

impl<'a, T: Headers<'a>> MessageDeserializer for Deserializer<'a, T>

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