ursula 0.5.0-patch1

Ursula deployment binary: Durable Streams server, gateway, and event-time indexer.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

//! Process-level orchestration: typed-config `ShardRuntime` constructors and
//! raft-related background workers.
//!
//! This module is responsible for:
//! - validating configuration,
//! - constructing the [`ShardRuntime`]
//! - spawning raft-related background workers.
//!
//! Runtime internals (engine factories, cold-store handles, etc.) do not leak
//! here; they are assembled by the caller and passed to the builder.

mod cold_health;
mod commit_stall;
mod egress;
mod leadership;
mod runtime;
mod snapshot;
mod topology;
mod util;
mod wal_disk;

pub use runtime::SpawnedRuntime;
pub use runtime::spawn_runtime;
pub(crate) use runtime::spawn_runtime_with_maintenance_drain;
pub use topology::Persistence;
pub use topology::Topology;
pub(crate) use wal_disk::initialize_wal_disk_monitor;
pub(crate) use wal_disk::spawn_wal_disk_gate;

// Re-export test-visible internals so existing tests don't break.
#[allow(unused_imports)]
mod test_reexports {
    pub(crate) use super::cold_health::ColdHealthDecision;
    pub(crate) use super::cold_health::ColdHealthSample;
    pub(crate) use super::cold_health::ColdHealthTracker;
    pub(crate) use super::commit_stall::CommitStallAction;
    pub(crate) use super::commit_stall::CommitStallTracker;
    pub(crate) use super::egress::ClusterEgressProbeScope;
    pub(crate) use super::egress::ClusterEgressShedAction;
    pub(crate) use super::egress::cluster_egress_probe_groups;
    pub(crate) use super::egress::plan_cluster_egress_shed;
    pub(crate) use super::egress::spawn_egress_gate;
    pub(crate) use super::leadership::LeadershipBalanceAction;
    pub(crate) use super::leadership::plan_leadership_balance;
    pub(crate) use super::leadership::plan_leadership_balance_with_eligible_nodes;
    pub(crate) use super::snapshot::next_snapshot_to_drive;
    pub(crate) use super::snapshot::pressure_snapshot_groups;
    pub(crate) use super::snapshot::resolve_snapshot_drive_interval_ms;
    pub(crate) use super::snapshot::should_drive_snapshot_for_group;
    pub(crate) use super::snapshot::unpurged_log_entries;
    pub(crate) use super::util::leader_counts;
    pub(crate) use super::util::prioritized_transfer_targets;
}
#[allow(unused_imports)]
pub(crate) use test_reexports::*;