Struct FileControlPlane 

pub struct FileControlPlane { /* private fields */ }

Durable control-plane implementation for one shared deployment directory.

Every operation takes an operating-system file lock, reloads validated state, applies one contract operation, and atomically persists the result. The deployment directory is the authentication and isolation boundary and is created with owner-only permissions on Unix.

Implementations

impl FileControlPlane

pub fn open( root: impl Into<PathBuf>, retention_ms: u64, ) -> ControlPlaneResult<Self>

Opens or creates a durable reference control plane.

pub fn with_clock( root: impl Into<PathBuf>, retention_ms: u64, clock: Arc<dyn Clock>, ) -> ControlPlaneResult<Self>

Opens a control plane using an explicit authoritative server clock.

pub fn state_path(&self) -> &Path

Returns the durable state path.

pub fn retention_ms(&self) -> u64

Returns the presence retention window in milliseconds.

pub fn backup_to(&self, destination: impl AsRef<Path>) -> ControlPlaneResult<()>

Creates an integrity-validated point-in-time state backup.

pub fn restore_from(&self, source: impl AsRef<Path>) -> ControlPlaneResult<()>

Replaces state from a validated backup.

Trait Implementations

impl Clone for FileControlPlane

fn clone(&self) -> FileControlPlane

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ControlPlaneProvider for FileControlPlane

fn register<'a>( &'a self, registration: CoreRegistration, ) -> ControlPlaneFuture<'a, CorePresence>

Registers a running core.

fn heartbeat<'a>( &'a self, request: HeartbeatRequest, ) -> ControlPlaneFuture<'a, HeartbeatResponse>

Reports liveness and current mode.

fn discover_peers<'a>( &'a self, identity: &'a CoreIdentity, ) -> ControlPlaneFuture<'a, PeerDirectory>

Discovers compatible peers.

fn acquire_or_renew_service_lease<'a>( &'a self, identity: &'a CoreIdentity, service_id: &'a ServiceId, ttl_ms: u64, _client_now_ms: u64, ) -> ControlPlaneFuture<'a, ServiceLeaderLease>

Acquires or renews leadership independently for one service.

fn release_service_lease<'a>( &'a self, lease: ServiceLeaderLease, ) -> ControlPlaneFuture<'a, ()>

Releases leadership for one service.

fn register_traced<'a>( &'a self, registration: CoreRegistration, _trace: Option<&'a TraceContext>, ) -> Pin<Box<dyn Future<Output = Result<CorePresence, ControlPlaneError>> + Send + 'a>>

Registers a core while propagating trace context when supported.

fn heartbeat_traced<'a>( &'a self, request: HeartbeatRequest, _trace: Option<&'a TraceContext>, ) -> Pin<Box<dyn Future<Output = Result<HeartbeatResponse, ControlPlaneError>> + Send + 'a>>

Sends a heartbeat while propagating trace context when supported.

fn discover_peers_traced<'a>( &'a self, identity: &'a CoreIdentity, _trace: Option<&'a TraceContext>, ) -> Pin<Box<dyn Future<Output = Result<PeerDirectory, ControlPlaneError>> + Send + 'a>>

Discovers peers while propagating trace context when supported.

fn acquire_or_renew_service_lease_traced<'a>( &'a self, identity: &'a CoreIdentity, service_id: &'a ServiceId, ttl_ms: u64, now_ms: u64, _trace: Option<&'a TraceContext>, ) -> Pin<Box<dyn Future<Output = Result<ServiceLeaderLease, ControlPlaneError>> + Send + 'a>>

Acquires a service lease while propagating trace context when supported.

fn release_service_lease_traced<'a>( &'a self, lease: ServiceLeaderLease, _trace: Option<&'a TraceContext>, ) -> Pin<Box<dyn Future<Output = Result<(), ControlPlaneError>> + Send + 'a>>

Releases a service lease while propagating trace context when supported.

impl Debug for FileControlPlane

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.