Trait kf_protocol_fs::FileWrite

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

Provided methods

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

Loading content...

Implementations on Foreign Types

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

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

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

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

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

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

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

Loading content...

Implementors

impl FileWrite for KfFileRecordSet

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

impl FileWrite for FileFetchResponse

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

impl FileWrite for FilePartitionRequest

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

impl FileWrite for FilePartitionResponse

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

impl FileWrite for FileProduceRequest

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

impl FileWrite for FileTopicRequest

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

impl FileWrite for FileTopicResponse

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

Loading content...