Trait fluvio_dataplane_protocol::store::FileWrite [−][src]
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>
[src]
&self,
src: &mut BytesMut,
_data: &mut Vec<StoreValue, Global>,
version: i16
) -> Result<(), Error>
Implementations on Foreign Types
impl<M> FileWrite for Vec<M, Global> where
M: FileWrite,
[src]
impl<M> FileWrite for Vec<M, Global> where
M: FileWrite,
[src]pub fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue, Global>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue, Global>,
version: i16
) -> Result<(), Error>
Implementors
impl FileWrite for FileRecordSet
[src]
impl FileWrite for FileRecordSet
[src]fn file_encode(
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
[src]
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
impl FileWrite for FileFetchResponse
[src]
impl FileWrite for FileFetchResponse
[src]fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
impl FileWrite for FilePartitionResponse
[src]
impl FileWrite for FilePartitionResponse
[src]fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
impl FileWrite for FileTopicResponse
[src]
impl FileWrite for FileTopicResponse
[src]fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
impl FileWrite for FilePartitionRequest
[src]
impl FileWrite for FilePartitionRequest
[src]fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
impl FileWrite for FileProduceRequest
[src]
impl FileWrite for FileProduceRequest
[src]fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
impl FileWrite for FileTopicRequest
[src]
impl FileWrite for FileTopicRequest
[src]fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: Version
) -> Result<(), IoError>
impl<P> FileWrite for ResponseMessage<P> where
P: FileWrite + Default,
[src]
impl<P> FileWrite for ResponseMessage<P> where
P: FileWrite + Default,
[src]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>
[src]
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue, Global>,
version: i16
) -> Result<(), Error>