ingest 0.1.1

Single and multi-threaded custom ingestion crate for Stellar Futurenet, written in Rust.
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

use ingest::{CaptiveCore, IngestionConfig, SupportedNetwork, LedgerCloseMetaReader};


pub fn main() {
    let config = IngestionConfig {
        executable_path: "/usr/local/bin/stellar-core".to_string(),
        context_path: Default::default(),
        network: SupportedNetwork::Futurenet,
        bounded_buffer_size: None,
        staggered: None,
    };

    let mut captive_core = CaptiveCore::new(config);

    let receiver = captive_core.start_online_no_range().unwrap();

    println!(
        "Capturing all events. When a contract event will be emitted it will be printed to stdout"
    );
    for result in receiver.iter() {
        let ledger_sequence = LedgerCloseMetaReader::ledegr_sequence(&result).unwrap();
        let events = LedgerCloseMetaReader::soroban_events(&result).unwrap();
        println!("Events for ledger {}:\n{}", ledger_sequence, serde_json::to_string(&events).unwrap())
    }
}