Struct SqlStorage 

pub struct SqlStorage {
    pool: DbPool,
    num_leaves: u32,
    recency: Arc<Recency>,
    _tmp: Option<Arc<TempDir>>,
}

Storage backed by SQLite or Postgres.

Fields

pool: DbPool

num_leaves: u32

recency: Arc<Recency>

Shared across all clones; all map operations are sync and never held across .await.

_tmp: Option<Arc<TempDir>>

Implementations

impl SqlStorage

async fn new( pool: DbPool, num_leaves: u32, tmp: Option<Arc<TempDir>>, ) -> Result<Self>

Trait Implementations

impl Clone for SqlStorage

fn clone(&self) -> SqlStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqlStorage

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

Formats the value using the given formatter.

impl Storage for SqlStorage

Available on crate feature client only.

async fn default() -> Result<Self>

Create a default, empty instance of the state.

async fn block_height(&self) -> Result<u64>

Get the number of blocks known to be in the chain.

async fn leaf_upper_bound( &self, id: impl Into<LeafRequest> + Send, ) -> Result<Option<LeafQueryData<SeqTypes>>>

Get the earliest available leaf which is later than or equal to the requested leaf.

async fn get_leaves_in_range( &self, start_height: u32, end_height: u32, ) -> Result<Vec<LeafQueryData<SeqTypes>>>

Get all leaves in the range [start, end)

async fn insert_leaf(&self, leaf: LeafQueryData<SeqTypes>) -> Result<()>

Add a leaf to the cache.

async fn stake_table_lower_bound( &self, epoch: EpochNumber, ) -> Result<Option<(EpochNumber, StakeTableState, Version, Version)>>

Get the stake table for the latest epoch which is not later than epoch.

async fn insert_stake_table( &self, epoch: EpochNumber, stake_table: &StakeTableState, epoch_root_protocol_version: Version, next_epoch_root_protocol_version: Version, ) -> Result<()>

Add a stake table to the cache.