notus-mempool 0.1.1

Notus Mempool Library
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
45
46
47
48
49

use log::{debug, error, info, trace, warn, LevelFilter};
use notus_mempool::mempool::{Mempool, MempoolMessageStruct};

fn main() {
    // if env::var("RUST_LOG").is_err() {
    //     env::set_var("RUST_LOG", "trace")
    // }
    // env_logger::init();

    let mut builder = env_logger::builder();
    builder.filter_level(LevelFilter::Trace);
    builder.format_target(false);
    builder.init();

    trace!("deneme");
    error!("deneme");
    info!("deneme");
    warn!("deneme");
    debug!("deneme");

    std::thread::spawn(move || {
        // some work here
        let mut counter = 1;
        loop {
            Mempool::send_via_udp(
                "127.0.0.1:7777".to_string(),
                MempoolMessageStruct {
                    time: Mempool::time_stamp(),
                    data: format!("deneme => {}", counter).as_bytes().to_vec(),
                },
            );
            counter += 1;
            std::thread::sleep(std::time::Duration::from_millis(1000));
        }
    });

    let mut mempool_obj = Mempool::new("127.0.0.1:7777".to_string());

    mempool_obj.add_nodes(vec![
        "127.0.0.1:3333".to_string(),
        "127.0.0.1:4444".to_string(),
        "127.0.0.1:5555".to_string(),
    ]);

    mempool_obj.add_node("127.0.0.1:6666".to_string());
    mempool_obj.add_msg("127.0.0.1:6666".to_string().as_bytes().to_vec());
    mempool_obj.start();
    loop {}
}