Struct ProgramTrackingPlugin 

pub struct ProgramTrackingPlugin;

Tracks per-program invocation counts and writes them to ClickHouse.

Trait Implementations

impl Clone for ProgramTrackingPlugin

fn clone(&self) -> ProgramTrackingPlugin

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProgramTrackingPlugin

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

Formats the value using the given formatter.

impl Default for ProgramTrackingPlugin

fn default() -> ProgramTrackingPlugin

Returns the “default value” for a type.

impl Plugin for ProgramTrackingPlugin

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.