kitsune2_api

Trait TxSpaceHandler

Source 
pub trait TxSpaceHandler: TxBaseHandler {
    // Provided methods
    fn recv_space_notify(
        &self,
        peer: Url,
        space: SpaceId,
        data: Bytes,
    ) -> K2Result<()> { ... }
    fn set_unresponsive(
        &self,
        peer: Url,
        when: Timestamp,
    ) -> BoxFut<'_, K2Result<()>> { ... }
}
Expand description

Handler for space-related events.

Provided Methods§

Source

fn recv_space_notify( &self, peer: Url, space: SpaceId, data: Bytes, ) -> K2Result<()>

The sync handler for receiving notifications sent by a remote peer in reference to a particular space. If this callback returns an error, then the connection which sent the message will be closed.

Source

fn set_unresponsive( &self, peer: Url, when: Timestamp, ) -> BoxFut<'_, K2Result<()>>

Mark a peer as unresponsive in the space’s peer meta store

Implementors§