Trait kafkaesque::formats::Write

pub trait Write {
    // Required methods
    fn calculate_size(&self) -> i32;
    async fn write_to(
        &self,
        writer: &mut (dyn AsyncWrite + Send + Unpin)
    ) -> Result<()>;
}

Required Methods

fn calculate_size(&self) -> i32

async fn write_to( &self, writer: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

Implementations on Foreign Types

impl Write for i8

fn calculate_size(&self) -> i32

async fn write_to( &self, sink: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

impl Write for i16

fn calculate_size(&self) -> i32

async fn write_to( &self, sink: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

impl Write for i32

fn calculate_size(&self) -> i32

async fn write_to( &self, sink: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

impl Write for i64

fn calculate_size(&self) -> i32

async fn write_to( &self, sink: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

impl Write for u32

fn calculate_size(&self) -> i32

async fn write_to( &self, sink: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

impl Write for bool

fn calculate_size(&self) -> i32

async fn write_to( &self, writer: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

impl<A: Write> Write for Vec<A>

fn calculate_size(&self) -> i32

async fn write_to( &self, writer: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

impl<'a> Write for &'a str

fn calculate_size(&self) -> i32

async fn write_to( &self, writer: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

impl Write for String

fn calculate_size(&self) -> i32

async fn write_to( &self, writer: &mut (dyn AsyncWrite + Send + Unpin) ) -> Result<()>

Implementors

impl Write for ApiKey

impl Write for ApiVersionsRequest

impl Write for MetadataRequestV0

impl Write for MetadataResponseV0

impl Write for Partition

impl Write for ReqV0Topic

impl Write for RespV0Broker

impl Write for RespV0Topic

impl Write for ApiVersion

impl Write for ErrorCode