Struct OfflineControlPlaneClient 

pub struct OfflineControlPlaneClient;

Client that explicitly reports the control plane as unavailable.

Trait Implementations

impl Clone for OfflineControlPlaneClient

fn clone(&self) -> OfflineControlPlaneClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ControlPlaneProvider for OfflineControlPlaneClient

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, _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 Copy for OfflineControlPlaneClient

impl Debug for OfflineControlPlaneClient

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

Formats the value using the given formatter.

impl Default for OfflineControlPlaneClient

fn default() -> OfflineControlPlaneClient

Returns the “default value” for a type.