appcore-control-plane 1.0.0

Generic control-plane contracts for distributed AppCore deployments.
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

// =============================================================================
//        #######
//     ###       ###     F: lib.rs
//    ##   ## ##   ##    P: AppCore-Runtime
//         ## ##
//                       C: 2026/07/20 23:03:47 by dnettoRaw
//    ##   ## ##   ##    U: 2026/07/24 16:07:49 by dnettoRaw
//      ###########      S: 1.0.1-rc.8
// =============================================================================

//! Generic control-plane contracts for distributed AppCore deployments.
//!
//! The control plane stores presence, leases, and routing metadata. It must not
//! transport business payloads or contain tenant-specific business rules.

#![deny(missing_docs)]

use appcore_contracts::ServiceId;
use appcore_core::{
    ClusterId, CoreId, CoreIdentity, RuntimeOperationalMode, TenantId, TraceContext,
};
use appcore_distributed_contracts::control_plane::v1::{
    EmptyResponse, ServiceLeaseRequest, CONTROL_HEARTBEAT_PATH, CONTROL_PEERS_PATH,
    CONTROL_REGISTER_PATH, CONTROL_SERVICE_LEASE_PATH, CONTROL_SERVICE_LEASE_RELEASE_PATH,
};
pub use appcore_transport::CancellationToken;
use serde::{Deserialize, Serialize};
use std::collections::BTreeMap;
use std::future::Future;
use std::pin::Pin;
use std::sync::{mpsc, Arc, Mutex};
use std::task::{Context, Poll, Waker};
use std::thread;
use std::time::Duration;

/// Stable control-plane wire and provider contracts.
pub mod v1 {
    pub use appcore_distributed_contracts::control_plane::v1::*;
}

pub use v1::{
    ControlPlaneError, ControlPlaneFuture, ControlPlaneProvider, ControlPlaneResult, CorePresence,
    CoreRegistration, DiscoveryProvider, HeartbeatRequest, HeartbeatResponse, LeadershipDecision,
    PeerDirectory, PeerRecord, ServiceLeaderLease, ServiceLeadershipGuard,
};

const DEFAULT_MAX_HTTP_RESPONSE_BYTES: usize = 1_048_576;
const MAX_HTTP_HEADER_BYTES: usize = 32_768;
const MAX_CONTROL_PLANE_WORK_ITEMS: usize = 64;

mod client;
mod coordinator;
mod file;
mod leadership;
mod memory;
mod offline;
mod transport;
mod worker;

pub use client::{
    ControlPlaneHttpConfig, HttpControlPlaneClient, HttpControlPlaneRequest,
    HttpControlPlaneResponse, HttpTransport, RetryPolicy,
};
pub use coordinator::{ControlPlaneCoordinator, HeartbeatPolicy};
pub use file::FileControlPlane;
pub use leadership::StaticServiceLeadershipGuard;
pub use memory::InMemoryControlPlane;
pub use offline::OfflineControlPlaneClient;
pub use transport::{
    require_secure_remote_endpoint, BearerHttpTransport, SecretString, StdHttpTransport,
};

#[cfg(test)]
mod tests;