Struct opendal::services::Rocksdb

source ·
pub struct Rocksdb { /* private fields */ }
Expand description

Rocksdb service support.

Capabilities

This service can be used to:

  • read
  • write
  • list
  • scan
  • presign
  • blocking

Note

OpenDAL will build rocksdb from source by default.

To link with existing rocksdb lib, please set one of the following:

  • ROCKSDB_LIB_DIR to the dir that contains librocksdb.so
  • ROCKSDB_STATIC to the dir that contains librocksdb.a

If the version of RocksDB is below 6.0, you may encounter compatibility issues. It is advisable to follow the steps provided in the INSTALL file to build rocksdb, rather than relying on system libraries that may be outdated and incompatible.

Configuration

  • root: Set the working directory of OpenDAL
  • datadir: Set the path to the rocksdb data directory

You can refer to RocksdbBuilder’s docs for more information

Example

Via Builder

use anyhow::Result;
use opendal::services::Rocksdb;
use opendal::Object;
use opendal::Operator;

#[tokio::main]
async fn main() -> Result<()> {
    let mut builder = Rocksdb::default();
    builder.datadir("/tmp/opendal/rocksdb");

    let op: Operator = Operator::new(builder)?.finish();
    let _: Object = op.object("test_file");
    Ok(())
}

Implementations§

source§

impl RocksdbBuilder

source

pub fn datadir(&mut self, path: &str) -> &mut Self

Set the path to the rocksdb data directory. Will create if not exists.

source

pub fn root(&mut self, root: &str) -> &mut Self

set the working directory, all operations will be performed under it.

default: “/”

Trait Implementations§

source§

impl Builder for RocksdbBuilder

source§

const SCHEME: Scheme = Scheme::Rocksdb

Associated scheme for this builder.
§

type Accessor = Backend<Adapter>

The accessor that built by this builder.
source§

fn from_map(map: HashMap<String, String>) -> Self

Construct a builder from given map.
source§

fn build(&mut self) -> Result<Self::Accessor>

Consume the accessor builder to build a service.
source§

fn from_iter(iter: impl Iterator<Item = (String, String)>) -> Selfwhere Self: Sized,

Construct a builder from given iterator.
source§

fn from_env() -> Selfwhere Self: Sized,

Construct a builder from envs.
source§

impl Clone for RocksdbBuilder

source§

fn clone(&self) -> RocksdbBuilder

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for RocksdbBuilder

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for RocksdbBuilder

source§

fn default() -> RocksdbBuilder

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

source§

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

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

const: unstable · source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

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

const: unstable · source§

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

Mutably borrows from an owned value. Read more
source§

impl<T> CompatExt for T

source§

fn compat(self) -> Compat<T>

Applies the Compat adapter by value. Read more
source§

fn compat_ref(&self) -> Compat<&T>

Applies the Compat adapter by shared reference. Read more
source§

fn compat_mut(&mut self) -> Compat<&mut T>

Applies the Compat adapter by mutable reference. Read more
source§

impl<T> From<T> for T

const: unstable · source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

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

const: unstable · source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

§

impl<T> Pointable for T

§

const ALIGN: usize = mem::align_of::<T>()

The alignment of pointer.
§

type Init = T

The type for initializers.
§

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

Initializes a with the given initializer. Read more
§

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

Dereferences the given pointer. Read more
§

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

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for Twhere T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

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

§

type Error = Infallible

The type returned in the event of a conversion error.
const: unstable · source§

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

Performs the conversion.
source§

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

§

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

The type returned in the event of a conversion error.
const: unstable · source§

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

Performs the conversion.
§

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

§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more