Struct AdminRpcImpl 

pub struct AdminRpcImpl { /* private fields */ }

Concrete server implementation backed by the live AdminState.

Implementations

impl AdminRpcImpl

pub const fn new(state: AdminState) -> Self

Serve the admin RPC methods against state.

Trait Implementations

impl AdminRpcServer for AdminRpcImpl

fn health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RpcResult<HealthResponse>> + Send + 'async_trait>>

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

Return this node’s identity and process uptime.

fn evict<'life0, 'async_trait>( &'life0 self, req: EvictRequest, ) -> Pin<Box<dyn Future<Output = RpcResult<EvictResponse>> + Send + 'async_trait>>

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

Evict a single blob from the local cache (issue #279). The eviction is logical: the iroh-blobs store still holds the bytes (Blobs::delete is pub(crate) in iroh-blobs and reserved for the GC task) until the next periodic GC sweep reclaims them (#518). The takedown itself is persisted to <cache_dir>/evicted.log so it survives a restart even when the next sweep hasn’t run yet.

fn reload<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RpcResult<ReloadResponse>> + Send + 'async_trait>>

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

Re-read the config file the node was started with and apply the reloadable subset (issue #373) — the same path SIGHUP triggers, exposed over the loopback admin surface for operators who want scripted control without kill -HUP. Both paths share the same RuntimeReloadState::reload, whose internal mutexes serialise concurrent reloads, so a SIGHUP racing this RPC waits behind it rather than corrupting state. Returns:

fn drain<'life0, 'async_trait>( &'life0 self, req: DrainRequest, ) -> Pin<Box<dyn Future<Output = RpcResult<DrainResponse>> + Send + 'async_trait>>

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

Trigger graceful shutdown via the same path SIGTERM exercises (issue #244, appendix-local-admin-http.md). Stops the iroh router’s accept loop and awaits in-flight ProtocolHandler::shutdown calls; the subsequent task drain is bounded by the runtime’s 15s SHUTDOWN_DEADLINE (the router-shutdown step itself is unbounded — a stuck handler hangs the runtime, only the post-router task join is timeout-gated).

fn status<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RpcResult<StatusResponse>> + Send + 'async_trait>>

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

Return a snapshot of this node’s DHT participation health (issue #741): routing-table bucket fill rates, the network-wide last bucket-refresh timestamp, active-staker count, provider-record store utilization, and republish-scheduler depth. Intended for decdn node status, giving operators a single human-readable (or --json) view to diagnose cold-start or routing-table degradation without scraping Prometheus. Returns DHT_UNAVAILABLE_CODE when the DHT subsystem is not wired on this node.

fn lanes<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RpcResult<LanesResponse>> + Send + 'async_trait>>

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

Return a live snapshot of every lane this node provides against a PaymentPool (issue #749): per lane the outstanding accrued claim, time since the last voucher (in-memory, None after a restart until the next voucher), and whether the accrued claim has reached the redemption threshold. Backs decdn node lanes, giving operators a single view to spot lanes approaching settlement, stale lanes, or unusually high outstanding balances before they become a liquidity risk — without scraping metrics or logs. Returns POOL_STORE_ERROR_CODE if the pool state store cannot be read.

fn slashes<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RpcResult<SlashesResponse>> + Send + 'async_trait>>

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

Return every slash the node’s watcher has detected against its own operator (#1032, G-NODE-05): per slash the slashId, offense type, amount, evidence digest, block, and the 30-day appeal-window close time. Consumed directly by operators/keepers (no CLI subcommand wraps it) so they notice a slash and file decdn appeal slash in time. Returns SLASH_DETECTION_UNAVAILABLE_CODE when the slash watcher is not wired on this node.

fn pools<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RpcResult<BuyerPoolsResponse>> + Send + 'async_trait>>

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

Return the node’s buyer-side PaymentPool state: every pool its buyer leg tracks, the deposit it believes each holds, and the per-lane spend watermark it has signed against each provider.

fn into_rpc(self) -> RpcModule<Self>

Collects all the methods and subscriptions defined in the trait and adds them into a single RpcModule.

impl Clone for AdminRpcImpl

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdminRpcImpl

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

Formats the value using the given formatter.