Trait KitsuneHandler 

pub trait KitsuneHandler:
    'static
    + Send
    + Sync
    + Debug {
    // Required method
    fn create_space(
        &self,
        space_id: SpaceId,
        config_override: Option<&Config>,
    ) -> BoxFut<'_, K2Result<DynSpaceHandler>>;

    // Provided methods
    fn new_listening_address(&self, this_url: Url) -> BoxFut<'static, ()> { ... }
    fn peer_disconnect(&self, peer: Url, reason: Option<String>) { ... }
    fn preflight_gather_outgoing(
        &self,
        peer_url: Url,
    ) -> BoxFut<'_, K2Result<Bytes>> { ... }
    fn preflight_validate_incoming(
        &self,
        peer_url: Url,
        data: Bytes,
    ) -> BoxFut<'_, K2Result<()>> { ... }
}

Handler for events coming out of Kitsune2.

Required Methods

fn create_space( &self, space_id: SpaceId, config_override: Option<&Config>, ) -> BoxFut<'_, K2Result<DynSpaceHandler>>

Creates a space handler for the given space.

Optionally, override configuration values for this space.

Provided Methods

fn new_listening_address(&self, this_url: Url) -> BoxFut<'static, ()>

A notification that a new listening address has been bound. Peers should now go to this new address to reach this node.

fn peer_disconnect(&self, peer: Url, reason: Option<String>)

A peer has disconnected from us. If they did so gracefully the reason will be is_some().

fn preflight_gather_outgoing( &self, peer_url: Url, ) -> BoxFut<'_, K2Result<Bytes>>

Gather preflight data to send to a new opening connection. Returning an Err result will close this connection.

The default implementation sends an empty preflight message.

fn preflight_validate_incoming( &self, peer_url: Url, data: Bytes, ) -> BoxFut<'_, K2Result<()>>

Validate preflight data sent by a remote peer on a new connection. Returning an Err result will close this connection.

The default implementation ignores the preflight data, and considers it valid.

Implementors