Struct RestReadStore 

pub struct RestReadStore { /* private fields */ }

Implementations

impl RestReadStore

pub fn new(state: Arc<AuthorityState>, rocks: RocksDbStore) -> Self

Trait Implementations

impl ChildObjectResolver for RestReadStore

fn read_child_object( &self, parent: &ObjectID, child: &ObjectID, child_version_upper_bound: SequenceNumber, ) -> SuiResult<Option<Object>>

child must have an ObjectOwner ownership equal to owner.

fn get_object_received_at_version( &self, _owner: &ObjectID, _receiving_object_id: &ObjectID, _receive_object_at_version: SequenceNumber, _epoch_id: EpochId, ) -> SuiResult<Option<Object>>

receiving_object_id must have an AddressOwner ownership equal to owner. get_object_received_at_version must be the exact version at which the object will be received, and it cannot have been previously received at that version. NB: An object not existing at that version, and not having valid access to the object will be treated exactly the same and Ok(None) must be returned.

impl ObjectStore for RestReadStore

fn get_object(&self, object_id: &ObjectID) -> Option<Object>

fn get_object_by_key( &self, object_id: &ObjectID, version: VersionNumber, ) -> Option<Object>

fn multi_get_objects(&self, object_ids: &[ObjectID]) -> Vec<Option<Object>>

fn multi_get_objects_by_key( &self, object_keys: &[ObjectKey], ) -> Vec<Option<Object>>

impl ReadStore for RestReadStore

fn get_committee(&self, epoch: EpochId) -> Option<Arc<Committee>>

fn get_latest_checkpoint(&self) -> Result<VerifiedCheckpoint>

Get the latest available checkpoint. This is the latest executed checkpoint.

fn get_highest_verified_checkpoint(&self) -> Result<VerifiedCheckpoint>

Get the highest verified checkpint. This is the highest checkpoint summary that has been verified, generally by state-sync. Only the checkpoint header is guaranteed to be present in the store.

fn get_highest_synced_checkpoint(&self) -> Result<VerifiedCheckpoint>

Get the highest synced checkpint. This is the highest checkpoint that has been synced from state-synce. The checkpoint header, contents, transactions, and effects of this checkpoint are guaranteed to be present in the store

fn get_lowest_available_checkpoint(&self) -> Result<CheckpointSequenceNumber>

Lowest available checkpoint for which transaction and checkpoint data can be requested.

fn get_checkpoint_by_digest( &self, digest: &CheckpointDigest, ) -> Option<VerifiedCheckpoint>

fn get_checkpoint_by_sequence_number( &self, sequence_number: CheckpointSequenceNumber, ) -> Option<VerifiedCheckpoint>

fn get_checkpoint_contents_by_digest( &self, digest: &CheckpointContentsDigest, ) -> Option<CheckpointContents>

fn get_checkpoint_contents_by_sequence_number( &self, sequence_number: CheckpointSequenceNumber, ) -> Option<CheckpointContents>

fn get_transaction( &self, digest: &TransactionDigest, ) -> Option<Arc<VerifiedTransaction>>

fn get_transaction_effects( &self, digest: &TransactionDigest, ) -> Option<TransactionEffects>

fn get_events(&self, digest: &TransactionDigest) -> Option<TransactionEvents>

fn get_full_checkpoint_contents( &self, sequence_number: Option<CheckpointSequenceNumber>, digest: &CheckpointContentsDigest, ) -> Option<VersionedFullCheckpointContents>

Get a “full” checkpoint for purposes of state-sync “full” checkpoints include: header, contents, transactions, effects. sequence_number is optional since we can always query it using the digest. However if it is provided, we can avoid an extra db lookup.

fn get_unchanged_loaded_runtime_objects( &self, digest: &TransactionDigest, ) -> Option<Vec<ObjectKey>>

fn get_transaction_checkpoint( &self, digest: &TransactionDigest, ) -> Option<CheckpointSequenceNumber>

fn get_latest_checkpoint_sequence_number(&self) -> Result<u64, Error>

Get the latest available checkpoint sequence number. This is the sequence number of the latest executed checkpoint.

fn get_latest_epoch_id(&self) -> Result<u64, Error>

Get the epoch of the latest checkpoint

fn multi_get_transactions( &self, tx_digests: &[TransactionDigest], ) -> Vec<Option<Arc<VerifiedEnvelope<SenderSignedData, EmptySignInfo>>>>

fn multi_get_transaction_effects( &self, tx_digests: &[TransactionDigest], ) -> Vec<Option<TransactionEffects>>

fn multi_get_events( &self, event_digests: &[TransactionDigest], ) -> Vec<Option<TransactionEvents>>

fn get_checkpoint_data( &self, checkpoint: VerifiedEnvelope<CheckpointSummary, AuthorityQuorumSignInfo<true>>, checkpoint_contents: CheckpointContents, ) -> Result<Checkpoint, Error>

impl RpcIndexes for RestReadStore

fn get_epoch_info(&self, epoch: EpochId) -> Result<Option<EpochInfo>>

fn owned_objects_iter( &self, owner: SuiAddress, object_type: Option<StructTag>, cursor: Option<OwnedObjectInfo>, ) -> Result<Box<dyn Iterator<Item = Result<OwnedObjectInfo, TypedStoreError>> + '_>>

fn dynamic_field_iter( &self, parent: ObjectID, cursor: Option<ObjectID>, ) -> Result<Box<dyn Iterator<Item = Result<DynamicFieldKey, TypedStoreError>> + '_>>

fn get_coin_info(&self, coin_type: &StructTag) -> Result<Option<CoinInfo>>

fn get_balance( &self, owner: &SuiAddress, coin_type: &StructTag, ) -> Result<Option<BalanceInfo>>

fn balance_iter( &self, owner: &SuiAddress, cursor: Option<(SuiAddress, StructTag)>, ) -> Result<BalanceIterator<'_>>

fn package_versions_iter( &self, original_id: ObjectID, cursor: Option<u64>, ) -> Result<Box<dyn Iterator<Item = Result<(u64, ObjectID), TypedStoreError>> + '_>>

fn get_highest_indexed_checkpoint_seq_number( &self, ) -> Result<Option<CheckpointSequenceNumber>>

fn authenticated_event_iter( &self, stream_id: SuiAddress, start_checkpoint: u64, start_accumulator_version: Option<u64>, start_transaction_idx: Option<u32>, start_event_idx: Option<u32>, end_checkpoint: u64, limit: u32, ) -> Result<Box<dyn Iterator<Item = Result<(u64, u64, u32, u32, Event), TypedStoreError>> + '_>>

impl RpcStateReader for RestReadStore

fn get_lowest_available_checkpoint_objects( &self, ) -> Result<CheckpointSequenceNumber>

Lowest available checkpoint for which object data can be requested.

fn get_chain_identifier(&self) -> Result<ChainIdentifier>

fn indexes(&self) -> Option<&dyn RpcIndexes>

fn get_struct_layout_with_overlay( &self, struct_tag: &StructTag, overlay: &ObjectSet, ) -> Result<Option<MoveTypeLayout>>

fn get_type_layout( &self, type_tag: &TypeTag, ) -> Result<Option<MoveTypeLayout>, Error>

fn get_struct_layout( &self, struct_tag: &StructTag, ) -> Result<Option<MoveTypeLayout>, Error>