Struct SqlColdBackend 

pub struct SqlColdBackend { /* private fields */ }

Available on crate features sqlite or postgres only.

SQL-based cold storage backend.

Uses sqlx::Any for database-agnostic access, supporting both PostgreSQL and SQLite through a single implementation. The backend is determined by the connection URL at construction time.

Example

use signet_cold_sql::SqlColdBackend;

// SQLite (in-memory)
let backend = SqlColdBackend::connect("sqlite::memory:").await.unwrap();

// PostgreSQL
let backend = SqlColdBackend::connect("postgres://localhost/signet").await.unwrap();

Implementations

impl SqlColdBackend

pub async fn new(pool: AnyPool) -> Result<Self, SqlColdError>

Create a new SQL cold storage backend from an existing AnyPool.

Auto-detects the database backend and creates all tables if they do not already exist. Callers must ensure sqlx::any::install_default_drivers has been called before constructing the pool.

pub async fn connect(url: &str) -> Result<Self, SqlColdError>

Connect to a database URL and create the backend.

Installs the default sqlx drivers on the first call. The database type is inferred from the URL scheme (sqlite: or postgres:).

For SQLite in-memory databases (sqlite::memory:), the pool is limited to one connection to ensure all operations share the same database.

Trait Implementations

impl Clone for SqlColdBackend

fn clone(&self) -> SqlColdBackend

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ColdStorage for SqlColdBackend

async fn get_header( &self, spec: HeaderSpecifier, ) -> ColdResult<Option<SealedHeader>>

Get a header by specifier.

async fn get_headers( &self, specs: Vec<HeaderSpecifier>, ) -> ColdResult<Vec<Option<SealedHeader>>>

Get multiple headers by specifiers.

async fn get_transaction( &self, spec: TransactionSpecifier, ) -> ColdResult<Option<Confirmed<RecoveredTx>>>

Get a transaction by specifier, with block confirmation metadata.

async fn get_transactions_in_block( &self, block: BlockNumber, ) -> ColdResult<Vec<RecoveredTx>>

Get all transactions in a block.

async fn get_transaction_count(&self, block: BlockNumber) -> ColdResult<u64>

Get the number of transactions in a block.

async fn get_receipt( &self, spec: ReceiptSpecifier, ) -> ColdResult<Option<ColdReceipt>>

Get a receipt by specifier.

async fn get_receipts_in_block( &self, block: BlockNumber, ) -> ColdResult<Vec<ColdReceipt>>

Get all receipts in a block.

async fn get_signet_events( &self, spec: SignetEventsSpecifier, ) -> ColdResult<Vec<DbSignetEvent>>

Get signet events by specifier.

async fn get_zenith_header( &self, spec: ZenithHeaderSpecifier, ) -> ColdResult<Option<DbZenithHeader>>

Get a zenith header by specifier.

async fn get_zenith_headers( &self, spec: ZenithHeaderSpecifier, ) -> ColdResult<Vec<DbZenithHeader>>

Get multiple zenith headers by specifier.

async fn get_logs( &self, filter: &Filter, max_logs: usize, ) -> ColdResult<Vec<RpcLog>>

Filter logs by block range, address, and topics.

async fn produce_log_stream(&self, filter: &Filter, params: StreamParams)

Produce a log stream by iterating blocks and sending matching logs.

async fn get_latest_block(&self) -> ColdResult<Option<BlockNumber>>

Get the latest block number in storage.

async fn append_block(&self, data: BlockData) -> ColdResult<()>

Append a single block to cold storage.

async fn append_blocks(&self, data: Vec<BlockData>) -> ColdResult<()>

Append multiple blocks to cold storage.

async fn truncate_above(&self, block: BlockNumber) -> ColdResult<()>

Truncate all data above the given block number (exclusive).

impl Debug for SqlColdBackend

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

Formats the value using the given formatter.