Trait fluvio::dataplane::store::FileWrite

pub trait FileWrite: Encoder {
    // Provided method
    fn file_encode(
        &self,
        src: &mut BytesMut,
        _data: &mut Vec<StoreValue>,
        version: i16
    ) -> Result<(), Error> { ... }
}

Provided Methods

fn file_encode( &self, src: &mut BytesMut, _data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl FileWrite for FetchResponse<FileRecordSet>

fn file_encode( &self, src: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

impl FileWrite for FetchablePartitionResponse<FileRecordSet>

fn file_encode( &self, src: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

impl FileWrite for FetchableTopicResponse<FileRecordSet>

fn file_encode( &self, src: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

impl FileWrite for FileRecordSet

fn file_encode( &self, dest: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

impl FileWrite for PartitionProduceData<FileRecordSet>

fn file_encode( &self, src: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

impl FileWrite for ProduceRequest<FileRecordSet>

fn file_encode( &self, src: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

impl FileWrite for TopicProduceData<FileRecordSet>

fn file_encode( &self, src: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

impl FileWrite for StreamFetchResponse<FileRecordSet>

fn file_encode( &self, src: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

impl<M> FileWrite for Vec<M>

where M: FileWrite,

fn file_encode( &self, src: &mut BytesMut, data: &mut Vec<StoreValue>, version: i16 ) -> Result<(), Error>

Implementors

impl<P> FileWrite for ResponseMessage<P>

where P: FileWrite + Default,

This is same as encoding in the ResponseMessage but first includes the length and can encode async file slice

impl<R> FileWrite for RequestMessage<R>

where R: FileWrite + Default + Request,

This is same as encoding in the RequestMessage but first includes the length and can encode async file slice