Struct mz_rocksdb::InstanceOptions
source · pub struct InstanceOptions<O, V, F> {
pub cleanup_on_new: bool,
pub cleanup_tries: usize,
pub use_wal: bool,
pub env: Env,
pub bincode: O,
pub merge_operator: Option<(String, F)>,
pub(crate) v: PhantomData<V>,
}
Expand description
Fixed options to configure a RocksDBInstance
. These are not tuning parameters,
see the config
modules for tuning. These are generally fixed within the binary.
Fields§
§cleanup_on_new: bool
Whether or not to clear state at the instance path before starting.
cleanup_tries: usize
If cleanup_on_new
, how many times to try.
use_wal: bool
Whether or not to write writes
to the wal. This is not in RocksDBTuningParameters
because it
applies to WriteOptions
when creating WriteBatch
es.
env: Env
A possibly shared RocksDB Env
.
bincode: O
The bincode options to use for serializing and deserializing values.
merge_operator: Option<(String, F)>
A merge operator to use for associative merges, if any. The first item is the name of the operator to store in RocksDB for compatibility checks, and the second is the merge function.
v: PhantomData<V>
Implementations§
source§impl<O, V, F> InstanceOptions<O, V, F>
impl<O, V, F> InstanceOptions<O, V, F>
sourcepub fn new(
env: Env,
cleanup_tries: usize,
merge_operator: Option<(String, F)>,
bincode: O,
) -> Self
pub fn new( env: Env, cleanup_tries: usize, merge_operator: Option<(String, F)>, bincode: O, ) -> Self
A new Options
object with reasonable defaults.
pub(crate) fn as_rocksdb_options( &self, tuning_config: &RocksDBConfig, ) -> (RocksDBOptions, Option<WriteBufferManagerHandle>)
pub(crate) fn as_rocksdb_write_options(&self) -> WriteOptions
Auto Trait Implementations§
impl<O, V, F> Freeze for InstanceOptions<O, V, F>
impl<O, V, F> RefUnwindSafe for InstanceOptions<O, V, F>
impl<O, V, F> Send for InstanceOptions<O, V, F>
impl<O, V, F> Sync for InstanceOptions<O, V, F>
impl<O, V, F> Unpin for InstanceOptions<O, V, F>
impl<O, V, F> UnwindSafe for InstanceOptions<O, V, F>
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> 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
.