jetstreamer-utils 0.6.0

Support crate for Jetstreamer containing utility functions, types, and ClickHouse integration
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use jetstreamer_utils::{start, stop_sync};

#[tokio::main(flavor = "multi_thread")]
async fn main() {
    solana_logger::setup_with_default("info");
    ctrlc::set_handler(|| {
        stop_sync();
    })
    .unwrap();
    let (mut ready_rx, clickhouse_future) = start().await.unwrap();
    log::info!("Waiting for ClickHouse to be ready...");
    if ready_rx.recv().await.is_some() {
        log::info!("ClickHouse is ready!");
    }
    // Wait for the ClickHouse process to finish
    clickhouse_future.await.unwrap();
}