Struct fluvio_dataplane_protocol::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
sourceimpl ProduceResponse
impl ProduceResponse
sourcepub fn find_partition_response(
&self,
topic: &str,
partition: i32
) -> Option<&PartitionProduceResponse>
pub fn find_partition_response(
&self,
topic: &str,
partition: i32
) -> Option<&PartitionProduceResponse>
Find partition in Response
Trait Implementations
sourceimpl Debug for ProduceResponse
impl Debug for ProduceResponse
sourceimpl Decoder for ProduceResponse
impl Decoder for ProduceResponse
sourceimpl Default for ProduceResponse
impl Default for ProduceResponse
sourceimpl Encoder for ProduceResponse
impl Encoder for ProduceResponse
Auto Trait Implementations
impl RefUnwindSafe for ProduceResponse
impl Send for ProduceResponse
impl Sync for ProduceResponse
impl Unpin for ProduceResponse
impl UnwindSafe for ProduceResponse
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more