mielin-cells 0.1.0-rc.1

Agent SDK providing agent lifecycle management, policy execution, and inter-agent communication
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

//! High Availability Module
//!
//! Provides high availability features for agent management including:
//! - Leader election for coordination
//! - Automatic failover mechanisms
//! - State replication across nodes
//! - Quorum-based decision making
//! - Health monitoring for clusters

pub mod failover;
pub mod health;
pub mod leader;
pub mod quorum;
pub mod replication;

pub use failover::{
    FailoverConfig, FailoverCoordinator, FailoverDecision, FailoverError, FailoverEvent,
    FailoverPolicy, FailoverResult, FailoverState, FailoverStrategy,
};
pub use health::{
    ClusterHealth, ClusterHealthMonitor, HealthConfig, HealthMetric, HealthStatus, HealthThreshold,
    NodeHealth,
};
pub use leader::{
    LeaderElection, LeaderElector, LeaderError, LeaderState, LeaderTerm, NodeId, VoteRequest,
    VoteResponse,
};
pub use quorum::{
    QuorumConfig, QuorumDecision, QuorumError, QuorumPolicy, QuorumResult, QuorumVote, QuorumVoter,
};
pub use replication::{
    ReplicationConfig, ReplicationError, ReplicationLog, ReplicationManager, ReplicationState,
    ReplicationStrategy, StateReplica,
};

use thiserror::Error;

#[derive(Debug, Error)]
pub enum HAError {
    #[error("Leader election failed: {0}")]
    LeaderElectionFailed(String),
    #[error("Failover failed: {0}")]
    FailoverFailed(String),
    #[error("Replication failed: {0}")]
    ReplicationFailed(String),
    #[error("Quorum not reached: {0}")]
    QuorumNotReached(String),
    #[error("Health check failed: {0}")]
    HealthCheckFailed(String),
}