add with-ttl open option to high level interface, fixing #57

Author: warrenfalk

RocksDbSharp/Native.Wrap.cs

@@ -33,6 +33,17 @@ public IntPtr rocksdb_open_for_read_only(
             return result;
         }
 
+        public IntPtr rocksdb_open_with_ttl(
+            /* const rocksdb_options_t* */ IntPtr options,
+            string name,
+            int ttlSeconds)
+        {
+            var result = rocksdb_open_with_ttl(options, name, ttlSeconds, out IntPtr errptr);
+            if (errptr != IntPtr.Zero)
+                throw new RocksDbException(errptr);
+            return result;
+        }
+
         public IntPtr rocksdb_open_column_families(
             /* const rocksdb_options_t* */ IntPtr options,
             string name,

RocksDbSharp/RocksDb.cs

@@ -51,6 +51,12 @@ public static RocksDb OpenReadOnly(OptionsHandle options, string path, bool erro
             return new RocksDb(db, optionsReferences: null, cfOptionsRefs: null);
         }
 
+        public static RocksDb OpenWithTtl(OptionsHandle options, string path, int ttlSeconds)
+        {
+            IntPtr db = Native.Instance.rocksdb_open_with_ttl(options.Handle, path, ttlSeconds);
+            return new RocksDb(db, optionsReferences: null, cfOptionsRefs: null);
+        }
+
         public static RocksDb Open(DbOptions options, string path, ColumnFamilies columnFamilies)
         {
             string[] cfnames = columnFamilies.Names.ToArray();

tests/RocksDbSharpTest/FunctionalTests.cs

@@ -375,6 +375,21 @@ public void FunctionalTest()
 
             }
 
+            // Smoke test OpenWithTtl
+            {
+                var dbname = "test-with-ttl";
+                if (Directory.Exists(dbname))
+                    Directory.Delete(dbname, true);
+                var optsTest = (DbOptions)new RocksDbSharp.DbOptions()
+                  .SetCreateIfMissing(true)
+                  .SetCreateMissingColumnFamilies(true);
+                using (var db = RocksDbSharp.RocksDb.OpenWithTtl(optsTest, dbname, 1))
+                {
+                }
+                if (Directory.Exists(dbname))
+                    Directory.Delete(dbname, true);
+            }
+
             // Smoke test MergeOperator
             {
                 var dbname = "test-merge-operator";