Struct InMemoryControlPlane 

pub struct InMemoryControlPlane { /* private fields */ }

Deterministic in-memory control plane for embedded hosts and tests.

Implementations

impl InMemoryControlPlane

pub fn registrations_len(&self) -> ControlPlaneResult<usize>

Returns the number of registered runtime instances.

Trait Implementations

impl Clone for InMemoryControlPlane

fn clone(&self) -> InMemoryControlPlane

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ControlPlaneProvider for InMemoryControlPlane

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 Debug for InMemoryControlPlane

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

Formats the value using the given formatter.

impl Default for InMemoryControlPlane

fn default() -> InMemoryControlPlane

Returns the “default value” for a type.