Struct ZakuraProtocolHandler 

pub struct ZakuraProtocolHandler { /* private fields */ }

Iroh protocol handler for the Zakura p2p-v2/1 ALPN.

Implementations

impl ZakuraProtocolHandler

pub fn new( supervisor: ZakuraSupervisorHandle, network: Network, handshake_config: ZakuraHandshakeConfig, limits: ZakuraLocalLimits, ) -> Self

Create a handler sharing the given supervisor.

pub fn new_with_registry( supervisor: ZakuraSupervisorHandle, network: Network, handshake_config: ZakuraHandshakeConfig, limits: ZakuraLocalLimits, registry: Arc<ServiceRegistry>, ) -> Self

Create a handler with an injected service registry.

pub fn new_with_registry_and_trace( supervisor: ZakuraSupervisorHandle, _network: Network, handshake_config: ZakuraHandshakeConfig, limits: ZakuraLocalLimits, registry: Arc<ServiceRegistry>, trace: ZakuraTrace, ) -> Self

Create a handler with an injected service registry and trace emitter.

pub fn with_endpoint(self, endpoint: Endpoint) -> Self

Attach the bound iroh endpoint so inbound Router-accepted connections can resolve the peer’s UDP source IP and enforce the per-IP connection cap.

Trait Implementations

impl Clone for ZakuraProtocolHandler

fn clone(&self) -> ZakuraProtocolHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ZakuraProtocolHandler

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

Formats the value using the given formatter.

impl ProtocolHandler for ZakuraProtocolHandler

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

Handle an incoming connection.

async fn shutdown(&self)

Called when the router shuts down.

fn on_connecting( &self, connecting: Connecting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Connecting state.