pub struct AuthorityEpochTablesReadOnly {Show 42 fields
pub signed_transactions: DBMap<TransactionDigest, TrustedEnvelope<SenderSignedData, AuthoritySignInfo>>,
pub owned_object_locked_transactions: DBMap<ObjectRef, LockDetailsWrapper>,
pub effects_signatures: DBMap<TransactionDigest, AuthoritySignInfo>,
pub transaction_cert_signatures: DBMap<TransactionDigest, AuthorityStrongQuorumSignInfo>,
pub assigned_shared_object_versions: DBMap<TransactionDigest, Vec<(ObjectID, SequenceNumber)>>,
pub assigned_shared_object_versions_v2: DBMap<TransactionKey, Vec<(ObjectID, SequenceNumber)>>,
pub next_shared_object_versions: DBMap<ObjectID, SequenceNumber>,
pub pending_execution: DBMap<TransactionDigest, TrustedExecutableTransaction>,
pub consensus_message_processed: DBMap<SequencedConsensusTransactionKey, bool>,
pub pending_consensus_transactions: DBMap<ConsensusTransactionKey, ConsensusTransaction>,
pub consensus_message_order: DBMap<ExecutionIndices, TransactionDigest>,
pub last_consensus_index: DBMap<u64, ExecutionIndicesWithHash>,
pub last_consensus_stats: DBMap<u64, ExecutionIndicesWithStats>,
pub checkpoint_boundary: DBMap<u64, u64>,
pub reconfig_state: DBMap<u64, ReconfigState>,
pub end_of_publish: DBMap<AuthorityName, ()>,
pub final_epoch_checkpoint: DBMap<u64, u64>,
pub pending_checkpoints: DBMap<CheckpointHeight, PendingCheckpoint>,
pub pending_checkpoints_v2: DBMap<CheckpointHeight, PendingCheckpointV2>,
pub builder_digest_to_checkpoint: DBMap<TransactionDigest, CheckpointSequenceNumber>,
pub transaction_key_to_digest: DBMap<TransactionKey, TransactionDigest>,
pub pending_checkpoint_signatures: DBMap<(CheckpointSequenceNumber, u64), CheckpointSignatureMessage>,
pub user_signatures_for_checkpoints: DBMap<TransactionDigest, Vec<GenericSignature>>,
pub builder_checkpoint_summary: DBMap<CheckpointSequenceNumber, CheckpointSummary>,
pub builder_checkpoint_summary_v2: DBMap<CheckpointSequenceNumber, BuilderCheckpointSummary>,
pub state_hash_by_checkpoint: DBMap<CheckpointSequenceNumber, Accumulator>,
pub authority_capabilities: DBMap<AuthorityName, AuthorityCapabilities>,
pub override_protocol_upgrade_buffer_stake: DBMap<u64, u64>,
pub executed_transactions_to_checkpoint: DBMap<TransactionDigest, CheckpointSequenceNumber>,
pub oauth_provider_jwk: DBMap<JwkId, JWK>,
pub pending_jwks: DBMap<(AuthorityName, JwkId, JWK), ()>,
pub active_jwks: DBMap<(u64, (JwkId, JWK)), ()>,
pub deferred_transactions: DBMap<DeferralKey, Vec<VerifiedSequencedConsensusTransaction>>,
pub randomness_rounds_written: DBMap<RandomnessRound, ()>,
pub dkg_processed_messages: DBMap<PartyId, ProcessedMessage<G2Element, G2Element>>,
pub dkg_used_messages: DBMap<u64, UsedProcessedMessages<G2Element, G2Element>>,
pub dkg_confirmations: DBMap<PartyId, Confirmation<G2Element>>,
pub dkg_output: DBMap<u64, Output<G2Element, G2Element>>,
pub randomness_rounds_pending: DBMap<RandomnessRound, ()>,
pub randomness_next_round: DBMap<u64, RandomnessRound>,
pub randomness_highest_completed_round: DBMap<u64, RandomnessRound>,
pub randomness_last_round_timestamp: DBMap<u64, TimestampMs>,
}
Expand description
Create an intermediate struct used to open the DBMap tables in secondary mode This is only used internally
Fields§
§signed_transactions: DBMap<TransactionDigest, TrustedEnvelope<SenderSignedData, AuthoritySignInfo>>
§owned_object_locked_transactions: DBMap<ObjectRef, LockDetailsWrapper>
§effects_signatures: DBMap<TransactionDigest, AuthoritySignInfo>
§transaction_cert_signatures: DBMap<TransactionDigest, AuthorityStrongQuorumSignInfo>
§pending_execution: DBMap<TransactionDigest, TrustedExecutableTransaction>
§consensus_message_processed: DBMap<SequencedConsensusTransactionKey, bool>
§pending_consensus_transactions: DBMap<ConsensusTransactionKey, ConsensusTransaction>
§consensus_message_order: DBMap<ExecutionIndices, TransactionDigest>
§last_consensus_index: DBMap<u64, ExecutionIndicesWithHash>
§last_consensus_stats: DBMap<u64, ExecutionIndicesWithStats>
§checkpoint_boundary: DBMap<u64, u64>
§reconfig_state: DBMap<u64, ReconfigState>
§end_of_publish: DBMap<AuthorityName, ()>
§final_epoch_checkpoint: DBMap<u64, u64>
§pending_checkpoints: DBMap<CheckpointHeight, PendingCheckpoint>
§pending_checkpoints_v2: DBMap<CheckpointHeight, PendingCheckpointV2>
§builder_digest_to_checkpoint: DBMap<TransactionDigest, CheckpointSequenceNumber>
§transaction_key_to_digest: DBMap<TransactionKey, TransactionDigest>
§pending_checkpoint_signatures: DBMap<(CheckpointSequenceNumber, u64), CheckpointSignatureMessage>
§user_signatures_for_checkpoints: DBMap<TransactionDigest, Vec<GenericSignature>>
§builder_checkpoint_summary: DBMap<CheckpointSequenceNumber, CheckpointSummary>
§builder_checkpoint_summary_v2: DBMap<CheckpointSequenceNumber, BuilderCheckpointSummary>
§state_hash_by_checkpoint: DBMap<CheckpointSequenceNumber, Accumulator>
§override_protocol_upgrade_buffer_stake: DBMap<u64, u64>
§executed_transactions_to_checkpoint: DBMap<TransactionDigest, CheckpointSequenceNumber>
§oauth_provider_jwk: DBMap<JwkId, JWK>
§pending_jwks: DBMap<(AuthorityName, JwkId, JWK), ()>
§active_jwks: DBMap<(u64, (JwkId, JWK)), ()>
§deferred_transactions: DBMap<DeferralKey, Vec<VerifiedSequencedConsensusTransaction>>
§randomness_rounds_written: DBMap<RandomnessRound, ()>
§dkg_processed_messages: DBMap<PartyId, ProcessedMessage<G2Element, G2Element>>
§dkg_used_messages: DBMap<u64, UsedProcessedMessages<G2Element, G2Element>>
§dkg_confirmations: DBMap<PartyId, Confirmation<G2Element>>
§dkg_output: DBMap<u64, Output<G2Element, G2Element>>
§randomness_rounds_pending: DBMap<RandomnessRound, ()>
§randomness_next_round: DBMap<u64, RandomnessRound>
§randomness_highest_completed_round: DBMap<u64, RandomnessRound>
§randomness_last_round_timestamp: DBMap<u64, TimestampMs>
Implementations§
source§impl AuthorityEpochTablesReadOnly
impl AuthorityEpochTablesReadOnly
sourcepub fn open_tables_read_only(
primary_path: PathBuf,
with_secondary_path: Option<PathBuf>,
metric_conf: MetricConf,
global_db_options_override: Option<Options>
) -> Self
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
sourcepub fn dump(
&self,
cf_name: &str,
page_size: u16,
page_number: usize
) -> Result<BTreeMap<String, String>>
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
sourcepub fn table_summary(&self, table_name: &str) -> Result<TableSummary>
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
sourcepub fn count_keys(&self, table_name: &str) -> Result<usize>
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)>
sourcepub fn try_catch_up_with_primary_all(&self) -> Result<()>
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§
source§impl TypedStoreDebug for AuthorityEpochTablesReadOnly
impl TypedStoreDebug for AuthorityEpochTablesReadOnly
source§fn dump_table(
&self,
table_name: String,
page_size: u16,
page_number: usize
) -> Result<BTreeMap<String, String>>
fn dump_table( &self, table_name: String, page_size: u16, page_number: usize ) -> Result<BTreeMap<String, String>>
Dump a DB table with pagination
source§fn primary_db_name(&self) -> String
fn primary_db_name(&self) -> String
Get the name of the DB. This is simply the name of the struct
source§fn describe_all_tables(&self) -> BTreeMap<String, (String, String)>
fn describe_all_tables(&self) -> BTreeMap<String, (String, String)>
Get a map of table names to key-value types
source§fn count_table_keys(&self, table_name: String) -> Result<usize>
fn count_table_keys(&self, table_name: String) -> Result<usize>
Count the entries in the table
source§fn table_summary(&self, table_name: String) -> Result<TableSummary>
fn table_summary(&self, table_name: String) -> Result<TableSummary>
Return table summary of the input table
Auto Trait Implementations§
impl !RefUnwindSafe for AuthorityEpochTablesReadOnly
impl Send for AuthorityEpochTablesReadOnly
impl Sync for AuthorityEpochTablesReadOnly
impl Unpin for AuthorityEpochTablesReadOnly
impl !UnwindSafe for AuthorityEpochTablesReadOnly
Blanket Implementations§
§impl<T> AnySync for T
impl<T> AnySync for T
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self
to use its Binary
implementation when Debug
-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self
to use its Display
implementation when
Debug
-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self
to use its LowerExp
implementation when
Debug
-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self
to use its LowerHex
implementation when
Debug
-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self
to use its Octal
implementation when Debug
-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self
to use its Pointer
implementation when
Debug
-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self
to use its UpperExp
implementation when
Debug
-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self
to use its UpperHex
implementation when
Debug
-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
Formats each item in a sequence. Read more
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a Request
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self
and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self
and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self
, then passes self.as_ref()
into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self
, then passes self.as_mut()
into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self
, then passes self.deref()
into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B>
of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B>
of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R>
view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R>
view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target
of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target
of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap()
only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut()
only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow()
only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut()
only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref()
only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut()
only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref()
only in debug builds, and is erased in release
builds.