add base_input_level getter for CompactionJobInfo (#622)

Signed-off-by: tabokie <xy.tao@outlook.com>

librocksdb_sys/crocksdb/c.cc

@@ -2137,6 +2137,11 @@ uint64_t crocksdb_compactionjobinfo_num_corrupt_keys(
   return info->rep.stats.num_corrupt_keys;
 }
 
+int crocksdb_compactionjobinfo_base_input_level(
+    const crocksdb_compactionjobinfo_t* info) {
+  return info->rep.base_input_level;
+}
+
 int crocksdb_compactionjobinfo_output_level(
     const crocksdb_compactionjobinfo_t* info) {
   return info->rep.output_level;

librocksdb_sys/crocksdb/crocksdb/c.h

@@ -823,6 +823,8 @@ crocksdb_compactionjobinfo_elapsed_micros(const crocksdb_compactionjobinfo_t*);
 extern C_ROCKSDB_LIBRARY_API uint64_t
 crocksdb_compactionjobinfo_num_corrupt_keys(
     const crocksdb_compactionjobinfo_t*);
+extern C_ROCKSDB_LIBRARY_API int crocksdb_compactionjobinfo_base_input_level(
+    const crocksdb_compactionjobinfo_t*);
 extern C_ROCKSDB_LIBRARY_API int crocksdb_compactionjobinfo_output_level(
     const crocksdb_compactionjobinfo_t*);
 extern C_ROCKSDB_LIBRARY_API uint64_t

librocksdb_sys/src/lib.rs

@@ -2142,6 +2142,7 @@ extern "C" {
     ) -> *const DBTablePropertiesCollection;
     pub fn crocksdb_compactionjobinfo_elapsed_micros(info: *const DBCompactionJobInfo) -> u64;
     pub fn crocksdb_compactionjobinfo_num_corrupt_keys(info: *const DBCompactionJobInfo) -> u64;
+    pub fn crocksdb_compactionjobinfo_base_input_level(info: *const DBCompactionJobInfo) -> c_int;
     pub fn crocksdb_compactionjobinfo_output_level(info: *const DBCompactionJobInfo) -> c_int;
     pub fn crocksdb_compactionjobinfo_input_records(info: *const DBCompactionJobInfo) -> u64;
     pub fn crocksdb_compactionjobinfo_output_records(info: *const DBCompactionJobInfo) -> u64;

src/event_listener.rs

@@ -105,6 +105,10 @@ impl CompactionJobInfo {
         unsafe { crocksdb_ffi::crocksdb_compactionjobinfo_num_corrupt_keys(&self.0) }
     }
 
+    pub fn base_input_level(&self) -> i32 {
+        unsafe { crocksdb_ffi::crocksdb_compactionjobinfo_base_input_level(&self.0) }
+    }
+
     pub fn output_level(&self) -> i32 {
         unsafe { crocksdb_ffi::crocksdb_compactionjobinfo_output_level(&self.0) }
     }