Crate rocksdb

Source
Expand description

Rust wrapper for RocksDB.

§Examples

use rocksdb::{DB, Options};
// NB: db is automatically closed at end of lifetime
let tempdir = tempfile::Builder::new()
    .prefix("_path_for_rocksdb_storage")
    .tempdir()
    .expect("Failed to create temporary path for the _path_for_rocksdb_storage");
let path = tempdir.path();
{
   let db = DB::open_default(path).unwrap();
   db.put(b"my key", b"my value").unwrap();
   match db.get(b"my key") {
       Ok(Some(value)) => println!("retrieved value {}", String::from_utf8(value).unwrap()),
       Ok(None) => println!("value not found"),
       Err(e) => println!("operational problem encountered: {}", e),
   }
   db.delete(b"my key").unwrap();
}
let _ = DB::destroy(&Options::default(), path);

Opening a database and a single column family with custom options:

use rocksdb::{DB, ColumnFamilyDescriptor, Options};

let tempdir = tempfile::Builder::new()
    .prefix("_path_for_rocksdb_storage_with_cfs")
    .tempdir()
    .expect("Failed to create temporary path for the _path_for_rocksdb_storage_with_cfs.");
let path = tempdir.path();
let mut cf_opts = Options::default();
cf_opts.set_max_write_buffer_number(16);
let cf = ColumnFamilyDescriptor::new("cf1", cf_opts);

let mut db_opts = Options::default();
db_opts.create_missing_column_families(true);
db_opts.create_if_missing(true);
{
    let db = DB::open_cf_descriptors(&db_opts, path, vec![cf]).unwrap();
}
let _ = DB::destroy(&db_opts, path);

Re-exports§

pub use crate::compaction_filter::Decision as CompactionDecision;
pub use crate::merge_operator::MergeOperands;
pub use crate::perf::PerfContext;
pub use crate::perf::PerfMetric;
pub use crate::perf::PerfStatsLevel;

Modules§

backup
checkpoint
Implementation of bindings to RocksDB Checkpoint1 API
compaction_filter
compaction_filter_factory
merge_operator
rustic merge operator
perf
properties
Properties
statistics

Structs§

BlockBasedOptions
For configuring block-based file storage.
BoundColumnFamily
A specialized opaque type used to represent a column family by the MultiThreaded mode. Clone (and Copy) is derived to behave like &ColumnFamily (this is used for single-threaded mode). Clone/Copy is safe because this lifetime is bound to DB like iterators/snapshots. On top of it, this is as cheap and small as &ColumnFamily because this only has a single pointer-wide field.
Cache
ColumnFamily
An opaque type used to represent a column family. Returned from some functions, and used in others
ColumnFamilyDescriptor
A descriptor for a RocksDB column family.
CompactOptions
CuckooTableOptions
Configuration of cuckoo-based storage.
DBCommon
A helper type to implement some common methods for DBWithThreadMode and OptimisticTransactionDB.
DBIteratorWithThreadMode
An iterator over a database or column family, with specifiable ranges and direction.
DBPath
Represents a path where sst files can be put into
DBPinnableSlice
Wrapper around RocksDB PinnableSlice struct.
DBRawIteratorWithThreadMode
An iterator over a database or column family, with specifiable ranges and direction.
DBWALIterator
Iterates the batches of writes since a given sequence number.
Env
An Env is an interface used by the rocksdb implementation to access operating system functionality like the filesystem etc. Callers may wish to provide a custom Env object when opening a database to get fine gain control; e.g., to rate limit file system operations.
Error
A simple wrapper round a string, used for errors reported from ffi calls.
FifoCompactOptions
FlushOptions
Optionally wait for the memtable flush to be performed.
IngestExternalFileOptions
For configuring external files ingestion.
LiveFile
The metadata that describes a SST file
LruCacheOptions
MultiThreaded
Actual marker type for the marker trait ThreadMode, which holds a collection of column families wrapped in a RwLock to be mutated concurrently. The other mode is SingleThreaded.
OptimisticTransactionOptions
Options
Database-wide options around performance and behavior.
PlainTableFactoryOptions
Used with DBOptions::set_plain_table_factory. See official wiki for more information.
PrefixRange
Representation of a range of keys starting with given prefix.
ReadOptions
SingleThreaded
Actual marker type for the marker trait ThreadMode, which holds a collection of column families without synchronization primitive, providing no overhead for the single-threaded column family alternations. The other mode is MultiThreaded.
SliceTransform
A SliceTransform is a generic pluggable way of transforming one string to another. Its primary use-case is in configuring rocksdb to store prefix blooms by setting prefix_extractor in ColumnFamilyOptions.
SnapshotWithThreadMode
A consistent view of the database at the point of creation.
SstFileWriter
SstFileWriter is used to create sst files that can be added to database later All keys in files generated by SstFileWriter will have sequence number = 0.
Transaction
RocksDB Transaction.
TransactionDB
RocksDB TransactionDB.
TransactionDBOptions
TransactionOptions
UniversalCompactOptions
WaitForCompactOptions
WriteBatchWithTransaction
An atomic batch of write operations.
WriteBufferManager
WriteOptions
Optionally disable WAL or sync for this write.

Enums§

BlockBasedIndexType
Used by BlockBasedOptions::set_index_type.
BottommostLevelCompaction
ChecksumType
Used by BlockBasedOptions::set_checksum_type.
ColumnFamilyTtl
Specifies the TTL behavior for a column family. https://github.com/facebook/rocksdb/blob/18cecb9c46b4c2a8b148659dac2fcab5a843d32b/include/rocksdb/utilities/db_ttl.h#L16-L46
CompactionPri
DBCompactionStyle
DBCompressionType
DBRecoveryMode
DataBlockIndexType
Used by BlockBasedOptions::set_data_block_index_type.
Direction
ErrorKind
RocksDB error kind.
IteratorMode
KeyEncodingType
Used in PlainTableFactoryOptions.
LogLevel
MemtableFactory
Defines the underlying memtable implementation. See official wiki for more information.
ReadTier
UniversalCompactionStopStyle

Constants§

DEFAULT_COLUMN_FAMILY_NAME
The name of the default column family.

Traits§

AsColumnFamilyRef
Utility trait to accept both supported references to ColumnFamily (&ColumnFamily and BoundColumnFamily)
CStrLike
Value which can be converted into a C string.
DBAccess
Minimal set of DB-related methods, intended to be generic over DBWithThreadMode<T>. Mainly used internally
IterateBounds
A range which can be set as iterate bounds on crate::ReadOptions.
ThreadMode
Marker trait to specify single or multi threaded column family alternations for DBWithThreadMode<T>
WriteBatchIterator
Receives the puts and deletes of a write batch.

Type Aliases§

ColumnFamilyRef
Handy type alias to hide actual type difference to reference ColumnFamily depending on the multi-threaded-cf crate feature.
DB
A type alias to DB instance type with the single-threaded column family creations/deletions
DBIterator
A type alias to keep compatibility. See DBIteratorWithThreadMode for details
DBRawIterator
A type alias to keep compatibility. See DBRawIteratorWithThreadMode for details
DBWithThreadMode
A type alias to RocksDB database.
OptimisticTransactionDB
A type alias to RocksDB Optimistic Transaction DB.
Snapshot
A type alias to keep compatibility. See SnapshotWithThreadMode for details
WriteBatch
A type alias to keep compatibility. See WriteBatchWithTransaction for details