Skip to main content

Module header_codec

Module header_codec 

Source
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§

BinarySink
An EncodeSink that writes canonical extension fields directly to a ROCKETMQ binary payload.
HeaderFieldContext
Static field metadata used for typed conversion and diagnostics.
HeaderFieldSpec
Static schema metadata for one non-flattened header field.
HeaderFlattenSpec
Static schema metadata for one flattened nested header.
JsonSink
An EncodeSink that writes one JSON extension-field object directly.
MapSink
An EncodeSink that appends typed fields directly to a HeaderMap.
ResolvedHeaderKey
Canonical resolution result for a canonical key or decode alias.

Enums§

AliasConflictPolicy
Decode behavior when canonical and legacy alias keys coexist.
DynamicCollisionPolicy
Merge behavior between typed fields and dynamic extension fields.
FlattenPresenceSpec
Presence semantics for a flattened nested header.
HeaderPresence
Missing-field semantics recorded in generated header schemas.
HeaderRange
A signed Java numeric range applied to an unsigned Rust field.
HeaderValueKind
Protocol-reviewed value categories supported by typed request headers.

Traits§

EncodeSink
A statically dispatched destination for typed header fields.
HeaderCodec
Statically dispatched codec contract for an explicit request-header schema.
HeaderFieldSource
A validated, borrowed view of remoting command extension fields.
HeaderValue
A protocol-approved request-header wire value.

Functions§

validate_unsigned_java_range
Validates an unsigned value against its field-level signed Java range.