Crate ursula_stream 

Durable Streams state machine for Ursula.

Module map:

• [command]: replicated command variants applied to the state machine.
• [response]: result variants and error codes returned per command.
• [model]: persistent data types (metadata, segments, producer state, plans).
• [record_index]: exact retained record-ordinal to offset boundaries.
• [snapshot]: snapshot wire format and restoration errors.
• [state_machine]: the deterministic StreamStateMachine that drives a Raft group.
• [validate]: bucket/stream id validation used by HTTP and Raft entry points.

Structs

AppendStreamInput

ColdFlushCandidate

ColdGcEntry

One unit of deferred cold-storage reclamation. Enqueued deterministically in the state machine when a stream’s cold objects become unreferenced, drained asynchronously by the leader’s background GC worker.

HotPayloadSegment

ObjectPayloadRef

ProducerAppendRecord

ProducerSnapshot

StreamAttrs

StreamBatchAppend

StreamBatchAppendItem

StreamBootstrapPlan

StreamIntegritySnapshot

StreamMessageRecord

StreamMetadata

StreamRead

StreamReadColdIndexSegment

StreamReadColdSegment

StreamReadObjectSegment

StreamReadPlan

StreamRecordIndex

StreamRecordRange

StreamSnapshot

StreamSnapshotEntry

StreamStateMachine

StreamVisibleSnapshot

Enums

ColdGcTarget

RecordIndexError

StreamCommand

StreamErrorCode

StreamErrorContext

StreamReadSegment

StreamResponse

StreamSnapshotError

StreamStatus

Constants

COLD_INDEX_PAGE_SPAN_BYTES

Functions

canonical_json_record_ends

is_json_record_content_type

validate_bucket_id

validate_stream_id

Type Aliases

ColdChunkRef

ExternalPayloadRef

ProducerRequest