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
26
27
28
29
30
31
32
33
34
35
36
37

// Note: this example is still untested.

use ingest::{CaptiveCore, IngestionConfig, SupportedNetwork};
use stellar_xdr::next::LedgerCloseMeta;

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

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

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

    println!("Printing tx sets");
    for result in receiver.iter() {
        let ledger = result.ledger_close_meta.unwrap().ledger_close_meta;
        match &ledger {
            LedgerCloseMeta::V0(v0) => {
                println!(
                    "v0 meta: {}",
                    serde_json::to_string_pretty(&v0.tx_set).unwrap()
                )
            }
            LedgerCloseMeta::V1(v1) => {
                println!(
                    "v1 meta: {}",
                    serde_json::to_string_pretty(&v1.tx_set).unwrap()
                )
            }
        }
    }
}