asupersync 0.3.6

Spec-first, cancel-correct, capability-secure async runtime for Rust.
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

//! Distributed region encoding, symbol distribution, recovery, and consensus.
//!
//! This module implements encoding of distributed region state into
//! RaptorQ symbols, their distribution to replicas, and recovery of
//! region state from collected symbols. It builds on the state model
//! from [`crate::record::distributed_region`] and the symbol types
//! from [`crate::types::symbol`].
//!
//! Additionally provides Byzantine fault tolerant consensus algorithms
//! for distributed coordination with safety guarantees even under
//! malicious replica behavior.
//!
//! # Modules
//!
//! - [`snapshot`]: Serializable region state snapshots
//! - [`encoding`]: RaptorQ encoding pipeline for snapshots
//! - [`assignment`]: Symbol-to-replica assignment strategies
//! - [`consistent_hash`]: Deterministic consistent hash ring
//! - [`distribution`]: Quorum-based symbol distribution
//! - [`recovery`]: Region recovery protocol
//! - [`bridge`]: Local-to-distributed region bridge
//! - [`consensus`]: Byzantine fault tolerant consensus algorithms
//! - [`membership`]: SWIM-style cluster membership and failure detection

pub mod adaptive_layout;
pub mod anti_entropy;
pub mod assignment;
pub mod bridge;
pub mod computation_schema;
pub mod consensus;
pub mod consistent_hash;
pub mod distribution;
pub mod encoding;
pub mod membership;
pub mod recovery;
pub mod snapshot;

pub use adaptive_layout::{AdaptiveLayoutConfig, BlockLayoutChoice, PathQuality};
pub use anti_entropy::{DiffKind, DiffReport, KeyDiff, MerkleRangeTree};
pub use assignment::{AssignmentStrategy, ReplicaAssignment, SymbolAssigner};
pub use bridge::{
    BridgeConfig, CloseResult, ConflictResolution, DistributedToLocal, EffectiveState,
    LocalToDistributed, RegionBridge, RegionMode, SyncMode, SyncResult, SyncState, UpgradeResult,
};
pub use computation_schema::{
    ComputationSchemaRegistry, ComputationSchemaRegistryError, HasSchema,
    RegisteredComputationSchema, SchemaDescriptor, SchemaFingerprint, SchemaMismatch,
    SchemaMismatchKind,
};
pub use consensus::{
    ConsensusBatch, ConsensusError, ConsensusRequest, ConsensusResponse, MessageDigest, PbftConfig,
    PbftConsensus, PbftNode, PbftState, PhaseKind, ReplicaId, SequenceNumber, ViewNumber,
};
pub use consistent_hash::{BoundedLoadConfig, BoundedLoadDecision, BoundedLoadFallback, HashRing};
pub use distribution::{
    DistributionConfig, DistributionMetrics, DistributionResult, ReplicaAck, ReplicaFailure,
    SymbolDistributor,
};
pub use encoding::{
    ADAPTIVE_BLOCK_LAYOUT_POLICY_ID, EncodedState, EncodingConfig, EncodingError,
    EncodingLayoutDecision, PathQualitySnapshot, STATIC_BLOCK_LAYOUT_POLICY_ID, StateEncoder,
};
pub use membership::{
    MemberState, MembershipEvent, MembershipKind, Swim, SwimConfig, SwimConfigError,
};
pub use recovery::{
    CollectedSymbol, CollectionConsistency, CollectionMetrics, RecoveryCollector, RecoveryConfig,
    RecoveryDecodingConfig, RecoveryOrchestrator, RecoveryPhase, RecoveryProgress, RecoveryResult,
    RecoveryTrigger, StateDecoder,
};
pub use snapshot::{BudgetSnapshot, RegionSnapshot, SnapshotError, TaskSnapshot, TaskState};

#[cfg(test)]
mod tests;