Struct SqliteStorage 

pub struct SqliteStorage { /* private fields */ }

SQLite-based storage implementation

Implementations

impl SqliteStorage

pub fn new(path: &Path) -> Result<Self, StorageError>

Creates a new SQLite storage

Arguments

• path - Path to the SQLite database file

Returns

A new SqliteStorage instance or an error

Trait Implementations

impl Storage for SqliteStorage

fn list_payments<'life0, 'async_trait>( &'life0 self, request: ListPaymentsRequest, ) -> Pin<Box<dyn Future<Output = Result<Vec<Payment>, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lists payments with optional filters and pagination

fn insert_payment<'life0, 'async_trait>( &'life0 self, payment: Payment, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Inserts a payment into storage

fn set_payment_metadata<'life0, 'async_trait>( &'life0 self, payment_id: String, metadata: PaymentMetadata, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Inserts payment metadata into storage

fn set_cached_item<'life0, 'async_trait>( &'life0 self, key: String, value: String, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_cached_item<'life0, 'async_trait>( &'life0 self, key: String, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn delete_cached_item<'life0, 'async_trait>( &'life0 self, key: String, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_payment_by_id<'life0, 'async_trait>( &'life0 self, id: String, ) -> Pin<Box<dyn Future<Output = Result<Payment, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets a payment by its ID

fn get_payment_by_invoice<'life0, 'async_trait>( &'life0 self, invoice: String, ) -> Pin<Box<dyn Future<Output = Result<Option<Payment>, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets a payment by its invoice

fn add_deposit<'life0, 'async_trait>( &'life0 self, txid: String, vout: u32, amount_sats: u64, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Add a deposit to storage

fn delete_deposit<'life0, 'async_trait>( &'life0 self, txid: String, vout: u32, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Removes an unclaimed deposit from storage

fn list_deposits<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<DepositInfo>, StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lists all unclaimed deposits from storage

fn update_deposit<'life0, 'async_trait>( &'life0 self, txid: String, vout: u32, payload: UpdateDepositPayload, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Updates or inserts unclaimed deposit details

impl SyncStorage for SqliteStorage

fn add_outgoing_change<'life0, 'async_trait>( &'life0 self, record: UnversionedRecordChange, ) -> Pin<Box<dyn Future<Output = Result<u64, SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn complete_outgoing_sync<'life0, 'async_trait>( &'life0 self, record: Record, ) -> Pin<Box<dyn Future<Output = Result<(), SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_pending_outgoing_changes<'life0, 'async_trait>( &'life0 self, limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<OutgoingChange>, SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_last_revision<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64, SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the revision number of the last synchronized record

fn insert_incoming_records<'life0, 'async_trait>( &'life0 self, records: Vec<Record>, ) -> Pin<Box<dyn Future<Output = Result<(), SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Insert incoming records from remote sync

fn delete_incoming_record<'life0, 'async_trait>( &'life0 self, record: Record, ) -> Pin<Box<dyn Future<Output = Result<(), SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete an incoming record after it has been processed

fn rebase_pending_outgoing_records<'life0, 'async_trait>( &'life0 self, revision: u64, ) -> Pin<Box<dyn Future<Output = Result<(), SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update revision numbers of pending outgoing records to be higher than the given revision

fn get_incoming_records<'life0, 'async_trait>( &'life0 self, limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<IncomingChange>, SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get incoming records that need to be processed, up to the specified limit

fn get_latest_outgoing_change<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<OutgoingChange>, SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the latest outgoing record if any exists

fn update_record_from_incoming<'life0, 'async_trait>( &'life0 self, record: Record, ) -> Pin<Box<dyn Future<Output = Result<(), SyncStorageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update the sync state record from an incoming record