Struct SharedWriteBufferManager

pub struct SharedWriteBufferManager {
    shared: Arc<Mutex<Weak<WriteBufferManager>>>,
}

Fields

shared: Arc<Mutex<Weak<WriteBufferManager>>>

Keeping a Weak pointer to WriteBufferManager here behind an Arc and a Mutex. The strong pointers will be owned by each RocksDBInstance. When the rocksdb instances are cleaned up, the WriteBufferManager here will be cleaned up as well. Updates to config values via RocksDbWriteBufferManagerConfig will not update the WriteBufferManager once it’s initialized here and there’s at least one RocksDBInstance keeping a strong reference to it.

Implementations

impl SharedWriteBufferManager

pub(crate) fn get_or_init<F>(&self, initializer: F) -> WriteBufferManagerHandle

where F: FnOnce() -> WriteBufferManager,

If a shared WriteBufferManager does not already exist, then it’s initialized with given initializer. A strong reference is returned for the shared buffer manager.

pub fn get(&self) -> Option<Arc<WriteBufferManager>>

This will return a non-empty WriteBufferManager only after it has been initialized by a RocksDBInstance. This method is only used in tests.

Trait Implementations

impl Clone for SharedWriteBufferManager

fn clone(&self) -> SharedWriteBufferManager

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for SharedWriteBufferManager

fn default() -> SharedWriteBufferManager

Returns the “default value” for a type.