[−][src]Trait kf_protocol::fs::FileWrite
Provided methods
fn file_encode(
&self,
src: &mut BytesMut,
_data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
&self,
src: &mut BytesMut,
_data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
Implementations on Foreign Types
impl<M> FileWrite for Vec<M> where
M: FileWrite,
[src]
M: FileWrite,
fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
Implementors
impl FileWrite for KfFileRecordSet
[src]
fn file_encode(
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
impl FileWrite for FetchablePartitionResponse<KfFileRecordSet>
[src]
fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
impl FileWrite for FetchableTopicResponse<KfFileRecordSet>
[src]
fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
impl FileWrite for KfFetchResponse<KfFileRecordSet>
[src]
fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
impl FileWrite for KfProduceRequest<KfFileRecordSet>
[src]
fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
impl FileWrite for PartitionProduceData<KfFileRecordSet>
[src]
fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
impl FileWrite for TopicProduceData<KfFileRecordSet>
[src]
fn file_encode(
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
src: &mut BytesMut,
data: &mut Vec<StoreValue>,
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
fn file_encode(
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
impl<R> FileWrite for RequestMessage<R> where
R: FileWrite + Default + Request,
[src]
R: FileWrite + Default + Request,
fn file_encode(
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>
[src]
&self,
dest: &mut BytesMut,
data: &mut Vec<StoreValue>,
version: i16
) -> Result<(), Error>