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

Methodfrom

(s: String)

src/database/models.rs:193

Methodfrom_alert

(alert: &LiquidationAlert)

src/notifications/webhook.rs:195

Methodfrom_file_or_env

(path: P)

src/config.rs:263

Methodfrom_notification_event

(event: &NotificationEventMessage)

src/notifications/mod.rs:150

Methodget_active_positions

(&self)

src/database/repository.rs:306

Methodget_config

(&self)

src/notifications/service.rs:393

Methodget_failed_notifications

(&self)

src/database/repository.rs:456

Functionget_instruction_name_with_typename

(instruction: &TokenInstruction)

src/main.rs:396

Methodget_liquidation_event_by_id

(&self, id: Uuid)

src/database/repository.rs:155

Methodget_liquidation_event_by_id

( &self, _id: Uuid, )

src/events/processor.rs:458

Methodget_liquidation_event_by_signature

( &self, signature: &str, )

src/database/repository.rs:166

Methodget_liquidation_events_by_protocol

( &self, protocol: &str, limit: i32, )

src/database/repository.rs:222

Methodget_liquidation_events_by_protocol

( &self, _protocol: &str, _limit: i32, )

src/events/processor.rs:486

Methodget_liquidation_events_by_user

( &self, user: &str, limit: i32, )

src/database/repository.rs:239

Methodget_liquidation_events_by_user

( &self, _user: &str, _limit: i32, )

src/events/processor.rs:494

Methodget_metrics_by_name

( &self, name: &str, since: DateTime<Utc>, )

src/database/repository.rs:571

Methodget_notification_stats

(&self)

src/notifications/service.rs:373

Methodget_pending_notifications

(&self, limit: i32)

src/database/repository.rs:396

Methodget_position_by_id

(&self, id: Uuid)

src/database/repository.rs:296

Methodget_positions_by_protocol

(&self, protocol: &str)

src/database/repository.rs:329

Methodget_positions_by_user

(&self, user_account: &str)

src/database/repository.rs:317

Methodget_unprocessed_liquidation_events

( &self, limit: i32, )

src/database/repository.rs:181

Methodget_unprocessed_liquidation_events

( &self, _limit: i32, )

src/events/processor.rs:465

Methodgraceful_shutdown

(&mut self, timeout: Duration)

src/events/handler.rs:421

Methodhas_errors

(&self)

src/events/validator.rs:361

Methodhealth_check

(&self)

src/notifications/webhook.rs:136

Methodhealth_check

(&self)

src/database/repository.rs:102

Methodhealth_check

(&self)

src/events/processor.rs:376

Methodhttp_error

(status_code: u16, response_body: String)

src/notifications/mod.rs:64

Methodincrement_notification_retry

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

src/database/repository.rs:434

Methodincrement_retry

(&mut self)

src/events/mod.rs:80

Functioninitialize_invoke

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

parsers/drift_protocol/src/instructions.rs:1106

Functioninitialize_invoke_signed

( accounts: InitializeAccounts<'_, '_>, args: InitializeIxArgs, seeds: &[&[&[u8]]], )

parsers/drift_protocol/src/instructions.rs:1122

Functioninitialize_ix

( keys: InitializeKeys, args: InitializeIxArgs, )

parsers/drift_protocol/src/instructions.rs:1091

Functioninitialize_verify_account_keys

( accounts: InitializeAccounts<'_, '_>, keys: InitializeKeys, )

parsers/drift_protocol/src/instructions.rs:1129

Functioninitialize_verify_account_privileges

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

parsers/drift_protocol/src/instructions.rs:1175

Methodinsert_liquidation_event

(&self, event: &LiquidationEventInsert)

src/database/repository.rs:113

Methodinsert_metric

(&self, metric: &SystemMetricsInsert)

src/database/repository.rs:549

Methodinsert_notification_log

( &self, _log: &NotificationLogInsert, )

src/notifications/service.rs:432

Methodis_duplicate

(&self, other: &Self)

( &self, accounts: &[AccountMeta], instruction_name: &str, )

src/instruction_account_mapper.rs:44

Methodmark_liquidation_event_notification_sent

(&self, id: Uuid)

src/database/repository.rs:209

Methodmark_liquidation_event_notification_sent

( &self, _id: Uuid, )

src/events/processor.rs:479

Methodmark_liquidation_event_processed

(&self, id: Uuid)

src/database/repository.rs:196

Methodmigrate

(&self)

src/database/repository.rs:94

Methodname

(&self)

parsers/kamino_protocol/src/instructions.rs:19

Methodnew

