[−][src]Trait fluvio::dataplane::core::store::FileWrite
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]
M: FileWrite,
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>
impl FileWrite for StreamFetchResponse<FileRecordSet>
[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 FetchResponse<FileRecordSet>
[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>
impl FileWrite for FetchablePartitionResponse<FileRecordSet>
[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>
impl FileWrite for FetchableTopicResponse<FileRecordSet>
[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>
impl FileWrite for PartitionProduceData<FileRecordSet>
[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>
impl FileWrite for ProduceRequest<FileRecordSet>
[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>
impl FileWrite for TopicProduceData<FileRecordSet>
[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>
impl FileWrite for FileRecordSet
[src]
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>
impl<P> FileWrite for ResponseMessage<P> where
P: FileWrite + Default,
[src]
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>
[src]
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue, Global>,
version: i16
) -> Result<(), Error>
impl<R> FileWrite for RequestMessage<R> where
R: FileWrite + Default + Request,
[src]
R: FileWrite + Default + Request,
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>