Expand description
Typed runtime primitives shared by request-header codec implementations.
This module deliberately exposes only protocol-reviewed wire value types and protocol-owned sinks. Both extension traits are sealed so adding a Rust type or sink cannot silently expand RocketMQ wire semantics in another crate.
Structs§
- Binary
Sink - An
EncodeSinkthat writes canonical extension fields directly to a ROCKETMQ binary payload. - Header
Field Context - Static field metadata used for typed conversion and diagnostics.
- Header
Field Spec - Static schema metadata for one non-flattened header field.
- Header
Flatten Spec - Static schema metadata for one flattened nested header.
- Json
Sink - An
EncodeSinkthat writes one JSON extension-field object directly. - MapSink
- An
EncodeSinkthat appends typed fields directly to aHeaderMap. - Resolved
Header Key - Canonical resolution result for a canonical key or decode alias.
Enums§
- Alias
Conflict Policy - Decode behavior when canonical and legacy alias keys coexist.
- Dynamic
Collision Policy - Merge behavior between typed fields and dynamic extension fields.
- Flatten
Presence Spec - Presence semantics for a flattened nested header.
- Header
Presence - Missing-field semantics recorded in generated header schemas.
- Header
Range - A signed Java numeric range applied to an unsigned Rust field.
- Header
Value Kind - Protocol-reviewed value categories supported by typed request headers.
Traits§
- Encode
Sink - A statically dispatched destination for typed header fields.
- Header
Codec - Statically dispatched codec contract for an explicit request-header schema.
- Header
Field Source - A validated, borrowed view of remoting command extension fields.
- Header
Value - A protocol-approved request-header wire value.
Functions§
- validate_
unsigned_ java_ range - Validates an unsigned value against its field-level signed Java range.