Struct BitcoindWatcher 

pub struct BitcoindWatcher { /* private fields */ }

Implementations

impl BitcoindWatcher

pub fn run(&self)

Examples found in repository

examples/example.rs (line 25)

fn main() {
    type Callback = Box<dyn Fn(LogLine) + 'static>;

    let on_transaction_added_to_mempool: Callback = Box::new(|log_line| {
        println!(".....on_transaction_added_to_mempool.....");
        println!("{:?}", log_line)
    });
    let on_new_proof_of_work_valid_block: Callback = Box::new(|log_line| {
        println!(".....on_new_proof_of_work_valid_block.....");
        println!("{:?}", log_line)
    });
    let on_new_outbound_peer_connected: Callback = Box::new(|log_line| {
        println!(".....on_new_outbound_peer_connected.....");
        println!("{:?}", log_line)
    });
    BitcoindWatcher::new(FILE_TO_WATCH)
        .on_transaction_added_to_mempool(on_transaction_added_to_mempool)
        .on_new_proof_of_work_valid_block(on_new_proof_of_work_valid_block)
        .on_new_outbound_peer_connected(on_new_outbound_peer_connected)
        .run();
}

pub fn new(log_path: &str) -> Self

Examples found in repository

examples/example.rs (line 21)

fn main() {
    type Callback = Box<dyn Fn(LogLine) + 'static>;

    let on_transaction_added_to_mempool: Callback = Box::new(|log_line| {
        println!(".....on_transaction_added_to_mempool.....");
        println!("{:?}", log_line)
    });
    let on_new_proof_of_work_valid_block: Callback = Box::new(|log_line| {
        println!(".....on_new_proof_of_work_valid_block.....");
        println!("{:?}", log_line)
    });
    let on_new_outbound_peer_connected: Callback = Box::new(|log_line| {
        println!(".....on_new_outbound_peer_connected.....");
        println!("{:?}", log_line)
    });
    BitcoindWatcher::new(FILE_TO_WATCH)
        .on_transaction_added_to_mempool(on_transaction_added_to_mempool)
        .on_new_proof_of_work_valid_block(on_new_proof_of_work_valid_block)
        .on_new_outbound_peer_connected(on_new_outbound_peer_connected)
        .run();
}

pub fn on_transaction_added_to_mempool( self, callback: Box<dyn Fn(LogLine) + 'static>, ) -> Self

Examples found in repository

examples/example.rs (line 22)

fn main() {
    type Callback = Box<dyn Fn(LogLine) + 'static>;

    let on_transaction_added_to_mempool: Callback = Box::new(|log_line| {
        println!(".....on_transaction_added_to_mempool.....");
        println!("{:?}", log_line)
    });
    let on_new_proof_of_work_valid_block: Callback = Box::new(|log_line| {
        println!(".....on_new_proof_of_work_valid_block.....");
        println!("{:?}", log_line)
    });
    let on_new_outbound_peer_connected: Callback = Box::new(|log_line| {
        println!(".....on_new_outbound_peer_connected.....");
        println!("{:?}", log_line)
    });
    BitcoindWatcher::new(FILE_TO_WATCH)
        .on_transaction_added_to_mempool(on_transaction_added_to_mempool)
        .on_new_proof_of_work_valid_block(on_new_proof_of_work_valid_block)
        .on_new_outbound_peer_connected(on_new_outbound_peer_connected)
        .run();
}

pub fn on_new_proof_of_work_valid_block( self, callback: Box<dyn Fn(LogLine) + 'static>, ) -> Self

Examples found in repository

examples/example.rs (line 23)

fn main() {
    type Callback = Box<dyn Fn(LogLine) + 'static>;

    let on_transaction_added_to_mempool: Callback = Box::new(|log_line| {
        println!(".....on_transaction_added_to_mempool.....");
        println!("{:?}", log_line)
    });
    let on_new_proof_of_work_valid_block: Callback = Box::new(|log_line| {
        println!(".....on_new_proof_of_work_valid_block.....");
        println!("{:?}", log_line)
    });
    let on_new_outbound_peer_connected: Callback = Box::new(|log_line| {
        println!(".....on_new_outbound_peer_connected.....");
        println!("{:?}", log_line)
    });
    BitcoindWatcher::new(FILE_TO_WATCH)
        .on_transaction_added_to_mempool(on_transaction_added_to_mempool)
        .on_new_proof_of_work_valid_block(on_new_proof_of_work_valid_block)
        .on_new_outbound_peer_connected(on_new_outbound_peer_connected)
        .run();
}

pub fn on_new_outbound_peer_connected( self, callback: Box<dyn Fn(LogLine) + 'static>, ) -> Self

Examples found in repository

examples/example.rs (line 24)

fn main() {
    type Callback = Box<dyn Fn(LogLine) + 'static>;

    let on_transaction_added_to_mempool: Callback = Box::new(|log_line| {
        println!(".....on_transaction_added_to_mempool.....");
        println!("{:?}", log_line)
    });
    let on_new_proof_of_work_valid_block: Callback = Box::new(|log_line| {
        println!(".....on_new_proof_of_work_valid_block.....");
        println!("{:?}", log_line)
    });
    let on_new_outbound_peer_connected: Callback = Box::new(|log_line| {
        println!(".....on_new_outbound_peer_connected.....");
        println!("{:?}", log_line)
    });
    BitcoindWatcher::new(FILE_TO_WATCH)
        .on_transaction_added_to_mempool(on_transaction_added_to_mempool)
        .on_new_proof_of_work_valid_block(on_new_proof_of_work_valid_block)
        .on_new_outbound_peer_connected(on_new_outbound_peer_connected)
        .run();
}