Struct ProbeHandler 

pub struct ProbeHandler { /* private fields */ }

Serves cdn/probe/v1: reads a framed ProbeMessage::Request, writes a framed ProbeMessage::Response.

rate_per_mb is the served price, fixed at startup. Reprice by restarting the daemon (see runtime::reload::warn_restart_required_sections).

Implementations

impl ProbeHandler

pub const ALPN: &'static [u8] = ALPN_PROBE

The ALPN this handler answers on: cdn/probe/v1, the unauthenticated latency and availability probe.

pub fn new( node_id: PublicKey, rate_per_mb: u64, metrics: Arc<Metrics>, limiter: Arc<ConnectionLimiter>, probe_rate_limiter: Arc<ProbeRateLimiter>, cache: CacheEngine, eth_signer: Arc<PrivateKeySigner>, slash_domain: Eip712Domain, stake_lane: Option<StakeLanePolicy>, relay_foreign_namespaces: bool, chain_freshness: Option<ChainFreshness>, ) -> Self

Build the probe handler from the runtime state it answers out of: the node’s identity and advertised rate, the rate limiters that gate an unauthenticated caller, and the signer that attests each response.

Trait Implementations

impl Debug for ProbeHandler

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

Formats the value using the given formatter.

impl ProtocolHandler for ProbeHandler

async fn accept(&self, connection: Connection) -> Result<(), AcceptError>

Handle an incoming connection.

fn on_accepting( &self, accepting: Accepting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Accepting state.

fn shutdown(&self) -> impl Future<Output = ()> + Send

Called when the router shuts down.