Crate quicknode_cascade 

quicknode-cascade

Stream blockchain data at scale. Plugin-based framework powered by QuickNode Cascade — an edge-cached block archive served from 300+ global PoPs with sub-50ms latency.

Currently supports Solana. More chains coming soon.

Quick Start

use quicknode_cascade::{CascadeRunner, solana};

struct MyPlugin;

impl solana::Plugin for MyPlugin {
    fn name(&self) -> &'static str { "my-plugin" }

    fn on_block<'a>(&'a self, block: &'a solana::BlockData) -> solana::PluginFuture<'a> {
        Box::pin(async move {
            println!("slot {} — {} txs", block.slot, block.transaction_count);
            Ok(())
        })
    }
}

CascadeRunner::solana_mainnet()
    .auth_token("your-jwt-token")
    .backfill(400_000_000, 400_000_010)
    .with_plugin(Box::new(MyPlugin))
    .run()
    .expect("done");

Modules

plugins

Built-in plugins that ship with the crate.

solana

Solana chain support.

Structs

CascadeRunner

Builder-pattern runner for the streaming engine.