Struct fluvio_spu_schema::produce::ProduceResponse
source · pub struct ProduceResponse {
pub responses: Vec<TopicProduceResponse>,
pub throttle_time_ms: i32,
}
Fields§
§responses: Vec<TopicProduceResponse>
Each produce response
throttle_time_ms: i32
The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.
Implementations§
source§impl ProduceResponse
impl ProduceResponse
sourcepub fn find_partition_response(
&self,
topic: &str,
partition: u32
) -> Option<&PartitionProduceResponse>
pub fn find_partition_response( &self, topic: &str, partition: u32 ) -> Option<&PartitionProduceResponse>
Find partition in Response
Trait Implementations§
source§impl Debug for ProduceResponse
impl Debug for ProduceResponse
source§impl Decoder for ProduceResponse
impl Decoder for ProduceResponse
source§impl Default for ProduceResponse
impl Default for ProduceResponse
source§impl Encoder for ProduceResponse
impl Encoder for ProduceResponse
Auto Trait Implementations§
impl Freeze for ProduceResponse
impl RefUnwindSafe for ProduceResponse
impl Send for ProduceResponse
impl Sync for ProduceResponse
impl Unpin for ProduceResponse
impl UnwindSafe for ProduceResponse
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more