Struct RocksDBUnifiedEngine

Source

pub struct RocksDBUnifiedEngine;

Expand description

Factory for unified single-DB storage (4 CFs, one Arc<DB>).

Opens a single RocksDB instance with all four column families and returns both a RocksDBStorageEngine and a RocksDBStateMachine sharing the same underlying Arc<DB>. This halves resource usage compared to the dual-instance setup: one 128 MB block cache, one set of background jobs, one file-descriptor budget.

§Usage

use d_engine_server::storage::RocksDBUnifiedEngine;

let (storage, sm) = RocksDBUnifiedEngine::open("/data/raft")?;

RocksDBUnifiedEngine

Struct RocksDBUnifiedEngine Copy item path

§Usage

Implementations§

impl RocksDBUnifiedEngine

pub fn open<P>( path: P, ) -> Result<(RocksDBStorageEngine, RocksDBStateMachine), Error>where P: AsRef<Path>,

Auto Trait Implementations§

impl Freeze for RocksDBUnifiedEngine

impl RefUnwindSafe for RocksDBUnifiedEngine

impl Send for RocksDBUnifiedEngine

impl Sync for RocksDBUnifiedEngine

impl Unpin for RocksDBUnifiedEngine

impl UnsafeUnpin for RocksDBUnifiedEngine

impl UnwindSafe for RocksDBUnifiedEngine

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct RocksDBUnifiedEngine

pub fn open<P>( path: P, ) -> Result<(RocksDBStorageEngine, RocksDBStateMachine), Error>
where P: AsRef<Path>,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,