Struct NdjsonPlugin 

pub struct NdjsonPlugin { /* private fields */ }

Built-in plugin that writes structured data to NDJSON files.

Creates one file per record type in the specified directory: blocks.ndjson, transactions.ndjson, token_transfers.ndjson, account_activity.ndjson. Files are append-only and safe for resume (re-runs append duplicates).

Implementations

impl NdjsonPlugin

pub fn new(dir: &str) -> Self

Create a new NDJSON plugin that writes to the specified directory. The directory is created on on_load if it doesn’t exist.

Trait Implementations

impl Plugin for NdjsonPlugin

fn name(&self) -> &'static str

Human-friendly name for this plugin (used in logs).

fn on_load<'a>(&'a self) -> PluginFuture<'a>

Called once when the runner starts, before any data is fetched. Use this to create tables, open connections, or validate config.

fn on_block<'a>(&'a self, block: &'a BlockData) -> PluginFuture<'a>

Called for each block. Fired once per slot, before transactions.

fn on_transaction<'a>(&'a self, tx: &'a TransactionData) -> PluginFuture<'a>

Called for each transaction within a block. Fired in order of tx_index within the slot.

fn on_token_transfer<'a>( &'a self, transfer: &'a TokenTransferData, ) -> PluginFuture<'a>

Called for each token balance change within a transaction. Only fired when the balance actually changed (pre != post).

fn on_account_activity<'a>( &'a self, activity: &'a AccountActivityData, ) -> PluginFuture<'a>

Called for each account touched by a transaction (SOL balance changes).

fn on_exit<'a>(&'a self) -> PluginFuture<'a>

Called once when the runner is shutting down. Flush buffers, close connections.

fn on_raw<'a>(&'a self, _slot: u64, _raw: &'a Value) -> PluginFuture<'a>

Called for every non-skipped slot with the full raw JSON-RPC response.

fn on_skipped_slot<'a>(&'a self, _slot: u64) -> PluginFuture<'a>

Called when a slot was skipped by the Solana leader (no block produced).