Struct TopicTracker

Source

pub struct TopicTracker {
    pub node_id: NodeId,
    /* private fields */
}

Fields§

§node_id: NodeId

Implementations§

Source §

pub const BOOTSTRAP_NODES: &str = "abcdef4df4d74587095d071406c2a8462bde5079cbbc0c50051b9b2e84d67691"

Source

pub fn new(endpoint: &Endpoint) -> Self

Examples found in repository ?

examples/server.rs (line 20)

async fn main() -> Result<()> {

    let secret_key =  SecretKey::from_str(SECRET_SERVER_KEY)?;
    
    let endpoint = Endpoint::builder()
        .secret_key(secret_key)
        .discovery_n0()
        .discovery_dht()
        .bind()
        .await?;
    
    let topic_tracker = Arc::new(TopicTracker::new(&endpoint));
    let _router = iroh::protocol::Router::builder(endpoint.clone())
        .accept(TopicTracker::ALPN, topic_tracker.clone())
        .spawn()
        .await?;

    let from = tokio::io::stdin();
    let mut lines = BufReader::new(from).lines();
    while let Some(_) = lines.next_line().await? {
        println!("{:?}",topic_tracker.memory_footprint().await);
    }
    
    Ok(())
}

More examples

Hide additional examples

examples/client.rs (line 21)

async fn main() -> Result<()> {
    let topic = Topic::from_passphrase("my test topic");
    let _topic_id: TopicId = topic.clone().into();
    let secret_key =  SecretKey::generate(rand::rngs::OsRng);
    
    let endpoint = Endpoint::builder()
        .secret_key(secret_key)
        .discovery_n0()
        .discovery_dht()
        .bind()
        .await?;
    
    let topic_tracker = Arc::new(TopicTracker::new(&endpoint));
    let _router = iroh::protocol::Router::builder(endpoint.clone())
        .accept(TopicTracker::ALPN, topic_tracker.clone())
        .spawn()
        .await?;

    // Send a request
    let node_ids_for_topic = topic_tracker.get_topic_nodes(&topic).await?;
    println!("Iroh node_ids for topic: {:?}",node_ids_for_topic);

    Ok(())
}

Source

pub async fn get_topic_nodes( self: Arc<Self>, topic: &Topic, ) -> Result<Vec<NodeId>>

Examples found in repository ?

examples/client.rs (line 28)

async fn main() -> Result<()> {
    let topic = Topic::from_passphrase("my test topic");
    let _topic_id: TopicId = topic.clone().into();
    let secret_key =  SecretKey::generate(rand::rngs::OsRng);
    
    let endpoint = Endpoint::builder()
        .secret_key(secret_key)
        .discovery_n0()
        .discovery_dht()
        .bind()
        .await?;
    
    let topic_tracker = Arc::new(TopicTracker::new(&endpoint));
    let _router = iroh::protocol::Router::builder(endpoint.clone())
        .accept(TopicTracker::ALPN, topic_tracker.clone())
        .spawn()
        .await?;

    // Send a request
    let node_ids_for_topic = topic_tracker.get_topic_nodes(&topic).await?;
    println!("Iroh node_ids for topic: {:?}",node_ids_for_topic);

    Ok(())
}

Source

pub async fn memory_footprint(&self) -> usize

Examples found in repository ?

examples/server.rs (line 29)

async fn main() -> Result<()> {

    let secret_key =  SecretKey::from_str(SECRET_SERVER_KEY)?;
    
    let endpoint = Endpoint::builder()
        .secret_key(secret_key)
        .discovery_n0()
        .discovery_dht()
        .bind()
        .await?;
    
    let topic_tracker = Arc::new(TopicTracker::new(&endpoint));
    let _router = iroh::protocol::Router::builder(endpoint.clone())
        .accept(TopicTracker::ALPN, topic_tracker.clone())
        .spawn()
        .await?;

    let from = tokio::io::stdin();
    let mut lines = BufReader::new(from).lines();
    while let Some(_) = lines.next_line().await? {
        println!("{:?}",topic_tracker.memory_footprint().await);
    }
    
    Ok(())
}