Trait fluvio::dataplane::core::store::FileWrite

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

Provided methods

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

Loading content...

Implementations on Foreign Types

impl<M> FileWrite for Vec<M, Global> where
    M: FileWrite, 

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

impl FileWrite for StreamFetchResponse<FileRecordSet>

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

Loading content...

Implementors

impl FileWrite for FetchResponse<FileRecordSet>

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

impl FileWrite for FetchablePartitionResponse<FileRecordSet>

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

impl FileWrite for FetchableTopicResponse<FileRecordSet>

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

impl FileWrite for PartitionProduceData<FileRecordSet>

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

impl FileWrite for ProduceRequest<FileRecordSet>

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

impl FileWrite for TopicProduceData<FileRecordSet>

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

impl FileWrite for FileRecordSet

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

impl<P> FileWrite for ResponseMessage<P> where
    P: FileWrite + Default, 

This is same as encoding in the ResponseMessage but can encode async file slice

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

impl<R> FileWrite for RequestMessage<R> where
    R: FileWrite + Default + Request, 

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

Loading content...