add output level for compaction job (#182)

librocksdb_sys/crocksdb/c.cc

@@ -1707,6 +1707,11 @@ uint64_t crocksdb_compactionjobinfo_num_corrupt_keys(
   return info->rep.stats.num_corrupt_keys;
 }
 
+int crocksdb_compactionjobinfo_output_level(
+    const crocksdb_compactionjobinfo_t* info) {
+  return info->rep.output_level;
+}
+
 /* ExternalFileIngestionInfo */
 
 const char* crocksdb_externalfileingestioninfo_cf_name(

librocksdb_sys/crocksdb/crocksdb/c.h

@@ -641,6 +641,9 @@ 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_output_level(
+    const crocksdb_compactionjobinfo_t*);
 
 /* External file ingestion info */
 

librocksdb_sys/src/lib.rs

@@ -1461,6 +1461,7 @@ extern "C" {
     pub fn crocksdb_compactionjobinfo_num_corrupt_keys(
         info: *const DBCompactionJobInfo,
     ) -> uint64_t;
+    pub fn crocksdb_compactionjobinfo_output_level(info: *const DBCompactionJobInfo) -> c_int;
 
     pub fn crocksdb_externalfileingestioninfo_cf_name(
         info: *const DBIngestionInfo,

src/event_listener.rs

@@ -88,6 +88,10 @@ impl CompactionJobInfo {
     pub fn num_corrupt_keys(&self) -> u64 {
         unsafe { crocksdb_ffi::crocksdb_compactionjobinfo_num_corrupt_keys(&self.0) }
     }
+
+    pub fn output_level(&self) -> i32 {
+        unsafe { crocksdb_ffi::crocksdb_compactionjobinfo_output_level(&self.0) }
+    }
 }
 
 pub struct IngestionInfo(DBIngestionInfo);

tests/test_event_listener.rs

@@ -62,6 +62,7 @@ impl EventListener for EventCounter {
 
         assert_ne!(info.elapsed_micros(), 0);
         assert_eq!(info.num_corrupt_keys(), 0);
+        assert!(info.output_level() >= 0);
 
         self.compaction.fetch_add(1, Ordering::SeqCst);
     }