Expand description
Fixed-width and varint primitive read/write helpers.
Every Kafka schema field eventually decomposes to one of these primitives.
Helpers operate on bytes::Bytes / bytes::BytesMut and return
PrimitiveError on insufficient data or malformed varints.
Re-exports§
pub use self::error::PrimitiveError;pub use self::error::PrimitiveErrorKind;
Modules§
- error
- Error types for
crate::primitives.
Functions§
- array_
length_ len - Encoded length of a non-flexible array length prefix.
- array_
read_ capacity - Initial
Veccapacity for a decoded array. - compact_
array_ length_ len - Encoded length of a compact array length prefix.
- read_
array_ length - Read a non-flexible array length (
i32).-1indicates a null array. - read_
bool - Read a boolean (1 byte: 0 = false, nonzero = true).
- read_
compact_ array_ length - Read a compact array length (varint of
len + 1,0 → -1(null)). - read_
f64 - Read a 64-bit IEEE-754 float (big-endian).
- read_i8
- Read a signed 8-bit integer.
- read_
i16 - Read a signed 16-bit integer (big-endian).
- read_
i32 - Read a signed 32-bit integer (big-endian).
- read_
i64 - Read a signed 64-bit integer (big-endian).
- read_
signed_ varint - Read a signed varint (zigzag-decoded
i32). - read_
signed_ varlong - Read a signed varlong (zigzag-decoded
i64). - read_
u16 - Read an unsigned 16-bit integer (big-endian).
- read_
u32 - Read an unsigned 32-bit integer (big-endian).
- read_
unsigned_ varint - Read an unsigned varint (1–5 bytes,
u32payload). - read_
unsigned_ varlong - Read an unsigned varlong (1–10 bytes,
u64payload). - signed_
varint_ len - Encoded length of a signed varint (zigzag-encoded
i32). - signed_
varlong_ len - Encoded length of a signed varlong (zigzag-encoded
i64). - unsigned_
varint_ len - Encoded length of an unsigned varint (1–5 bytes,
u32payload). - unsigned_
varlong_ len - Encoded length of an unsigned varlong (1–10 bytes,
u64payload). - write_
array_ length - Write a non-flexible array length (
i32). - write_
bool - Write a boolean (1 byte: 0 or 1).
- write_
compact_ array_ length - Write a compact array length (varint of
len + 1, negative →0(null)). - write_
f64 - Write a 64-bit IEEE-754 float (big-endian).
- write_
i8 - Write a signed 8-bit integer.
- write_
i16 - Write a signed 16-bit integer (big-endian).
- write_
i32 - Write a signed 32-bit integer (big-endian).
- write_
i64 - Write a signed 64-bit integer (big-endian).
- write_
signed_ varint - Write a signed varint (zigzag-encoded
i32). - write_
signed_ varlong - Write a signed varlong (zigzag-encoded
i64). - write_
u16 - Write an unsigned 16-bit integer (big-endian).
- write_
u32 - Write an unsigned 32-bit integer (big-endian).
- write_
unsigned_ varint - Write an unsigned varint (1–5 bytes,
u32payload). - write_
unsigned_ varlong - Write an unsigned varlong (1–10 bytes,
u64payload).
Type Aliases§
- Result
- Result alias for primitive read operations.