Struct RpcIndexStore

pub struct RpcIndexStore { /* private fields */ }

Implementations

impl RpcIndexStore

pub async fn new( dir: &Path, authority_store: &AuthorityStore, checkpoint_store: &CheckpointStore, epoch_store: &AuthorityPerEpochStore, package_store: &Arc<dyn BackingPackageStore + Send + Sync>, ) -> Self

pub fn new_without_init(dir: &Path) -> Self

pub fn prune( &self, pruned_checkpoint_watermark: u64, checkpoint_contents_to_prune: &[CheckpointContents], ) -> Result<(), TypedStoreError>

pub fn index_checkpoint( &self, checkpoint: &CheckpointData, resolver: &mut dyn LayoutResolver, )

Index a checkpoint and stage the index updated in pending_updates.

Updates will not be committed to the database until commit_update_for_checkpoint is called.

pub fn commit_update_for_checkpoint( &self, checkpoint: u64, ) -> Result<(), StorageError>

Commits the pending updates for the provided checkpoint number.

Invariants:

• index_checkpoint must have been called for the provided checkpoint
• Callers of this function must ensure that it is called for each checkpoint in sequential order. This will panic if the provided checkpoint does not match the expected next checkpoint to commit.

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

pub fn get_transaction_info( &self, digest: &TransactionDigest, ) -> Result<Option<TransactionInfo>, TypedStoreError>

pub fn owner_iter( &self, owner: SuiAddress, object_type: Option<StructTag>, cursor: Option<OwnerIndexKey>, ) -> Result<impl Iterator<Item = Result<(OwnerIndexKey, OwnerIndexInfo), TypedStoreError>> + '_, TypedStoreError>

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

pub fn get_coin_info( &self, coin_type: &StructTag, ) -> Result<Option<CoinIndexInfo>, TypedStoreError>

Trait Implementations

impl RpcIndexes for RpcIndexStore

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

fn get_transaction_info( &self, digest: &TransactionDigest, ) -> Result<Option<TransactionInfo>>

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, DynamicFieldIndexInfo), TypedStoreError>> + '_>>

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