Trait engine_traits::MiscExt[−][src]

pub trait MiscExt: CFNamesExt {
    fn flush(&self, sync: bool) -> Result<()>;

    fn flush_cf(&self, cf: &str, sync: bool) -> Result<()>;

    fn delete_ranges_cf(
        &self, 
        cf: &str, 
        strategy: DeleteStrategy, 
        ranges: &[Range<'_>]
    ) -> Result<()>;

    fn get_approximate_memtable_stats_cf(
        &self, 
        cf: &str, 
        range: &Range<'_>
    ) -> Result<(u64, u64)>;

    fn ingest_maybe_slowdown_writes(&self, cf: &str) -> Result<bool>;

    fn get_engine_used_size(&self) -> Result<u64>;

    fn roughly_cleanup_ranges(
        &self, 
        ranges: &[(Vec<u8>, Vec<u8>)]
    ) -> Result<()>;

    fn path(&self) -> &str;

    fn sync_wal(&self) -> Result<()>;

    fn exists(path: &str) -> bool;

    fn dump_stats(&self) -> Result<String>;

    fn get_latest_sequence_number(&self) -> u64;

    fn get_oldest_snapshot_sequence_number(&self) -> Option<u64>;

    fn get_total_sst_files_size_cf(&self, cf: &str) -> Result<Option<u64>>;

    fn get_range_entries_and_versions(
        &self, 
        cf: &str, 
        start: &[u8], 
        end: &[u8]
    ) -> Result<Option<(u64, u64)>>;

    fn get_cf_num_files_at_level(
        &self, 
        cf: &str, 
        level: usize
    ) -> Result<Option<u64>>;

    fn get_cf_num_immutable_mem_table(&self, cf: &str) -> Result<Option<u64>>;

    fn get_cf_compaction_pending_bytes(&self, cf: &str) -> Result<Option<u64>>;

    fn is_stalled_or_stopped(&self) -> bool;

    fn delete_all_in_range(
        &self, 
        strategy: DeleteStrategy, 
        ranges: &[Range<'_>]
    ) -> Result<()> { ... }
}

Required methods

fn flush(&self, sync: bool) -> Result<()>[src]

fn flush_cf(&self, cf: &str, sync: bool) -> Result<()>[src]

fn delete_ranges_cf(
    &self,
    cf: &str,
    strategy: DeleteStrategy,
    ranges: &[Range<'_>]
) -> Result<()>[src]

fn get_approximate_memtable_stats_cf(
    &self,
    cf: &str,
    range: &Range<'_>
) -> Result<(u64, u64)>[src]

Return the approximate number of records and size in the range of memtables of the cf.

fn ingest_maybe_slowdown_writes(&self, cf: &str) -> Result<bool>[src]

fn get_engine_used_size(&self) -> Result<u64>[src]

Gets total used size of rocksdb engine, including:

  • total size (bytes) of all SST files.
  • total size (bytes) of active and unflushed immutable memtables.
  • total size (bytes) of all blob files.

fn roughly_cleanup_ranges(&self, ranges: &[(Vec<u8>, Vec<u8>)]) -> Result<()>[src]

Roughly deletes files in multiple ranges.

Note:

  • After this operation, some keys in the range might still exist in the database.
  • After this operation, some keys in the range might be removed from existing snapshot, so you shouldn’t expect to be able to read data from the range using existing snapshots any more.

Ref: https://github.com/facebook/rocksdb/wiki/Delete-A-Range-Of-Keys

fn path(&self) -> &str[src]

The path to the directory on the filesystem where the database is stored

fn sync_wal(&self) -> Result<()>[src]

fn exists(path: &str) -> bool[src]

Check whether a database exists at a given path

fn dump_stats(&self) -> Result<String>[src]

Dump stats about the database into a string.

For debugging. The format and content is unspecified.

fn get_latest_sequence_number(&self) -> u64[src]

fn get_oldest_snapshot_sequence_number(&self) -> Option<u64>[src]

fn get_total_sst_files_size_cf(&self, cf: &str) -> Result<Option<u64>>[src]

fn get_range_entries_and_versions(
    &self,
    cf: &str,
    start: &[u8],
    end: &[u8]
) -> Result<Option<(u64, u64)>>[src]

fn get_cf_num_files_at_level(
    &self,
    cf: &str,
    level: usize
) -> Result<Option<u64>>[src]

fn get_cf_num_immutable_mem_table(&self, cf: &str) -> Result<Option<u64>>[src]

fn get_cf_compaction_pending_bytes(&self, cf: &str) -> Result<Option<u64>>[src]

fn is_stalled_or_stopped(&self) -> bool[src]

Loading content...

Provided methods

fn delete_all_in_range(
    &self,
    strategy: DeleteStrategy,
    ranges: &[Range<'_>]
) -> Result<()>[src]

Loading content...

Implementors

Loading content...