Struct PubkeyStatsPlugin 

pub struct PubkeyStatsPlugin;

Tracks per-slot pubkey mention counts and writes them to ClickHouse.

For every transaction, all account keys referenced in the message (both static and loaded) are counted. A ClickHouse pubkey_mentions table stores the aggregated count per (slot, pubkey) pair using ReplacingMergeTree for safe parallel ingestion.

A companion pubkeys table assigns a unique auto-incremented id to each pubkey, maintained via a materialised view so lookups by id are efficient.

Implementations

impl PubkeyStatsPlugin

pub const fn new() -> Self

Creates a new instance.

Trait Implementations

impl Clone for PubkeyStatsPlugin

fn clone(&self) -> PubkeyStatsPlugin

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PubkeyStatsPlugin

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PubkeyStatsPlugin

fn default() -> Self

Returns the “default value” for a type.

impl Plugin for PubkeyStatsPlugin

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

Human-friendly plugin name used in logs and persisted metadata.

fn on_transaction<'a>( &'a self, _thread_id: usize, _db: Option<Arc<Client>>, transaction: &'a TransactionData, ) -> PluginFuture<'a>

Called for every transaction seen by the firehose.

fn on_block( &self, _thread_id: usize, db: Option<Arc<Client>>, block: &BlockData, ) -> PluginFuture<'_>

Called for every block observed by the firehose.

fn on_load(&self, db: Option<Arc<Client>>) -> PluginFuture<'_>

Invoked once before the firehose starts streaming events.

fn on_exit(&self, db: Option<Arc<Client>>) -> PluginFuture<'_>

Invoked once after the firehose finishes or shuts down.

fn version(&self) -> u16

Semantic version for the plugin; defaults to 1.

fn id(&self) -> u16

Deterministic identifier derived from Plugin::name.

fn on_entry<'a>( &'a self, _thread_id: usize, _db: Option<Arc<Client>>, _entry: &'a EntryData, ) -> PluginFuture<'a>

Called for every entry observed by the firehose when entry notifications are enabled.

fn on_reward<'a>( &'a self, _thread_id: usize, _db: Option<Arc<Client>>, _reward: &'a RewardsData, ) -> PluginFuture<'a>

Called for reward updates associated with processed blocks.

fn on_error<'a>( &'a self, _thread_id: usize, _db: Option<Arc<Client>>, _error: &'a FirehoseErrorContext, ) -> PluginFuture<'a>

Called whenever a firehose thread encounters an error before restarting.