Enum StateStoreImpl

pub enum StateStoreImpl {
    HummockStateStore(MonitoredStateStore<HummockStorageType>),
    MemoryStateStore(MonitoredStateStore<MemoryStateStoreType>),
    SledStateStore(MonitoredStateStore<SledStateStoreType>),
}

The type erased StateStore.

Variants

HummockStateStore(MonitoredStateStore<HummockStorageType>)

The Hummock state store, which operates on an S3-like service. URLs beginning with hummock will be automatically recognized as Hummock state store.

Example URLs:

• hummock+s3://bucket
• hummock+minio://KEY:SECRET@minio-ip:port
• hummock+memory (should only be used in 1 compute node mode)

MemoryStateStore(MonitoredStateStore<MemoryStateStoreType>)

In-memory B-Tree state store. Should only be used in unit and integration tests. If you want speed up e2e test, you should use Hummock in-memory mode instead. Also, this state store misses some critical implementation to ensure the correctness of persisting streaming state. (e.g., no read_epoch support, no async checkpoint)

SledStateStore(MonitoredStateStore<SledStateStoreType>)

Implementations

impl StateStoreImpl

pub fn is_hummock_state_store(&self) -> bool

Returns true if this is a StateStoreImpl::HummockStateStore, otherwise false

pub fn as_hummock_state_store_mut( &mut self, ) -> Option<&mut MonitoredStateStore<HummockStorageType>>

Optionally returns mutable references to the inner fields if this is a StateStoreImpl::HummockStateStore, otherwise None

pub fn as_hummock_state_store( &self, ) -> Option<&MonitoredStateStore<HummockStorageType>>

Optionally returns references to the inner fields if this is a StateStoreImpl::HummockStateStore, otherwise None

pub fn into_hummock_state_store( self, ) -> Result<MonitoredStateStore<HummockStorageType>, Self>

Returns the inner fields if this is a StateStoreImpl::HummockStateStore, otherwise returns back the enum in the Err case of the result

pub fn is_memory_state_store(&self) -> bool

Returns true if this is a StateStoreImpl::MemoryStateStore, otherwise false

pub fn as_memory_state_store_mut( &mut self, ) -> Option<&mut MonitoredStateStore<MemoryStateStoreType>>

Optionally returns mutable references to the inner fields if this is a StateStoreImpl::MemoryStateStore, otherwise None

pub fn as_memory_state_store( &self, ) -> Option<&MonitoredStateStore<MemoryStateStoreType>>

Optionally returns references to the inner fields if this is a StateStoreImpl::MemoryStateStore, otherwise None

pub fn into_memory_state_store( self, ) -> Result<MonitoredStateStore<MemoryStateStoreType>, Self>

Returns the inner fields if this is a StateStoreImpl::MemoryStateStore, otherwise returns back the enum in the Err case of the result

pub fn is_sled_state_store(&self) -> bool

Returns true if this is a StateStoreImpl::SledStateStore, otherwise false

pub fn as_sled_state_store_mut( &mut self, ) -> Option<&mut MonitoredStateStore<SledStateStoreType>>

Optionally returns mutable references to the inner fields if this is a StateStoreImpl::SledStateStore, otherwise None

pub fn as_sled_state_store( &self, ) -> Option<&MonitoredStateStore<SledStateStoreType>>

Optionally returns references to the inner fields if this is a StateStoreImpl::SledStateStore, otherwise None

pub fn into_sled_state_store( self, ) -> Result<MonitoredStateStore<SledStateStoreType>, Self>

Returns the inner fields if this is a StateStoreImpl::SledStateStore, otherwise returns back the enum in the Err case of the result

impl StateStoreImpl

fn in_memory( state_store: MemoryStateStore, storage_metrics: Arc<MonitoredStorageMetrics>, ) -> Self

pub fn hummock( state_store: HummockStorage, storage_metrics: Arc<MonitoredStorageMetrics>, ) -> Self

pub fn sled( state_store: SledStateStore, storage_metrics: Arc<MonitoredStorageMetrics>, ) -> Self

pub fn shared_in_memory_store( storage_metrics: Arc<MonitoredStorageMetrics>, ) -> Self

pub fn for_test() -> Self

pub fn as_hummock(&self) -> Option<&HummockStorage>

impl StateStoreImpl

pub async fn new( s: &str, opts: Arc<StorageOpts>, hummock_meta_client: Arc<MonitoredHummockMetaClient>, state_store_metrics: Arc<HummockStateStoreMetrics>, object_store_metrics: Arc<ObjectStoreMetrics>, storage_metrics: Arc<MonitoredStorageMetrics>, compactor_metrics: Arc<CompactorMetrics>, await_tree_config: Option<Config>, use_new_object_prefix_strategy: bool, ) -> StorageResult<Self>

Trait Implementations

impl Clone for StateStoreImpl

fn clone(&self) -> StateStoreImpl

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StateStoreImpl

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.