Crate kinbox 

Re-exports

pub use inbox::Inbox;

pub use config::*;

pub use list::*;

pub use reader::*;

pub use writer::*;

Modules

config

inbox

list

reader

writer

Structs

BorrowedHeaders

A zero-copy collection of Kafka message headers.

BorrowedMessage

A zero-copy Kafka message.

FutureRecord

A record for the future producer.

Header

A Kafka message header.

HeadersIter

An iterator over Headers.

OwnedHeaders

A collection of Kafka message headers that owns its backing data.

OwnedMessage

A Kafka message that owns its backing data.

Enums

KafkaError

Represents all possible Kafka errors.

RDKafkaErrorCode

Native rdkafka error code.

Timeout

Specifies a timeout for a Kafka operation.

Timestamp

Timestamp of a Kafka message.

Traits

FromBytes

A cheap conversion from a byte slice to typed data.

Headers

A generic representation of Kafka message headers.

Message

A generic representation of a Kafka message.

ToBytes

A cheap conversion from typed data to a byte slice.

Type Aliases

DeliveryResult

The result of a message production.