Crate fluvio_protocol

Re-exports

pub use fluvio_protocol_derive as derive;

pub use self::core::Version;

pub use bytes;

Modules

core

Structs

ByteBuf

Bytes Buffer with an optimized implementation for encoding and decoding. Useful for handling an immutable set of bytes.

Traits

Decoder

DecoderVarInt

Encoder

EncoderVarInt

Derive Macros

Decoder

Custom derive for decoding structure or enum from bytes using fluvio protocol format. This assumes all fields implement fluvio decode traits.

Encoder

Custom derive for encoding structure or enum to bytes using Kafka protocol format. This assumes all fields(or enum variants) implement kafka encode traits.

FluvioDefault

Custom derive for generating default structure

RequestApi

Custom derive for implementing Request trait. This derives requires fluvio