Skip to main content

Crate ursula_runtime

Crate ursula_runtime 

Source
Expand description

Per-core actor runtime for Ursula.

Module map:

  • [cold_store]: opendal-backed cold tier handle and object path helpers.
  • [request]: HTTP/gRPC request and response value types for each engine op.
  • [command]: the replicated GroupWriteCommand and From conversions from request values into the wire command consumed by GroupEngine.
  • [error]: runtime-level error type RuntimeError.
  • [engine]: the GroupEngine trait, factory, metrics, and the boxed-future type aliases that form the replaceable per-group engine boundary.
  • [engine_in_memory]: InMemoryGroupEngine, the hot-ring reference engine used by tests and the --raft-memory cluster mode.
  • [engine_wal]: WalGroupEngine, the durable file-backed engine.
  • [runtime]: ShardRuntime, RuntimeConfig, and per-core worker spawn.
  • [core_worker]: single-thread actor that owns groups for one core.
  • [group_actor]: per-group mailbox actor running inside a core worker.
  • [metrics]: runtime metrics shared across cores; lock-free counters.

Structs§

AppendBatchRequest
AppendBatchResponse
AppendExternalRequest
AppendRequest
AppendResponse
BootstrapStreamRequest
BootstrapStreamResponse
BootstrapUpdate
CloseStreamRequest
CloseStreamResponse
ColdFlushCandidate
ColdHotBacklog
ColdStore
ColdWriteAdmission
CreateStreamExternalRequest
CreateStreamRequest
CreateStreamResponse
DeleteSnapshotRequest
DeleteStreamRequest
DeleteStreamResponse
FlushColdRequest
FlushColdResponse
ForkRefResponse
GroupAppendBatchResponse
GroupEngineError
GroupEngineMetrics
GroupLeaderHint
GroupReadStreamParts
GroupSnapshot
HeadStreamRequest
HeadStreamResponse
InMemoryGroupEngine
InMemoryGroupEngineFactory
PlanColdFlushRequest
PlanGroupColdFlushRequest
PublishSnapshotRequest
PublishSnapshotResponse
ReadSnapshotRequest
ReadSnapshotResponse
ReadStreamRequest
ReadStreamResponse
RuntimeConfig
RuntimeMailboxSnapshot
RuntimeMetrics
RuntimeMetricsSnapshot
ShardRuntime
StreamAppendCount
TouchStreamAccessResponse
WalGroupEngine
WalGroupEngineFactory

Enums§

GroupReadStreamBody
GroupWriteCommand
GroupWriteResponse
RuntimeError
RuntimeThreading
StreamErrorCode

Traits§

GroupEngine
GroupEngineFactory

Functions§

new_cold_chunk_path
new_external_payload_path

Type Aliases§

ColdChunkRef
ColdStoreHandle
ExternalPayloadRef
GroupAppendBatchFuture
GroupAppendFuture
GroupBootstrapStreamFuture
GroupCloseStreamFuture
GroupColdHotBacklogFuture
GroupCreateStreamFuture
GroupDeleteSnapshotFuture
GroupDeleteStreamFuture
GroupEngineCreateFuture
GroupFlushColdFuture
GroupForkRefFuture
GroupHeadStreamFuture
GroupInstallSnapshotFuture
GroupPlanColdFlushFuture
GroupPlanNextColdFlushBatchFuture
GroupPlanNextColdFlushFuture
GroupPublishSnapshotFuture
GroupReadSnapshotFuture
GroupReadStreamFuture
GroupReadStreamPartsFuture
GroupRequireLiveReadOwnerFuture
GroupSnapshotFuture
GroupTouchStreamAccessFuture
GroupWriteBatchFuture
ProducerRequest