Struct ClientRawFederationApi

pub struct ClientRawFederationApi<I> {
    inner: I,
    db: Database,
    log_ordering_wakeup_tx: Sender<()>,
}

A wrapper over IRawFederationApi adding client side event logging

Create using ClientRawFederationApiExt::with_client_ext

Fields

inner: I

db: Database

log_ordering_wakeup_tx: Sender<()>

Implementations

impl<I> ClientRawFederationApi<I>

pub async fn log_event<E>(&self, event: E)

where E: Event + Send,

pub async fn log_event_dbtx<E, Cap>( &self, dbtx: &mut DatabaseTransaction<'_, Cap>, event: E, )

where E: Event + Send, Cap: Send,

Trait Implementations

impl<I: Debug> Debug for ClientRawFederationApi<I>

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

Formats the value using the given formatter.

impl<I> IRawFederationApi for ClientRawFederationApi<I>

where I: IRawFederationApi,

fn all_peers(&self) -> &BTreeSet<PeerId>

List of all federation peers for the purpose of iterating each peer in the federation.

fn self_peer(&self) -> Option<PeerId>

PeerId of the Guardian node, if set

fn with_module(&self, id: ModuleInstanceId) -> DynModuleApi

fn request_raw<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, peer_id: PeerId, method: &'life1 str, params: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = Result<Value, JsonRpcClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Make request to a specific federation peer by peer_id