Functions — github.com/anshuman008/solana-liquidation-detection

hub / github.com/anshuman008/solana-liquidation-detection / functions

Functions203 in github.com/anshuman008/solana-liquidation-detection

⨍ Functions 203◇ Types & classes 118

↓ 227 callersMethodto_string

(&self)

src/database/models.rs:183

↓ 20 callersMethodadd_error

(&mut self, error: String)

src/events/validator.rs:353

↓ 15 callersMethodadd_warning

(&mut self, warning: String)

src/events/validator.rs:357

↓ 5 callersFunctioncompiled_instruction_to_instruction

( ci: &CompiledInstruction, parsed_accounts: Vec<AccountMeta>, )

src/main.rs:1441

↓ 5 callersMethodvalidate

(&self, event: &LiquidationEventMessage)

src/events/validator.rs:37

↓ 4 callersMethodcalculate_retry_time

(&self, retry_count: u32)

src/events/processor.rs:318

↓ 4 callersFunctioncreate_valid_event

()

src/events/validator.rs:382

↓ 4 callersFunctionextract_liquidation_data

( data: &serde_json::Value

src/main.rs:790

↓ 4 callersMethodname

(&self)

parsers/drift_protocol/src/instructions.rs:28

↓ 4 callersMethodvalidate_pubkey

(&self, pubkey: &str, field_name: &str, result: &mut ValidationResult)

src/events/validator.rs:156

↓ 3 callersMethodadd_provider

( &mut self, name: String, provider: Arc<dyn NotificationProvider + Send + Sync>,

src/notifications/service.rs:31

↓ 3 callersMethodcan_retry

(&self)

src/events/mod.rs:76

↓ 3 callersMethodget_pending_notifications

( &self, _limit: i32, )

src/notifications/service.rs:439

↓ 3 callersFunctioninitialize_ix_with_program_id

( program_id: Pubkey, keys: InitializeKeys, args: InitializeIxArgs, )

parsers/drift_protocol/src/instructions.rs:1078

↓ 3 callersMethodlog_processing_error

( &self, event: &LiquidationEventMessage, error_type: &str, error_message: &st

src/events/processor.rs:291

↓ 3 callersFunctionparse_transaction_accounts

( message: &VersionedMessage, loaded_addresses: LoadedAddresses, )

src/main.rs:1469

↓ 3 callersMethodsend

(&self, _message: &NotificationEventMessage)

src/notifications/service.rs:483

↓ 3 callersMethodupdate_notification_status

( &self, _id: uuid::Uuid, _status: &str, _response: Option<ser

src/notifications/service.rs:446

↓ 2 callersMethodcalculate_retry_delay

(&self, attempt: u32, config: &RetryConfig)

src/notifications/service.rs:247

↓ 2 callersMethodconnect

(&self)

src/main.rs:88

↓ 2 callersMethodget_retryable_errors

(&self)

src/database/repository.rs:500

↓ 2 callersMethodsend_notification

(&self, event: NotificationEventMessage)

src/notifications/service.rs:39

↓ 2 callersMethodserialize

(&self, mut writer: W)

parsers/drift_protocol/src/instructions.rs:86

↓ 2 callersFunctionto_camel_case

(name: &str)

src/main.rs:388

↓ 1 callersFunctionconvert_set_authority

( authority_type: AuthorityType, new_authority: COption<Pubkey>, )

src/token_serializable.rs:15

↓ 1 callersFunctioncreate_pool

(database_url: &str)

src/database/mod.rs:12

↓ 1 callersFunctioncreate_test_notification_event

()

src/notifications/webhook.rs:420

↓ 1 callersFunctionflatten_compiled_instructions

( transaction_with_meta: &VersionedTransactionWithStatusMeta, )

src/main.rs:1384

↓ 1 callersFunctionflatten_inner_instructions

( transaction_with_meta: &VersionedTransactionWithStatusMeta, )

src/main.rs:1405

↓ 1 callersMethodformat_discord_message

(&self)

src/notifications/mod.rs:211

↓ 1 callersMethodget_failed_notifications

( &self, )

src/notifications/service.rs:463

↓ 1 callersMethodget_liquidation_event_by_signature

( &self, signature: &str, )

src/events/processor.rs:451

↓ 1 callersMethodget_txn_updates

(&self)

src/main.rs:100

↓ 1 callersFunctiongeyser_subscribe

( mut client: GeyserGrpcClient<impl Interceptor>, request: SubscribeRequest, liquidation_sender: m

src/main.rs:406

↓ 1 callersMethodhas_warnings

(&self)

src/events/validator.rs:365

↓ 1 callersMethodhealth_check

(&self)

src/notifications/service.rs:338

↓ 1 callersMethodhealth_check

(&self)

src/events/handler.rs:349

↓ 1 callersMethodincrement_error_retry

(&self, id: Uuid, next_retry_at: DateTime<Utc>)

src/database/repository.rs:517

↓ 1 callersMethodincrement_notification_retry

( &self, _id: uuid::Uuid, _next_retry_at: chrono::DateTime<chrono::Utc>,

src/notifications/service.rs:455

↓ 1 callersFunctioninitialize_invoke_signed_with_program_id

( program_id: Pubkey, accounts: InitializeAccounts<'_, '_>, args: InitializeIxArgs, seeds: &[&

parsers/drift_protocol/src/instructions.rs:1112

↓ 1 callersFunctioninitialize_invoke_with_program_id

( program_id: Pubkey, accounts: InitializeAccounts<'_, '_>, args: InitializeIxArgs, )

parsers/drift_protocol/src/instructions.rs:1097

↓ 1 callersFunctioninitialize_verify_signer_privileges

( accounts: InitializeAccounts<'me, 'info>, )

parsers/drift_protocol/src/instructions.rs:1165

↓ 1 callersFunctioninitialize_verify_writable_privileges

( accounts: InitializeAccounts<'me, 'info>, )

parsers/drift_protocol/src/instructions.rs:1147

↓ 1 callersMethodinsert_liquidation_event

( &self, event: &LiquidationEventInsert, )

src/events/processor.rs:415

↓ 1 callersMethodinsert_notification_log

(&self, log: &NotificationLogInsert)

src/database/repository.rs:367

↓ 1 callersMethodinsert_processing_error

(&self, error: &ProcessingErrorInsert)

src/database/repository.rs:470

↓ 1 callersFunctioninvoke_instruction

( ix: &Instruction, accounts: A, )

parsers/drift_protocol/src/instructions.rs:128

↓ 1 callersFunctioninvoke_instruction_signed

( ix: &Instruction, accounts: A, seeds: &[&[&[u8]]], )

parsers/drift_protocol/src/instructions.rs:135

↓ 1 callersMethodis_retryable_error

(&self, response: &NotificationResponse)

src/notifications/service.rs:255

↓ 1 callersMethodmark_error_resolved

(&self, id: Uuid)

src/database/repository.rs:535

↓ 1 callersMethodmark_liquidation_event_processed

( &self, _id: Uuid, )

src/events/processor.rs:472

↓ 1 callersMethodprocess_liquidation_event

( &self, event: LiquidationEventMessage, )

src/events/processor.rs:43

↓ 1 callersMethodprocess_retry_queue

(&self)

src/events/processor.rs:324

↓ 1 callersMethodqueue_notifications

( &self, event_id: Uuid, event: &LiquidationEventMessage, )

src/events/processor.rs:224

↓ 1 callersFunctionrun_migrations

(pool: &PgPool)

src/database/mod.rs:27

↓ 1 callersMethodsend

(&self, message: &NotificationEventMessage)

src/notifications/webhook.rs:87

↓ 1 callersMethodsend_notification_attempt

( &self, event: &NotificationEventMessage, _alert: &LiquidationAlert, )

src/notifications/service.rs:228

↓ 1 callersMethodsend_to_webhook

( &self, url: &str, payload: &WebhookPayload, )

src/notifications/webhook.rs:31

↓ 1 callersMethodsend_with_retry

( &self, event: &NotificationEventMessage, alert: &LiquidationAlert, )

src/notifications/service.rs:154

↓ 1 callersMethodserialize

(&self, mut writer: W)

parsers/kamino_protocol/src/instructions.rs:50

↓ 1 callersMethodstart

(&mut self)

src/events/handler.rs:60

↓ 1 callersFunctionstart_grpc_processing

( args: Args, liquidation_sender: mpsc::Sender<LiquidationEventMessage>, )

src/main.rs:351

↓ 1 callersMethodstore_liquidation_event

(&self, event: &LiquidationEventMessage)

src/events/processor.rs:198

↓ 1 callersMethodtry_to_vec

(&self)

parsers/drift_protocol/src/instructions.rs:122

↓ 1 callersMethodvalidate

(&self)

src/config.rs:298

↓ 1 callersMethodvalidate_accounts

(&self, event: &LiquidationEventMessage, result: &mut ValidationResult)

src/events/validator.rs:138

↓ 1 callersMethodvalidate_amounts

(&self, event: &LiquidationEventMessage, result: &mut ValidationResult)

src/events/validator.rs:167

↓ 1 callersMethodvalidate_business_logic

( &self, event: &LiquidationEventMessage, result: &mut ValidationResult, )

src/events/validator.rs:267

↓ 1 callersMethodvalidate_drift_specific

( &self, event: &LiquidationEventMessage, result: &mut ValidationResult, )

src/events/validator.rs:299

↓ 1 callersMethodvalidate_event_data

(&self, event_data: &Value, result: &mut ValidationResult)

src/events/validator.rs:244

↓ 1 callersMethodvalidate_health_ratios

( &self, event: &LiquidationEventMessage, result: &mut ValidationResult, )

src/events/validator.rs:210

↓ 1 callersMethodvalidate_kamino_specific

( &self, event: &LiquidationEventMessage, result: &mut ValidationResult, )

src/events/validator.rs:317

↓ 1 callersMethodvalidate_protocol

(&self, protocol: &str, result: &mut ValidationResult)

src/events/validator.rs:131

↓ 1 callersMethodvalidate_required_fields

( &self, event: &LiquidationEventMessage, result: &mut ValidationResult, )

src/events/validator.rs:88

↓ 1 callersMethodvalidate_signature

(&self, signature: &str, result: &mut ValidationResult)

src/events/validator.rs:118

↓ 1 callersMethodwith_event_timeout

(mut self, timeout: Duration)

src/events/handler.rs:406

↓ 1 callersMethodwith_max_concurrent_events

(mut self, max_concurrent: usize)

src/events/handler.rs:401

↓ 1 callersMethodwith_retry_interval

(mut self, interval: Duration)

src/events/handler.rs:411

Functionconvert_coption

Helper function to convert COption<Pubkey> to Option<Pubkey>

src/token_serializable.rs:8

Functionconvert_to_serializable

Convert TokenInstruction to SerializableTokenInstruction

src/token_serializable.rs:94

Methoddeactivate_position

(&self, id: Uuid)

src/database/repository.rs:353

Methoddead_letter

(error: String)

src/events/mod.rs:161

src/notifications/mod.rs:106

Methoddefault

()

src/events/validator.rs:332

Methoddefault

()

src/events/handler.rs:473

Methoddeserialize

(buf: &[u8])

parsers/drift_protocol/src/instructions.rs:32

Methoddeserialize

(buf: &[u8])

parsers/kamino_protocol/src/instructions.rs:22

Functiondeserialize_i128_as_string

(deserializer: D)

parsers/drift_protocol/src/serializer.rs:31

Functiondeserialize_i128_as_string

(deserializer: D)

parsers/kamino_protocol/src/serializer.rs:31

Functiondeserialize_u128_as_string

(deserializer: D)

parsers/drift_protocol/src/serializer.rs:14

Functiondeserialize_u128_as_string

(deserializer: D)

parsers/kamino_protocol/src/serializer.rs:14

Methoderror

(error_message: String)

src/notifications/mod.rs:53

Methodfailure

(error: String)

src/events/mod.rs:143

Functionflatten_transaction_response

( transaction_with_meta: &VersionedTransactionWithStatusMeta, )

src/main.rs:1314

Methodformat_address

(&self, address: &str)

src/notifications/mod.rs:269

Methodformat_telegram_message

(&self)

src/notifications/mod.rs:240

Methodfrom

(accounts: InitializeAccounts)

parsers/drift_protocol/src/instructions.rs:167

Methodfrom

(accounts: LiquidateV2Accounts)

parsers/kamino_protocol/src/instructions.rs:121

Methodfrom

(err: tokio::sync::mpsc::error::SendError<T>)

src/error.rs:136

next →1–100 of 203, ranked by callers