ursula_runtime/
lib.rs

1//! Per-core actor runtime for Ursula.
2//!
3//! Module map:
4//!
5//! - [`cold_store`]: opendal-backed cold tier handle and object path helpers.
6//! - [`request`]: HTTP/gRPC request and response value types for each engine op.
7//! - [`command`]: the replicated [`GroupWriteCommand`] envelope around the
8//!   canonical [`ursula_stream::StreamCommand`], plus `From` conversions from
9//!   request values into that command.
10//! - [`error`]: runtime-level error type [`RuntimeError`].
11//! - [`engine`]: the `GroupEngine` trait, factory, metrics, and the boxed-future
12//!   type aliases that form the replaceable per-group engine boundary, plus the
13//!   in-memory implementation under [`engine::in_memory`].
14//! - [`runtime`]: `ShardRuntime`, `RuntimeConfig`, and per-core worker spawn.
15//! - [`core_worker`]: single-thread actor that owns groups for one core.
16//! - [`group_actor`]: per-group mailbox actor running inside a core worker.
17//! - [`ops`]: declarative manifest of the uniform runtime operations; expands
18//!   into the per-operation actor and client plumbing.
19//! - [`metrics`]: runtime metrics shared across cores; lock-free counters.
20
21mod admission;
22pub mod cold_index;
23mod cold_store;
24pub mod cold_worker;
25mod command;
26mod core_worker;
27mod engine;
28
29mod error;
30mod group_actor;
31pub mod journal;
32mod metrics;
33mod ops;
34mod request;
35mod rt;
36mod runtime;
37mod snapshot_store;
38mod trace;
39
40pub use admission::RaftUncommittedAdmission;
41pub use cold_index::ColdIndexPage;
42pub use cold_index::ColdIndexPageCache;
43pub use cold_index::ColdIndexPageKey;
44pub use cold_index::ColdIndexPageStore;
45pub use cold_index::ColdStoreColdIndexPageStore;
46pub use cold_index::InMemoryColdIndexPageStore;
47pub use cold_index::cold_index_prefix;
48pub use cold_index::write_cold_chunk_index_pages;
49pub use cold_index::write_external_segment_index_pages;
50pub use cold_store::ColdReadCacheParams;
51pub use cold_store::ColdStore;
52pub use cold_store::ColdStoreEvent;
53pub use cold_store::ColdStoreFault;
54pub use cold_store::ColdStoreFaultContext;
55pub use cold_store::ColdStoreFaultEffect;
56pub use cold_store::ColdStoreHandle;
57pub use cold_store::ColdStoreInfo;
58pub use cold_store::ColdStoreOperation;
59pub use cold_store::new_cold_chunk_path;
60pub use cold_store::new_external_payload_path;
61pub use cold_worker::spawn_cold_flush_worker_if_configured;
62pub use cold_worker::spawn_cold_gc_worker_if_configured;
63pub use command::GroupSnapshot;
64pub use command::GroupWriteCommand;
65pub use engine::GroupAckColdGcFuture;
66pub use engine::GroupAppendBatchFuture;
67pub use engine::GroupAppendBatchResponse;
68pub use engine::GroupAppendFuture;
69pub use engine::GroupBootstrapStreamFuture;
70pub use engine::GroupCloseStreamFuture;
71pub use engine::GroupColdHotBacklogFuture;
72pub use engine::GroupCreateStreamFuture;
73pub use engine::GroupDeleteSnapshotFuture;
74pub use engine::GroupDeleteStreamFuture;
75pub use engine::GroupEngine;
76pub use engine::GroupEngineCreateFuture;
77pub use engine::GroupEngineError;
78pub use engine::GroupEngineFactory;
79pub use engine::GroupEngineMetrics;
80pub use engine::GroupFlushColdFuture;
81pub use engine::GroupGetStreamAttrsFuture;
82pub use engine::GroupHeadStreamFuture;
83pub use engine::GroupInfraError;
84pub use engine::GroupInstallSnapshotFuture;
85pub use engine::GroupLeaderHint;
86pub use engine::GroupPlanColdFlushFuture;
87pub use engine::GroupPlanColdGcFuture;
88pub use engine::GroupPlanNextColdFlushBatchFuture;
89pub use engine::GroupPublishSnapshotFuture;
90pub use engine::GroupReadSnapshotFuture;
91pub use engine::GroupReadStreamFuture;
92pub use engine::GroupReadStreamPartsFuture;
93pub use engine::GroupRequireLiveReadOwnerFuture;
94pub use engine::GroupShutdownFuture;
95pub use engine::GroupSnapshotFuture;
96pub use engine::GroupTouchStreamAccessFuture;
97pub use engine::GroupUpdateStreamAttrsFuture;
98pub use engine::GroupWriteBatchFuture;
99pub use engine::GroupWriteFuture;
100pub use engine::GroupWriteResponse;
101pub use engine::in_memory::InMemoryGroupEngine;
102pub use engine::in_memory::InMemoryGroupEngineFactory;
103pub use error::ErrorStatus;
104pub use error::RuntimeError;
105pub use metrics::RuntimeMailboxSnapshot;
106pub use metrics::RuntimeMetrics;
107pub use metrics::RuntimeMetricsSnapshot;
108pub use request::AckColdGcResponse;
109pub use request::AppendBatchRequest;
110pub use request::AppendBatchResponse;
111pub use request::AppendExternalRequest;
112pub use request::AppendRequest;
113pub use request::AppendResponse;
114pub use request::BootstrapStreamRequest;
115pub use request::BootstrapStreamResponse;
116pub use request::BootstrapUpdate;
117pub use request::CloseStreamRequest;
118pub use request::CloseStreamResponse;
119pub use request::ColdHotBacklog;
120pub use request::ColdWriteAdmission;
121pub use request::CreateStreamExternalRequest;
122pub use request::CreateStreamRequest;
123pub use request::CreateStreamResponse;
124pub use request::DeleteSnapshotRequest;
125pub use request::DeleteStreamRequest;
126pub use request::DeleteStreamResponse;
127pub use request::FlushColdRequest;
128pub use request::FlushColdResponse;
129pub use request::GetStreamAttrsRequest;
130pub use request::GetStreamAttrsResponse;
131pub use request::GroupReadStreamBody;
132pub use request::GroupReadStreamParts;
133pub use request::HeadStreamRequest;
134pub use request::HeadStreamResponse;
135pub use request::PlanColdFlushRequest;
136pub use request::PlanGroupColdFlushRequest;
137pub use request::PublishSnapshotRequest;
138pub use request::PublishSnapshotResponse;
139pub use request::ReadSnapshotRequest;
140pub use request::ReadSnapshotResponse;
141pub use request::ReadStreamRequest;
142pub use request::ReadStreamResponse;
143pub use request::StreamAppendCount;
144pub use request::TouchStreamAccessResponse;
145pub use request::UpdateStreamAttrsRequest;
146pub use request::UpdateStreamAttrsResponse;
147pub use runtime::RuntimeConfig;
148pub use runtime::RuntimeThreading;
149pub use runtime::ShardRuntime;
150pub use snapshot_store::InlineSnapshotStore;
151#[cfg(not(madsim))]
152pub use snapshot_store::S3SnapshotStore;
153pub use snapshot_store::SharedSnapshotStore;
154pub use snapshot_store::SnapshotBytesIterator;
155pub use snapshot_store::SnapshotCompression;
156pub use snapshot_store::SnapshotKey;
157pub use snapshot_store::SnapshotLocation;
158pub use snapshot_store::SnapshotPointer;
159pub use snapshot_store::SnapshotStore;
160pub use snapshot_store::SnapshotStoreError;
161pub use snapshot_store::SnapshotStoreFuture;
162pub use snapshot_store::default_snapshot_store;
163pub use snapshot_store::snapshot_store_from_config;
164pub use ursula_config::config::ColdConfig;
165pub use ursula_stream::ColdChunkRef;
166pub use ursula_stream::ColdFlushCandidate;
167pub use ursula_stream::ColdGcEntry;
168pub use ursula_stream::ColdGcTarget;
169pub use ursula_stream::ExternalPayloadRef;
170pub use ursula_stream::ProducerRequest;
171pub use ursula_stream::StreamAttrs;
172pub use ursula_stream::StreamErrorCode;
173pub use ursula_stream::StreamErrorContext;
174pub use ursula_stream::StreamIntegritySnapshot;
175pub use ursula_stream::StreamRecordRange;
176
177#[cfg(test)]
178mod tests;
ursula_runtime/lib.rs

ursula_runtime/
lib.rs
