Module stream_failure 

Structured processing failures shared by string-based binding errors.

Structs

StreamBarrierCause

Safe cause metadata. Messages do not contain raw nested error data.

StreamBarrierFailure

One failed barrier and every topic obligation that it did not complete.

StreamBarrierTopic

All 64-bit values are decimal strings. Topic bytes use hexadecimal.

StreamFailureDetails

Versioned error details shared by all string-based binding error carriers.

StreamFailureSummary

Partial committed catch-up counts, encoded as exact decimal u64 strings.

Enums

StreamBarrierCauseKind

Stable categories for one unfinished topic’s cause.

StreamBarrierReason

Why the barrier stopped waiting. Durable pending work is retained.

StreamFailureKind

The operation whose fixed processing obligations remain unfinished.

Constants

STREAM_FAILURE_MARKER

The suffix version is independent of the normal error message and code.

Functions

decode_stream_failure

Decode the versioned suffix. Ordinary errors have no structured details.

encode_stream_failure

Append this suffix after the existing error code and message.

stream_failure_details

Read known wrapper fields explicitly. Transparent errors can skip them in source(). Visit every summary branch so a first error cannot hide sibling obligations.