grapevine 1.0.0

A modern, asynchronous peer-to-peer gossip protocol library and application
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

//! Example demonstrating custom configuration.
//!
//! Run with: `RUST_LOG=info cargo run --example custom_config`
//! Shutdown with `Control+C (^C)`

use std::time::Duration;

use grapevine::{Node, NodeConfigBuilder, TransportConfig};
use tracing::info;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    tracing_subscriber::fmt::init();

    // Build custom configuration
    let config = NodeConfigBuilder::new()
        .bind_addr("127.0.0.1:9000".parse()?)
        .gossip_interval(Duration::from_secs(3))
        .fanout(5)
        .max_peers(100)
        .max_message_size(2 * 1024 * 1024) // 2 MB
        .peer_timeout(Duration::from_secs(60))
        .connection_timeout(Duration::from_secs(15))
        .transport(TransportConfig::Tcp)
        .build()?;

    info!("Configuration:");
    info!("  Bind address: {}", config.bind_addr);
    info!("  Gossip interval: {:?}", config.gossip_interval);
    info!("  Fan-out: {}", config.fanout);
    info!("  Max peers: {}", config.max_peers);
    info!("  Max message size: {} bytes", config.max_message_size);

    let node = Node::new(config).await?;
    node.start().await?;

    let addr = node.local_addr().await.expect("No local address");
    info!("Node started on {addr}");

    tokio::signal::ctrl_c().await?;
    node.shutdown().await?;

    Ok(())
}