Trait rabbitmq_stream_protocol::codec::Encoder

source ·
pub trait Encoder {
    // Required methods
    fn encoded_size(&self) -> u32;
    fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>;
}

Required Methods§

source

fn encoded_size(&self) -> u32

source

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

Object Safety§

This trait is not object safe.

Implementations on Foreign Types§

source§

impl Encoder for &str

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Option<String>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for i8

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for i32

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for i64

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for u8

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for u16

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for u32

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for u64

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<u8>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<u16>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<u32>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<u64>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<Broker>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<StreamMetadata>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<PublishedMessage>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<PublishingError>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for Vec<String>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

source§

impl Encoder for HashMap<String, String>

source§

fn encoded_size(&self) -> u32

source§

fn encode(&self, writer: &mut impl Write) -> Result<(), EncodeError>

Implementors§

source§

impl Encoder for OffsetSpecification

source§

impl Encoder for RequestKind

source§

impl Encoder for ResponseCode

source§

impl Encoder for CloseRequest

source§

impl Encoder for CloseResponse

source§

impl Encoder for CreateStreamCommand

source§

impl Encoder for CreditCommand

source§

impl Encoder for CreditResponse

source§

impl Encoder for DeclarePublisherCommand

source§

impl Encoder for Delete

source§

impl Encoder for DeletePublisherCommand

source§

impl Encoder for DeliverCommand

source§

impl Encoder for GenericResponse

source§

impl Encoder for HeartBeatCommand

source§

impl Encoder for HeartbeatResponse

source§

impl Encoder for Broker

source§

impl Encoder for MetadataCommand

source§

impl Encoder for MetadataResponse

source§

impl Encoder for StreamMetadata

source§

impl Encoder for MetadataUpdateCommand

source§

impl Encoder for OpenCommand

source§

impl Encoder for PeerPropertiesCommand

source§

impl Encoder for PublishCommand

source§

impl Encoder for PublishConfirm

source§

impl Encoder for PublishErrorResponse

source§

impl Encoder for QueryOffsetRequest

source§

impl Encoder for QueryOffsetResponse

source§

impl Encoder for QueryPublisherRequest

source§

impl Encoder for QueryPublisherResponse

source§

impl Encoder for SaslAuthenticateCommand

source§

impl Encoder for SaslHandshakeCommand

source§

impl Encoder for StoreOffset

source§

impl Encoder for SubscribeCommand

source§

impl Encoder for TunesCommand

source§

impl Encoder for UnSubscribeCommand

source§

impl Encoder for Message

source§

impl Encoder for Request

source§

impl Encoder for Header

source§

impl Encoder for PublishedMessage

source§

impl Encoder for PublishingError