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).
• [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

HotPayloadSegment

ObjectPayloadRef

ProducerAppendRecord

ProducerSnapshot

StreamBatchAppend

StreamBatchAppendItem

StreamBootstrapPlan

StreamMessageRecord

StreamMetadata

StreamRead

StreamReadColdSegment

StreamReadObjectSegment

StreamReadPlan

StreamSnapshot

StreamSnapshotEntry

StreamStateMachine

StreamVisibleSnapshot

Enums

StreamCommand

StreamErrorCode

StreamReadSegment

StreamResponse

StreamSnapshotError

StreamStatus

Functions

validate_bucket_id

validate_stream_id

Type Aliases

ColdChunkRef

ExternalPayloadRef

ProducerRequest