pub struct SharedWriteBufferManager {
shared: Arc<Mutex<Weak<WriteBufferManager>>>,
}
Fields§
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§
Sourcepub(crate) fn get_or_init<F>(&self, initializer: F) -> WriteBufferManagerHandlewhere
F: FnOnce() -> WriteBufferManager,
pub(crate) fn get_or_init<F>(&self, initializer: F) -> WriteBufferManagerHandlewhere
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.
Sourcepub fn get(&self) -> Option<Arc<WriteBufferManager>>
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§
Source§fn clone(&self) -> SharedWriteBufferManager
fn clone(&self) -> SharedWriteBufferManager
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§fn default() -> SharedWriteBufferManager
fn default() -> SharedWriteBufferManager
Returns the “default value” for a type. Read more
Auto Trait Implementations§
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
Source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.Source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.