Struct solana_accountsdb_plugin_kafka::KafkaPlugin

pub struct KafkaPlugin { /* private fields */ }

Implementations

impl KafkaPlugin

pub fn new() -> Self

Trait Implementations

impl AccountsDbPlugin for KafkaPlugin

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

fn on_load(&mut self, config_file: &str) -> PluginResult<()>

The callback called when a plugin is loaded by the system, used for doing whatever initialization is required by the plugin. The _config_file contains the name of the of the config file. The config must be in JSON format and include a field “libpath” indicating the full path name of the shared library implementing this interface.

fn on_unload(&mut self)

The callback called right before a plugin is unloaded by the system Used for doing cleanup before unload.

fn update_account(
    &mut self,
    account: ReplicaAccountInfoVersions<'_>,
    slot: u64,
    is_startup: bool
) -> PluginResult<()>

Called when an account is updated at a slot. When is_startup is true, it indicates the account is loaded from snapshots when the validator starts up. When is_startup is false, the account is updated during transaction processing.

fn update_slot_status(
    &mut self,
    slot: u64,
    parent: Option<u64>,
    status: PluginSlotStatus
) -> PluginResult<()>

Called when a slot status is updated

fn account_data_notifications_enabled(&self) -> bool

Check if the plugin is interested in account data Default is true – if the plugin is not interested in account data, please return false.

fn transaction_notifications_enabled(&self) -> bool

Check if the plugin is interested in transaction data Default is false – if the plugin is not interested in transaction data, please return false.

fn notify_end_of_startup(&mut self) -> Result<(), AccountsDbPluginError>

Called when all accounts are notified of during startup.

fn notify_transaction(
    &mut self,
    transaction: ReplicaTransactionInfoVersions<'_>,
    slot: u64
) -> Result<(), AccountsDbPluginError>

Called when a transaction is updated at a slot.

fn notify_block_metadata(
    &mut self,
    blockinfo: ReplicaBlockInfoVersions<'_>
) -> Result<(), AccountsDbPluginError>

Called when block’s metadata is updated.

impl Debug for KafkaPlugin

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

Formats the value using the given formatter.

impl Default for KafkaPlugin

fn default() -> KafkaPlugin

Returns the “default value” for a type.