Trait rabbitmq_stream_protocol::codec::Encoder

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

Required Methods

fn encoded_size(&self) -> u32

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

Implementations on Foreign Types

impl Encoder for i8

fn encoded_size(&self) -> u32

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

impl Encoder for i32

fn encoded_size(&self) -> u32

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

impl Encoder for u8

fn encoded_size(&self) -> u32

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

impl Encoder for u16

fn encoded_size(&self) -> u32

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

impl Encoder for u32

fn encoded_size(&self) -> u32

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

impl Encoder for u64

fn encoded_size(&self) -> u32

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

impl Encoder for i64

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<PublishedMessage>

fn encoded_size(&self) -> u32

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

impl Encoder for &str

fn encoded_size(&self) -> u32

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

impl Encoder for HashMap<String, String>

fn encoded_size(&self) -> u32

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

impl Encoder for Option<String>

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<String>

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<u8>

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<u32>

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<u16>

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<u64>

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<PublishingError>

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<Broker>

fn encoded_size(&self) -> u32

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

impl Encoder for Vec<StreamMetadata>

fn encoded_size(&self) -> u32

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

Implementors

impl Encoder for OffsetSpecification

impl Encoder for RequestKind

impl Encoder for ResponseCode

impl Encoder for CloseRequest

impl Encoder for CloseResponse

impl Encoder for CreateStreamCommand

impl Encoder for CreditCommand

impl Encoder for CreditResponse

impl Encoder for DeclarePublisherCommand

impl Encoder for Delete

impl Encoder for DeletePublisherCommand

impl Encoder for DeliverCommand

impl Encoder for GenericResponse

impl Encoder for HeartBeatCommand

impl Encoder for HeartbeatResponse

impl Encoder for Broker

impl Encoder for MetadataCommand

impl Encoder for MetadataResponse

impl Encoder for StreamMetadata

impl Encoder for MetadataUpdateCommand

impl Encoder for OpenCommand

impl Encoder for PeerPropertiesCommand

impl Encoder for PublishCommand

impl Encoder for PublishConfirm

impl Encoder for PublishErrorResponse

impl Encoder for QueryOffsetRequest

impl Encoder for QueryOffsetResponse

impl Encoder for QueryPublisherRequest

impl Encoder for QueryPublisherResponse

impl Encoder for SaslAuthenticateCommand

impl Encoder for SaslHandshakeCommand

impl Encoder for StoreOffset

impl Encoder for SubscribeCommand

impl Encoder for TunesCommand

impl Encoder for UnSubscribeCommand

impl Encoder for Message

impl Encoder for Request

impl Encoder for Header

impl Encoder for PublishedMessage

impl Encoder for PublishingError