Functions — github.com/Blockdaemon/solana-accountsdb-plugin-kafka

hub / github.com/Blockdaemon/solana-accountsdb-plugin-kafka / functions

Functions63 in github.com/Blockdaemon/solana-accountsdb-plugin-kafka

⨍ Functions 63 ◇ Types & classes 8

↓ 5 callersMethodunwrap_filters

(&self)

src/plugin.rs:248

↓ 4 callersMethodcopy_and_prepend

(&self, data: &[u8], prefix: u8)

src/publisher.rs:142

↓ 4 callersMethodset_default

(&mut self, k: &'static str, v: &'static str)

src/config.rs:88

↓ 4 callersMethodunwrap_publisher

(&self)

src/plugin.rs:244

↓ 2 callersMethodwants_account

(&self, account: &[u8])

src/filter.rs:76

↓ 2 callersMethodwants_program

(&self, program: &[u8])

src/filter.rs:66

↓ 1 callersMethodcreate_prometheus

(&self)

src/config.rs:101

↓ 1 callersMethodfill_defaults

(&mut self)

src/config.rs:94

↓ 1 callersFunctionmetrics_handler

()

src/prom.rs:125

↓ 1 callersFunctionnot_found_handler

()

src/prom.rs:137

↓ 1 callersMethodproducer

Create rdkafka::FutureProducer from config.

src/config.rs:80

↓ 1 callersMethodshutdown

(self)

src/prom.rs:120

↓ 1 callersMethodupdate_block

( &self, ev: BlockEvent, wrap_messages: bool, topic: &str, )

src/publisher.rs:114

↓ 1 callersMethodupdate_transaction

( &self, ev: TransactionEvent, wrap_messages: bool, topic: &str, )

src/publisher.rs:91

↓ 1 callersMethodwants_failed_tx

(&self)

src/filter.rs:87

↓ 1 callersMethodwants_vote_tx

(&self)

src/filter.rs:83

Function_create_plugin

# Safety This function returns a pointer to the Kafka Plugin box implementing trait GeyserPlugin. The Solana validator and this plugin must be compi

src/lib.rs:42

Methodaccount_data_notifications_enabled

(&self)

src/plugin.rs:220

Methodbuild_block_event

(block: ReplicaBlockInfoV4)

src/plugin.rs:734

Methodbuild_compiled_instruction

( ix: &solana_message::compiled_instruction::CompiledInstruction, )

src/plugin.rs:306

Methodbuild_inner_instruction

( ix: &solana_transaction_status::InnerInstruction, )

src/plugin.rs:316

Methodbuild_loaded_address_info

Build detailed loaded address information

src/plugin.rs:694

Methodbuild_message_header

(header: &solana_message::MessageHeader)

src/plugin.rs:325

Methodbuild_transaction_event

( slot: u64, ReplicaTransactionInfoV3 { signature, is_vote,

src/plugin.rs:351

Methodbuild_transaction_token_balance

( transaction_token_account_balance: solana_transaction_status::TransactionTokenBalance, )

src/plugin.rs:333

Methodcalculate_confirmation_count

Calculate confirmation count based on slot status

(&self, _: &DeliveryResult<'_>, _: Self::DeliveryOpaque)

Methodencode_with_wrapper

(message: EventMessage)

src/publisher.rs:135

Methodextract_compute_price_from_transaction

Extract compute unit price from transaction message

src/plugin.rs:623

Methodextract_compute_units_from_metadata

Extract compute units consumed from transaction metadata

src/plugin.rs:609

Methodextract_error_logs_from_status

Extract error information from transaction status (more reliable than log parsing)

src/plugin.rs:663

Methodfmt

(&self, _: &mut Formatter<'_>)

src/plugin.rs:45

Methodfrom

(other: PluginSlotStatus)

src/event.rs:23

Methodget_account_keys_from_message

Extract account keys from versioned message

src/plugin.rs:653

Functionget_pkg_version

(lockfile: &Lockfile, pkg_name: &str)

build.rs:37

Methodget_slot_status_description

Get human-readable slot status description

src/plugin.rs:679

Methodis_slot_confirmed

Determine if slot is confirmed based on status

src/plugin.rs:674

Methodlog_ignore_account_update

(info: &ReplicaAccountInfoV3)

(config: &ConfigFilter)

(producer: ThreadedProducer<StatsThreadedProducerContext>, config: &Config)

src/publisher.rs:38

Methodnew

(address: SocketAddr)

src/prom.rs:55

Methodnotify_block_metadata

(&self, blockinfo: ReplicaBlockInfoVersions)

src/plugin.rs:209

Methodnotify_transaction

( &self, transaction: ReplicaTransactionInfoVersions, slot: u64, )

src/plugin.rs:169

Methodon_load

(&mut self, config_file: &str, _: bool)

Read plugin from JSON file.

src/config.rs:71

Methodstats

(&self, statistics: Statistics)

src/prom.rs:148

Functiontest_account_filter

Functiontest_owner_filter

()

src/filter.rs:131

Methodtransaction_notifications_enabled

(&self)

src/plugin.rs:227

Methodunwrap_block_metadata

(block: ReplicaBlockInfoVersions)

src/plugin.rs:285

Methodunwrap_transaction

( transaction: ReplicaTransactionInfoVersions, )

src/plugin.rs:268

Methodunwrap_update_account

(account: ReplicaAccountInfoVersions)

src/plugin.rs:252

Methodupdate_account

( &self, account: ReplicaAccountInfoVersions, slot: u64, is_startup: bool,

src/plugin.rs:97

Methodupdate_account

( &self, ev: UpdateAccountEvent, wrap_messages: bool, topic: &str, )

src/publisher.rs:45

Methodupdate_slot_status

( &self, slot: u64, parent: Option<u64>, status: &PluginSlotStatus, )

src/plugin.rs:141

Methodupdate_slot_status

( &self, ev: SlotStatusEvent, wrap_messages: bool, topic: &str, )

src/publisher.rs:69