Struct BridgeOrchestratorTablesReadOnly

pub struct BridgeOrchestratorTablesReadOnly {
    pub pending_actions: DBMap<BridgeActionDigest, BridgeAction>,
    pub sui_syncer_cursors: DBMap<Identifier, EventID>,
    pub eth_syncer_cursors: DBMap<Address, u64>,
}

Create an intermediate struct used to open the DBMap tables in secondary mode This is only used internally

Fields

pending_actions: DBMap<BridgeActionDigest, BridgeAction>

sui_syncer_cursors: DBMap<Identifier, EventID>

eth_syncer_cursors: DBMap<Address, u64>

Implementations

impl BridgeOrchestratorTablesReadOnly

pub fn open_tables_read_only( primary_path: PathBuf, with_secondary_path: Option<PathBuf>, metric_conf: MetricConf, global_db_options_override: Option<Options>, ) -> Self

Open in read only mode. No limitation on number of processes to do this

pub fn dump( &self, cf_name: &str, page_size: u16, page_number: usize, ) -> Result<BTreeMap<String, String>>

Dump all key-value pairs in the page at the given table name Tables must be opened in read only mode using open_tables_read_only

pub fn table_summary(&self, table_name: &str) -> Result<TableSummary>

Get key value sizes from the db Tables must be opened in read only mode using open_tables_read_only

pub fn count_keys(&self, table_name: &str) -> Result<usize>

Count the keys in this table Tables must be opened in read only mode using open_tables_read_only

pub fn describe_tables() -> BTreeMap<String, (String, String)>

pub fn try_catch_up_with_primary_all(&self) -> Result<()>

Try catch up with primary for all tables. This can be a slow operation Tables must be opened in read only mode using open_tables_read_only

Trait Implementations

impl TypedStoreDebug for BridgeOrchestratorTablesReadOnly

fn dump_table( &self, table_name: String, page_size: u16, page_number: usize, ) -> Result<BTreeMap<String, String>>

Dump a DB table with pagination

fn primary_db_name(&self) -> String

Get the name of the DB. This is simply the name of the struct

fn describe_all_tables(&self) -> BTreeMap<String, (String, String)>

Get a map of table names to key-value types

fn count_table_keys(&self, table_name: String) -> Result<usize>

Count the entries in the table

fn table_summary(&self, table_name: String) -> Result<TableSummary>

Return table summary of the input table