Struct HummockStorageReadSnapshot

pub struct HummockStorageReadSnapshot {
    raw_epoch: u64,
    table_id: TableId,
    recent_versions: Arc<ArcSwap<RecentVersions>>,
    hummock_version_reader: HummockVersionReader,
    read_version_mapping: ReadOnlyReadVersionMapping,
    backup_reader: BackupReaderRef,
    hummock_meta_client: Arc<dyn HummockMetaClient>,
    simple_time_travel_version_cache: Arc<SimpleTimeTravelVersionCache>,
}

Fields

raw_epoch: u64

table_id: TableId

recent_versions: Arc<ArcSwap<RecentVersions>>

hummock_version_reader: HummockVersionReader

read_version_mapping: ReadOnlyReadVersionMapping

backup_reader: BackupReaderRef

hummock_meta_client: Arc<dyn HummockMetaClient>

simple_time_travel_version_cache: Arc<SimpleTimeTravelVersionCache>

Implementations

impl HummockStorageReadSnapshot

async fn get_inner( &self, key: TableKey<Bytes>, read_options: ReadOptions, ) -> StorageResult<Option<StateStoreKeyedRow>>

Gets the value of a specified key in the table specified in read_options. The result is based on a snapshot corresponding to the given epoch. if key has consistent hash virtual node value, then such value is stored in value_meta

If Ok(Some()) is returned, the key is found. If Ok(None) is returned, the key is not found. If Err() is returned, the searching for the key failed due to other non-EOF errors.

async fn iter_inner( &self, key_range: TableKeyRange, read_options: ReadOptions, ) -> StorageResult<HummockStorageIterator>

async fn rev_iter_inner( &self, key_range: TableKeyRange, read_options: ReadOptions, ) -> StorageResult<HummockStorageRevIterator>

async fn get_time_travel_version( &self, epoch: u64, table_id: TableId, ) -> StorageResult<PinnedVersion>

async fn build_read_version_tuple( &self, epoch: u64, key_range: TableKeyRange, read_options: &ReadOptions, ) -> StorageResult<(TableKeyRange, ReadVersionTuple)>

async fn build_read_version_tuple_from_backup( &self, epoch: u64, table_id: TableId, key_range: TableKeyRange, ) -> StorageResult<(TableKeyRange, ReadVersionTuple)>

async fn build_read_version_tuple_from_committed( &self, epoch: u64, table_id: TableId, key_range: TableKeyRange, ) -> StorageResult<(TableKeyRange, ReadVersionTuple)>

fn build_read_version_tuple_from_all( &self, epoch: u64, table_id: TableId, key_range: TableKeyRange, ) -> StorageResult<(TableKeyRange, ReadVersionTuple)>

Trait Implementations

impl Clone for HummockStorageReadSnapshot

fn clone(&self) -> HummockStorageReadSnapshot

Returns a copy of the value.

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

Performs copy-assignment from source.

impl StateStoreRead for HummockStorageReadSnapshot

type Iter = HummockStorageIteratorInner<'static>

type RevIter = HummockStorageRevIteratorInner<'static>

fn get_keyed_row( &self, key: TableKey<Bytes>, read_options: ReadOptions, ) -> impl Future<Output = StorageResult<Option<StateStoreKeyedRow>>> + Send + '_

Point gets a value from the state store. The result is based on a snapshot corresponding to the given epoch. Both full key and the value are returned.

fn iter( &self, key_range: TableKeyRange, read_options: ReadOptions, ) -> impl Future<Output = StorageResult<Self::Iter>> + '_

Opens and returns an iterator for given prefix_hint and full_key_range Internally, prefix_hint will be used to for checking bloom_filter and full_key_range used for iter. (if the prefix_hint not None, it should be be included in key_range) The returned iterator will iterate data based on a snapshot corresponding to the given epoch.

fn rev_iter( &self, key_range: TableKeyRange, read_options: ReadOptions, ) -> impl Future<Output = StorageResult<Self::RevIter>> + '_

fn get( &self, key: TableKey<Bytes>, read_options: ReadOptions, ) -> impl StorageFuture<'_, Option<Bytes>>

Point gets a value from the state store. The result is based on a snapshot corresponding to the given epoch. Only the value is returned.