Struct Connection 

pub struct Connection { /* private fields */ }

One broker connection’s protocol state. Owns no socket.

Implementations

impl Connection

pub fn new(client_id: impl Into<StrBytes>) -> Self

pub fn in_flight(&self) -> usize

How many requests are awaiting responses.

The producer’s in-flight limit is enforced against this: Kafka retains idempotence with up to five in flight, and only because sequence numbers let the broker order them.

pub fn request<R: Encodable>( &mut self, api_key: ApiKey, version: i16, req: &R, ) -> Result<Bytes>

Encode req into a framed, ready-to-write buffer and record it as in flight.

Errors

Error::Codec if encoding fails.

pub fn push_bytes(&mut self, bytes: &[u8])

Feed bytes from the socket.

pub fn needed(&self) -> usize

How many more bytes the next response needs. See FrameDecoder::needed.

pub fn next_response(&mut self) -> Result<Option<PendingResponse>>

Take the next complete response, matched to its request.

Errors

Error::Unsolicited if nothing was in flight, Error::Correlation if the id does not match the oldest in-flight request. Both are fatal for the connection.

pub fn decode<R: Decodable>(resp: &PendingResponse) -> Result<R>

Decode a response body into its concrete type.

Errors

Error::Codec if decoding fails.

Trait Implementations

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.