Struct Monitor

pub struct Monitor {
    event_emitter: Arc<EventEmitter<MonitorTopic>>,
    config: Arc<Config>,
}

Responsible for network and system monitoring.

It use event emitter to notify the registerd listeners about new events.

Example

use std::sync::Arc;

use smol::Executor;

use karyon_p2p::{
    Config, Backend, PeerID, keypair::{KeyPair, KeyPairType}, monitor::ConnectionEvent,
};

async {
     
    // Create a new Executor
    let ex = Arc::new(Executor::new());

    let key_pair = KeyPair::generate(&KeyPairType::Ed25519);
    let backend = Backend::new(&key_pair, Config::default(), ex.into());

    // Create a new Subscription
    let monitor =  backend.monitor();
     
    let listener = monitor.register::<ConnectionEvent>().await;
     
    let new_event = listener.recv().await;
};

Fields

event_emitter: Arc<EventEmitter<MonitorTopic>>

config: Arc<Config>

Implementations

impl Monitor

pub(crate) fn new(config: Arc<Config>) -> Self

Creates a new Monitor

pub(crate) async fn notify<E: ToEventStruct>(&self, event: E)

Sends a new monitor event to subscribers.

pub async fn register<E>(&self) -> EventListener<MonitorTopic, E>

where E: Clone + EventValue + EventValueTopic<Topic = MonitorTopic>,

Registers a new event listener for the provided topic.