Struct Hc2ClientPlaneService 

pub struct Hc2ClientPlaneService { /* private fields */ }

Production gRPC service. Construction requires existing verified dispatch state.

Implementations

impl Hc2ClientPlaneService

pub fn new( state: Arc<ClientSurfaceState>, cluster_id: impl Into<String>, ) -> Self

Construct a service over the shared HC/1/RESP dispatch state.

pub fn accounting(&self) -> Hc2AccountingSnapshot

Return bounded, secret-free listener accounting.

pub fn prometheus_metrics(&self) -> String

Render the production listener’s bounded aggregate accounting for the existing internal Prometheus endpoint.

The only label has a closed domain. Peer identities, tenant IDs, authorities, certificate material, keys, and values are never exposed.

Trait Implementations

impl ClientPlaneAlpha for Hc2ClientPlaneService

type OpenStream = Pin<Box<dyn Stream<Item = Result<ServerEnvelope, Status>> + Send>>

Server streaming response type for the Open method.

fn open<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<ClientEnvelope>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::OpenStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl Clone for Hc2ClientPlaneService

fn clone(&self) -> Hc2ClientPlaneService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Hc2ClientPlaneService

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

Formats the value using the given formatter.