reddb-io-server 1.12.0

RedDB server-side engine: storage, runtime, replication, MCP, AI, and the gRPC/HTTP/RedWire/PG-wire dispatchers. Re-exported by the umbrella `reddb` crate.
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88

//! Shared cluster identity and membership model.

pub mod bootstrap_authority;
pub mod commit_resolution;
pub mod cross_range;
pub mod drain;
pub mod identity;
pub mod join;
pub mod membership;
pub mod move_range;
pub mod ownership;
pub mod ownership_force;
pub mod ownership_lease;
pub mod ownership_transition;
pub mod placement;
pub mod routing;
pub mod slot;
pub mod supervisor;
pub mod topology;

pub use bootstrap_authority::{
    authorize as authorize_cluster_bootstrap, authorize_vault_bootstrap, is_cluster_shaped,
    plan_vault_bootstrap, AuthBootstrapInput, BootstrapDisposition, VaultBootstrapPlan,
};
pub use commit_resolution::{
    is_local_ack, resolve_commit_policy, CollectionDataModel, CommitPolicyResolution,
    CommitPolicyViolation, FailoverEligibility, GuardrailDisposition, HaIntent, ResolutionSource,
};
pub use cross_range::{
    ConsistentReadLeg, ConsistentReadPlan, ConsistentReadReject, GlobalReadWatermark, KeyTarget,
    PinnedTarget, RangeParticipant, ReadFanout, ReadFanoutReject, ReadLeg, ResolvedTarget,
    WriteTransactionPlan, WriteTransactionReject, WriterParticipation,
};
pub use drain::{
    drain_status, plan_drain, plan_force_remove, run_drain, run_force_remove, DrainBlock,
    DrainBlockReason, DrainOutcome, DrainPlan, DrainStatus, DrainStep, ForceCapability,
    ForceRemoveAudit, ForceRemoveOrder, ForceRemoveOrderError, ForceRemovePlan, ForceRemoveResult,
    ForcedBlock, ForcedPromotion, OwnedHandoff, RemovalRejection, ReplicaEvacuation,
};
pub use identity::{
    ClusterVoterIdentity, NodeIdentity, NodeIdentityError, ReplicationPeerIdentity,
};
pub use join::{ControlPlaneSnapshot, JoinGrant, JoinRejection, JoinRequest, SeedAuthority};
pub use membership::{
    AdmissionOutcome, BaselineAssessment, ClusterId, ClusterIdError, ClusterMember, MemberKind,
    MemberState, MembershipCatalog, RESILIENT_DATA_MEMBER_BASELINE,
};
pub use move_range::{
    classify_move, recover_interrupted_move, split_range, MoveError, MoveKind, MovePhase,
    MoveRange, MoveRecovery, RangeSplit, SplitError, SplitPolicy, SplitSide,
};
pub use ownership::{
    CatalogError, CatalogVersion, CollectionId, CollectionIdError, OwnershipEpoch,
    PlacementMetadata, RangeBound, RangeBounds, RangeBoundsError, RangeId, RangeOwnership,
    RangeRole, RangeWriteReject, ShardKeyMode, ShardOwnershipCatalog, UpdateOutcome,
};
pub use ownership_force::{
    force_transition, EmptyOperatorReason, ForceDenial, ForceFailure, ForceTransitionCapability,
    ForcedTransitionAudit, ForcedTransitionDisposition, ForcedTransitionRequest, OperatorReason,
};
pub use ownership_lease::{
    admit_durable_write, DurableWriteReject, FenceReason, LeaseFenceRejection, LeasedOwner,
    OwnerWriteMode, OwnershipLease, RangeRequest, SupervisorTerm,
};
pub use ownership_transition::{
    prepare, run_transition, CatchUpEvidence, CommitWatermark, InvalidCandidateReason,
    PreparedTransition, TransitionError, TransitionKind, TransitionOutcome, TransitionRejection,
    TransitionRequest,
};
pub use placement::{
    HotspotRange, MemberCapacity, MoveReason, PlacementPolicy, PlacementSignals, PlannedMove,
    RangeLoad, RebalancePlan, WeightedPlacementPlanner, NEUTRAL_OPERATOR_WEIGHT,
};
pub use routing::{
    RedirectReason, RequestOperation, RouteDecision, RoutedRequest, RoutingHint, RoutingPolicy,
    DEFAULT_MAX_FORWARD_PAYLOAD,
};
pub use slot::{
    hash_shard_key_to_range_key, hash_shard_key_to_slot, HashSlot, HashSlotError,
    PRODUCTION_HASH_SLOT_COUNT,
};
pub use supervisor::{
    BlockedFailover, BlockedReason, ClusterSignals, ClusterSupervisor, FailoverPlan, HealthClass,
    HealthPolicy, HealthScore, MemberSignals, PlannedPromotion,
};
pub use topology::{
    ClientTopology, HintOutcome, RefreshOutcome, TopologyRange, TopologySnapshot, TopologyUpdate,
};