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
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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123

//! Mielin Cells - Agent SDK
//!
//! Provides agent definition, lifecycle management, policy execution,
//! and inter-agent communication.

pub mod agent;
pub mod compliance;
pub mod composition;
pub mod debug;
pub mod discovery;
pub mod dna;
pub mod dr;
pub mod group;
pub mod ha;
pub mod history;
pub mod messaging;
pub mod migration;
pub mod multiregion;
pub mod orchestration;
pub mod policy;
pub mod pool;
pub mod resource;
pub mod security;
pub mod template;
pub mod versioning;

pub use agent::{
    Agent, AgentError, AgentId, AgentState, StateTransition, TransitionHook, TransitionResult,
};
pub use compliance::{
    AuditEntry, AuditLogger, AuditQuery, CompliancePolicy, ComplianceReport, DataClassification,
    EventType, PolicyChecker, PolicyViolation, PrivacyConfig, PrivacyControl, PrivacyManager,
    ReportGenerator, ReportType, RetentionPolicy,
};
pub use composition::{
    Behavior, BehaviorComposite, BehaviorContext, BehaviorId, BehaviorRegistry, BehaviorResult,
    ClosureBehavior, HealthCheckBehavior, LoggingBehavior, MetricsBehavior,
};
pub use debug::{
    Breakpoint, DebugCommand, DebugContext, DebugSession, DebuggerConfig, ExecutionTracer,
    InspectionQuery, InspectionResult, MemoryProfiler, RemoteDebugger, StateInspector, TraceEvent,
    TraceFilter, WatchExpression,
};
pub use discovery::{
    Capability, DiscoveryError, DiscoveryQuery, DiscoveryResult, HealthCheck,
    HealthStatus as DiscoveryHealthStatus, LoadBalancer, LoadBalancingStrategy,
    Location as DiscoveryLocation, ServiceRegistration, ServiceRegistry,
};
pub use dna::Dna;
pub use dr::{
    Backup, BackupConfig, BackupManager, BackupSchedule, BackupScheduler, BackupStrategy,
    BackupType, RecoveryConfig, RecoveryManager, RecoveryPlan, RecoveryPoint, RecoveryStrategy,
    RecoveryTarget, VerificationConfig, Verifier,
};
pub use group::{
    AgentGroup, GroupConfig, GroupCoordinator, GroupError, GroupId, GroupMember, GroupRegistry,
    GroupResult, GroupRole, GroupState,
};
pub use ha::{
    ClusterHealth, ClusterHealthMonitor, FailoverConfig, FailoverCoordinator, FailoverDecision,
    FailoverEvent, FailoverPolicy, FailoverState, FailoverStrategy, HealthConfig as HAHealthConfig,
    HealthMetric, HealthStatus as HAHealthStatus, HealthThreshold, LeaderElection, LeaderElector,
    LeaderState, NodeHealth, QuorumConfig, QuorumDecision, QuorumPolicy, QuorumVote, QuorumVoter,
    ReplicationConfig, ReplicationManager, ReplicationState, ReplicationStrategy, StateReplica,
    VoteRequest, VoteResponse,
};
pub use history::{
    AgentHistory, HistoryConfig as HistoryTrackerConfig, HistoryTracker, StateHistoryEntry,
    StateStatistics,
};
pub use messaging::{Mailbox, Message, MessageBus, MessagingError, Priority, Topic};
pub use multiregion::{
    CrossRegionSync, GeoRouter, LatencyMap, Region, RegionConfig, RegionDeployment, RegionManager,
    RegionStatus, RouteDecision, RoutingPolicy, RoutingStrategy, SyncConfig, SyncManager,
    SyncStatus,
};
pub use orchestration::{
    Deployment, DeploymentSpec, DeploymentStatus, DeploymentStrategy, Node, OrchestrationError,
    Orchestrator, PlacementConstraint, ResourceRequirements, ScalingPolicy, Scheduler,
};
pub use policy::Policy;
pub use pool::{AgentPool, PoolConfig, PoolStats};
pub use resource::{
    Anomaly, AnomalyConfig, AnomalyDetector, AnomalyType, HistoryConfig, MonitorSummary,
    QuotaEnforcer, QuotaViolation, ResourceHistory, ResourceManager, ResourceMonitor,
    ResourcePrediction, ResourcePredictor, ResourceQuota, ResourceRate, ResourceSnapshot,
    ResourceUsage,
};
pub use security::{
    AgentIdentity, AttestationValidator, AuthChallenge, AuthResponse, AuthToken, Authenticator,
    Capability as SecurityCapability, CapabilityAttestation, EncryptedSnapshot, EncryptionKey,
    IdentityProvider, PublicIdentity, SandboxConfig, SandboxExecutor, SandboxViolation,
    SecurityContext, StateEncryptor,
};
pub use template::{AgentTemplate, TemplateBuilder, TemplateError, TemplateId, TemplateRegistry};
pub use versioning::{
    ABTestConfig, ABTestDeployment, ABTestStats, CanaryConfig, CanaryDeployment, CanaryStats,
    RollingUpdateConfig, RollingUpdateStrategy, Version, VersionDeployer, VersionError,
    VersionMetadata, VersionRegistry,
};

use thiserror::Error;

#[derive(Debug, Error)]
pub enum CellError {
    #[error("Agent execution failed: {0}")]
    ExecutionFailed(String),
    #[error("Migration failed: {0}")]
    MigrationFailed(String),
    #[error("Invalid state: {0}")]
    InvalidState(String),
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_agent_creation() {
        let agent = Agent::new(vec![0x00, 0x61, 0x73, 0x6d]);
        assert!(agent.id().as_bytes().len() == 16);
    }
}