Struct InstructionTrackingPlugin 

pub struct InstructionTrackingPlugin;

Tracks total instructions executed per slot and batches writes to ClickHouse.

Trait Implementations

impl Clone for InstructionTrackingPlugin

fn clone(&self) -> InstructionTrackingPlugin

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InstructionTrackingPlugin

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

Formats the value using the given formatter.

impl Default for InstructionTrackingPlugin

fn default() -> InstructionTrackingPlugin

Returns the “default value” for a type.

impl Plugin for InstructionTrackingPlugin

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.