jetstreamer 0.7.0

High-throughput Solana transaction ledger streaming and plugin framework suitable for research and backfilling
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use jetstreamer::{BuiltinPlugin, JetstreamerInvocation, JetstreamerRunner};

fn main() -> Result<(), Box<dyn std::error::Error>> {
    match JetstreamerRunner::default()
        .with_log_level("info")
        .parse_cli_args()?
    {
        JetstreamerInvocation::Run(runner) => runner
            .run()
            .map_err(|err| -> Box<dyn std::error::Error> { Box::new(err) })?,
        JetstreamerInvocation::ListPlugins => {
            for plugin in BuiltinPlugin::ALL {
                println!("{}", plugin.name());
            }
        }
    }
    Ok(())
}