Struct PeerRpcClient 

pub struct PeerRpcClient<T, I> { /* private fields */ }

Authenticated client for stable peer query, command, and diagnostic endpoints.

Implementations

impl<T, I> PeerRpcClient<T, I>

where T: PeerTransportProvider, I: PeerRpcTokenIssuer,

pub fn new( source_identity: CoreIdentity, config: PeerRpcClientConfig, transport: T, token_issuer: I, ) -> Self

Creates an authenticated peer RPC client.

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

Replaces the shared cancellation token used by I/O and retry waits.

pub fn cancel(&self)

Cancels active official transport I/O and future retries.

pub fn is_cancelled(&self) -> bool

Reports whether this client has been cancelled.

pub fn query( &self, endpoint_url: &str, request: PeerRpcOutboundRequest, ) -> Result<PeerRpcResponse, PeerRpcError>

Executes a peer query.

pub fn command( &self, endpoint_url: &str, request: PeerRpcOutboundRequest, ) -> Result<PeerRpcResponse, PeerRpcError>

Executes a peer command.

pub fn health( &self, endpoint_url: &str, ) -> Result<PeerHealthResponse, PeerRpcError>

Reads the authenticated peer health endpoint.

pub fn advertisement( &self, endpoint_url: &str, ) -> Result<PeerAdvertisementV1, PeerRpcError>

Reads and returns the authenticated peer runtime manifest. Loads the versioned public advertisement exposed by a peer.

Trait Implementations

impl<T, I> PeerRpcClientExecutor for PeerRpcClient<T, I>

where T: PeerTransportProvider, I: PeerRpcTokenIssuer,

fn call_peer( &self, endpoint_url: &str, kind: PeerRpcCallKind, request: PeerRpcOutboundRequest, ) -> Result<PeerRpcResponse, PeerRpcError>

Executes one query or command against endpoint_url.