Struct HttpControlPlaneClient 

pub struct HttpControlPlaneClient<T> { /* private fields */ }

Control-plane client that maps stable contracts onto an HTTP transport.

Implementations

impl<T> HttpControlPlaneClient<T>

where T: HttpTransport,

pub fn new(config: ControlPlaneHttpConfig, transport: T) -> Self

Creates an HTTP client with a dedicated bounded worker queue.

pub fn with_cancellation_token(self, cancellation: CancellationToken) -> Self

Replaces the shared cancellation token used by requests and retries.

pub fn cancel(&self)

Cancels queued requests, active official transport I/O, and retry waits.

pub fn is_cancelled(&self) -> bool

Reports whether this client has been cancelled.

Trait Implementations

impl<T> Clone for HttpControlPlaneClient<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> ControlPlaneProvider for HttpControlPlaneClient<T>

where T: HttpTransport + 'static,

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>, ) -> ControlPlaneFuture<'a, CorePresence>

Registers a core while propagating trace context when supported.

fn heartbeat_traced<'a>( &'a self, request: HeartbeatRequest, trace: Option<&'a TraceContext>, ) -> ControlPlaneFuture<'a, HeartbeatResponse>

Sends a heartbeat while propagating trace context when supported.

fn discover_peers_traced<'a>( &'a self, identity: &'a CoreIdentity, trace: Option<&'a TraceContext>, ) -> ControlPlaneFuture<'a, PeerDirectory>

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>, ) -> ControlPlaneFuture<'a, ServiceLeaderLease>

Acquires a service lease while propagating trace context when supported.

fn release_service_lease_traced<'a>( &'a self, lease: ServiceLeaderLease, trace: Option<&'a TraceContext>, ) -> ControlPlaneFuture<'a, ()>

Releases a service lease while propagating trace context when supported.

impl<T: Debug> Debug for HttpControlPlaneClient<T>

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

Formats the value using the given formatter.