( notification_repo: Arc<dyn NotificationRepository + Send + Sync>, config: NotificationConfig

src/notifications/service.rs:20

Methodnew

(webhook_urls: Vec<String>, timeout_seconds: u64)

src/notifications/webhook.rs:18

Methodnew

( signature: String, slot: i64, block_time: Option<DateTime<Utc>>, protocol: S

src/database/models.rs:69

Methodnew

(pool: PgPool)

src/database/repository.rs:90

Methodnew

( liquidation_repo: Arc<dyn LiquidationRepository + Send + Sync>, notification_repo: Arc<dyn N

src/events/processor.rs:26

Methodnew

()

src/events/validator.rs:16

Methodnew

( signature: String, slot: i64, block_time: Option<DateTime<Utc>>, protocol: S

src/events/mod.rs:36

Methodnew

( repository: Arc<PostgresRepository>, notification_service: Arc<NotificationService>,

src/events/handler.rs:27

Methodparse_email_config

()

src/config.rs:271

Methodprocess_dead_letter_queue

(error_repo: Arc<dyn ErrorRepository + Send + Sync>)

src/events/handler.rs:311

Methodprocess_liquidation_events_static

( mut liquidation_receiver: mpsc::Receiver<LiquidationEventMessage>, max_concurrent_events: us

src/events/handler.rs:142

Methodprocess_notification_batch

( notification_service: &NotificationService, batch: &mut Vec<NotificationEventMessage>, )

src/events/handler.rs:257

Methodprocess_notifications

( notification_service: Arc<NotificationService>, mut receiver: mpsc::Receiver<NotificationEve

src/events/handler.rs:211

Methodprocess_pending_notifications

(&self)

src/notifications/service.rs:267

Methodprocess_retries

(event_processor: EventProcessor, retry_interval: Duration)

src/events/handler.rs:287

Methodprovider_type

(&self)

src/notifications/service.rs:495

Methodprovider_type

(&self)

src/notifications/webhook.rs:154

Methodretry_after

(error: String, retry_after: DateTime<Utc>)

src/events/mod.rs:152

Functionserialize_i128_as_string

(value: &i128, serializer: S)

parsers/drift_protocol/src/serializer.rs:23

Functionserialize_i128_as_string

(value: &i128, serializer: S)

parsers/kamino_protocol/src/serializer.rs:23

Functionserialize_option_pubkey

(value: &Option<Pubkey>, serializer: S)

src/serialization.rs:10

Functionserialize_pubkey

(value: &Pubkey, serializer: S)

src/serialization.rs:3

Functionserialize_u128_as_string

(value: &u128, serializer: S)

parsers/drift_protocol/src/serializer.rs:6

Functionserialize_u128_as_string

(value: &u128, serializer: S)

parsers/kamino_protocol/src/serializer.rs:6

Methodsuccess

()

src/notifications/mod.rs:31

Methodsuccess

()

src/events/mod.rs:134

Methodsuccess_with_id

(delivery_id: String)

src/notifications/mod.rs:42

Functiontest_add_provider

()

src/notifications/service.rs:510

Functiontest_config_validation

()

src/config.rs:442

Functiontest_discord_webhook_provider_creation

()

src/notifications/webhook.rs:469

Functiontest_discord_webhook_validation

()

src/config.rs:478

Functiontest_duplicate_event_detection

()

src/events/processor.rs:513

Functiontest_empty_signature

()

src/events/validator.rs:414

Functiontest_health_check

()

src/notifications/service.rs:523

Functiontest_invalid_discord_webhook_url

()

src/notifications/webhook.rs:480

Functiontest_negative_amounts

()

src/events/validator.rs:424

Functiontest_notification_service_creation

()

src/notifications/service.rs:501

Functiontest_process_liquidation_event_success

()

src/events/processor.rs:507

Functiontest_retry_logic

()

src/events/processor.rs:518

Functiontest_same_liquidator_liquidatee

()

src/events/validator.rs:434

Functiontest_valid_event

()

src/events/validator.rs:405

Functiontest_webhook_payload_creation

()

src/notifications/webhook.rs:447

Functiontest_webhook_provider_creation

()

src/notifications/webhook.rs:459

Functiontest_webhook_url_validation

parsers/kamino_protocol/src/instructions.rs:63

Methodupdate_config

(&mut self, config: NotificationConfig)

src/notifications/service.rs:397

Methodupdate_notification_status

( &self, id: Uuid, status: &str, response: Option<serde_json::Value>, )

src/database/repository.rs:414

Methodupdate_position_health_ratio

(&self, id: Uuid, health_ratio: f64)

src/database/repository.rs:341

Methodupsert_position

(&self, position: &Position)

src/database/repository.rs:259

Methodwith_correlation_id

(mut self, correlation_id: String)

src/events/mod.rs:201

Methodwith_max_retry_attempts

(mut self, max_retries: u32)

src/events/processor.rs:382

← previous next →101–200 of 203, ranked by callers