Trait StateStore

pub trait StateStore:
    StateStoreRead
    + StaticSendSync
    + Clone {
    type Local: LocalStateStore;

    // Required methods
    fn try_wait_epoch(
        &self,
        epoch: HummockReadEpoch,
        options: TryWaitEpochOptions,
    ) -> impl Future<Output = Result<(), StorageError>> + Send;
    fn new_local(
        &self,
        option: NewLocalOptions,
    ) -> impl Future<Output = Self::Local> + Send;

    // Provided method
    fn monitored(
        self,
        storage_metrics: Arc<MonitoredStorageMetrics>,
    ) -> MonitoredStateStore<Self> { ... }
}

Required Associated Types

type Local: LocalStateStore

Required Methods

fn try_wait_epoch( &self, epoch: HummockReadEpoch, options: TryWaitEpochOptions, ) -> impl Future<Output = Result<(), StorageError>> + Send

If epoch is Committed, we will wait until the epoch is committed and its data is ready to read. If epoch is Current, we will only check if the data can be read with this epoch.

fn new_local( &self, option: NewLocalOptions, ) -> impl Future<Output = Self::Local> + Send

Provided Methods

fn monitored( self, storage_metrics: Arc<MonitoredStorageMetrics>, ) -> MonitoredStateStore<Self>

Creates a MonitoredStateStore from this state store, with given stats.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl StateStore for Box<dyn DynamicDispatchedStateStore>

type Local = Box<dyn DynamicDispatchedLocalStateStore>

fn try_wait_epoch( &self, epoch: HummockReadEpoch, options: TryWaitEpochOptions, ) -> impl Future<Output = Result<(), StorageError>> + Send

fn new_local( &self, option: NewLocalOptions, ) -> impl Future<Output = <Box<dyn DynamicDispatchedStateStore> as StateStore>::Local> + Send

Implementors

impl StateStore for HummockStorage

type Local = LocalHummockStorage

impl StateStore for PanicStateStore

type Local = PanicStateStore

impl<A, E> StateStore for VerifyStateStore<A, E>

where A: StateStore, E: StateStore,

type Local = VerifyStateStore<<A as StateStore>::Local, <E as StateStore>::Local>

impl<R> StateStore for RangeKvStateStore<R>

where R: RangeKv,

type Local = MemtableLocalStateStore<RangeKvStateStore<R>>

impl<S> StateStore for MonitoredStateStore<S>

where S: StateStore,

type Local = MonitoredStateStore<<S as StateStore>::Local>