Struct fluvio_dataplane_protocol::produce::ProduceResponse [−][src]
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
pub 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
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
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more