feat: export persist_period_sec option and background_threads #447

- [x] add test disable all threads on get_with_cache_and_bulkload_test
- [x] add test for stats_persist_period_sec

src/db_options.rs

@@ -2188,6 +2188,24 @@ impl Options {
         }
     }
 
+    /// If not zero, dump rocksdb.stats to RocksDB to LOG every `stats_persist_period_sec`.
+    ///
+    /// Default: `600` (10 mins)
+    /// 
+    /// # Examples
+    ///
+    /// ```
+    /// use rocksdb::Options;
+    ///
+    /// let mut opts = Options::default();
+    /// opts.set_stats_persist_period_sec(5);
+    /// ```
+    pub fn set_stats_persist_period_sec(&mut self, period: c_uint) {
+        unsafe {
+            ffi::rocksdb_options_set_stats_persist_period_sec(self.inner, period);
+        }
+    }
+
     /// When set to true, reading SST files will opt out of the filesystem's
     /// readahead. Setting this to false may improve sequential iteration
     /// performance.
@@ -3360,4 +3378,15 @@ mod tests {
             branching_factor: 4,
         });
     }
+
+    #[test]
+    fn test_set_stats_persist_period_sec(){
+        let mut opts = Options::default();
+        opts.enable_statistics();
+        opts.set_stats_persist_period_sec(5);
+        assert!(opts.get_statistics().is_some());
+
+        let opts = Options::default();
+        assert!(opts.get_statistics().is_none());
+    }
 }

tests/test_db.rs

@@ -691,6 +691,26 @@ fn get_with_cache_and_bulkload_test() {
         opts.set_error_if_exists(true);
         assert!(DB::open(&opts, &path).is_err());
     }
+
+    // disable all threads 
+    {
+        // create new options
+        let mut opts = Options::default();
+        opts.max_background_jobs(0); 
+        opts.max_background_compactions(0);  
+        opts.max_background_flushes(0);  
+        opts.stats_dump_period_sec(0);  
+        opts.stats_persist_period_sec(0); 
+
+        // open db
+        let db = DB::open(&opts, &path).unwrap();
+
+        // try to get key
+        let iter = db.iterator(IteratorMode::Start);
+        for (expected, (k, _)) in iter.enumerate() {
+            assert_eq!(k.as_ref(), format!("{:0>4}", expected).as_bytes());
+        }
+    }
 }
 
 #[test]