Memory leak fix and some option feature support

db.go

@@ -674,6 +674,12 @@ func (db *DB) SetOptions(keys, values []string) error {
 		cKeys[i] = C.CString(keys[i])
 		cValues[i] = C.CString(values[i])
 	}
+	defer func() {
+		for i := range cKeys {
+			C.free(unsafe.Pointer(cKeys[i]))
+			C.free(unsafe.Pointer(cValues[i]))
+		}
+	}()
 
 	var cErr *C.char
 
@@ -691,6 +697,43 @@ func (db *DB) SetOptions(keys, values []string) error {
 	return nil
 }
 
+// SetDBOptions dynamically changes options through the SetDBOptions API.
+func (db *DB) SetDBOptions(keys, values []string) error {
+	num_keys := len(keys)
+
+	if num_keys == 0 {
+		return nil
+	}
+
+	cKeys := make([]*C.char, num_keys)
+	cValues := make([]*C.char, num_keys)
+	for i := range keys {
+		cKeys[i] = C.CString(keys[i])
+		cValues[i] = C.CString(values[i])
+	}
+	defer func() {
+		for i := range cKeys {
+			C.free(unsafe.Pointer(cKeys[i]))
+			C.free(unsafe.Pointer(cValues[i]))
+		}
+	}()
+
+	var cErr *C.char
+
+	C.rocksdb_set_dboptions(
+		db.c,
+		C.int(num_keys),
+		&cKeys[0],
+		&cValues[0],
+		&cErr,
+	)
+	if cErr != nil {
+		defer C.rocksdb_free(unsafe.Pointer(cErr))
+		return errors.New(C.GoString(cErr))
+	}
+	return nil
+}
+
 // LiveFileMetadata is a metadata which is associated with each SST file.
 type LiveFileMetadata struct {
 	Name        string
@@ -752,6 +795,17 @@ func (db *DB) Flush(opts *FlushOptions) error {
 	return nil
 }
 
+// FlushCF triggers a manuel column family flush for the database.
+func (db *DB) FlushCF(opts *FlushOptions, cf *ColumnFamilyHandle) error {
+	var cErr *C.char
+	C.rocksdb_flush_cf(db.c, opts.c, cf.c, &cErr)
+	if cErr != nil {
+		defer C.rocksdb_free(unsafe.Pointer(cErr))
+		return errors.New(C.GoString(cErr))
+	}
+	return nil
+}
+
 // DisableFileDeletions disables file deletions and should be used when backup the database.
 func (db *DB) DisableFileDeletions() error {
 	var cErr *C.char

options.go

@@ -918,6 +918,14 @@ func (opts *Options) SetStatsDumpPeriodSec(value uint) {
 	C.rocksdb_options_set_stats_dump_period_sec(opts.c, C.uint(value))
 }
 
+// SetStatsPersistPeriodSec sets the stats persist period in seconds.
+//
+// If not zero, persist stats to LOG every stats_persist_period_sec
+// Default: 300 (5 min)
+func (opts *Options) SetStatsPersistPeriodSec(value uint) {
+	C.rocksdb_options_set_stats_persist_period_sec(opts.c, C.uint(value))
+}
+
 // SetAdviseRandomOnOpen specifies whether we will hint the underlying
 // file system that the file access pattern is random, when a sst file is opened.
 // Default: true
@@ -1196,6 +1204,55 @@ func (opts *Options) SetOptimizeFiltersForHits(value bool) {
 	C.rocksdb_options_set_optimize_filters_for_hits(opts.c, C.int(btoi(value)))
 }
 
+// SetMaxSubCompactions set max_subcompactions
+// This value represents the maximum number of threads that will
+// concurrently perform a compaction job by breaking it into multiple,
+// smaller ones that are run simultaneously.
+// Default: 1 (i.e. no subcompactions)
+//
+// Dynamically changeable through SetDBOptions() API.
+func (opts *Options) SetMaxSubCompactions(value int) {
+	C.rocksdb_options_set_max_subcompactions(opts.c, C.uint32_t(value))
+}
+
+// SetWriteBufferManager set write_bufffer_manager for the option
+// The memory usage of memtable will report to this object. The same object
+// can be passed into multiple DBs and it will track the sum of size of all
+// the DBs. If the total size of all live memtables of all the DBs exceeds
+// a limit, a flush will be triggered in the next DB to which the next write
+// is issued.
+//
+// If the object is only passed to one DB, the behavior is the same as
+// db_write_buffer_size. When write_buffer_manager is set, the value set will
+// override db_write_buffer_size.
+//
+// This feature is disabled by default. Specify a non-zero value
+// to enable it.
+//
+// Default: null
+func (opts *Options) SetWriteBufferManager(w *WriteBufferManager) {
+	C.rocksdb_options_set_write_buffer_manager(opts.c, w.c)
+}
+
+// SetSstFileManager set sst_file_manager for the option
+// Use to track SST files and control their file deletion rate.
+//
+// Features:
+//  - Throttle the deletion rate of the SST files.
+//  - Keep track the total size of all SST files.
+//  - Set a maximum allowed space limit for SST files that when reached
+//    the DB wont do any further flushes or compactions and will set the
+//    background error.
+//  - Can be shared between multiple dbs.
+// Limitations:
+//  - Only track and throttle deletes of SST files in
+//    first db_path (db_name if db_paths is empty).
+//
+// Default: null
+func (opts *Options) SetSstFileManager(s *SstFileManager) {
+	C.rocksdb_options_set_sst_file_manager(opts.c, s.c)
+}
+
 // Destroy deallocates the Options object.
 func (opts *Options) Destroy() {
 	C.rocksdb_options_destroy(opts.c)

ratelimiter.go

@@ -24,6 +24,11 @@ func NewNativeRateLimiter(c *C.rocksdb_ratelimiter_t) *RateLimiter {
 	return &RateLimiter{c}
 }
 
+// SetBytesPerSecond set rate limiter bytes per second dynamically
+func (self *RateLimiter) SetBytesPerSecond(val int64) {
+	C.rocksdb_ratelimiter_set_bytes_per_second(self.c, C.int64_t(val))
+}
+
 // Destroy deallocates the RateLimiter object.
 func (self *RateLimiter) Destroy() {
 	C.rocksdb_ratelimiter_destroy(self.c)

sst_file_manager.go

@@ -0,0 +1,21 @@
+package gorocksdb
+
+// #include <stdlib.h>
+// #include "rocksdb/c.h"
+import "C"
+
+// SstFileManager manager sst file deletion between multiple column families or multiple db
+type SstFileManager struct {
+	c *C.rocksdb_sst_file_manager_t
+}
+
+// NewSstFileManager creates a SstFileManager object.
+func NewSstFileManager(env *Env) *SstFileManager {
+	return &SstFileManager{c: C.rocksdb_sst_file_manager_create(env.c)}
+}
+
+// Destroy deallocates the SstFileManager object.
+func (w *SstFileManager) Destroy() {
+	C.rocksdb_sst_file_manager_destory(w.c)
+	w.c = nil
+}

write_buffer_manager.go

@@ -0,0 +1,21 @@
+package gorocksdb
+
+// #include <stdlib.h>
+// #include "rocksdb/c.h"
+import "C"
+
+// WriteBufferManager manager the whole write buffer between multiple column families or multiple db
+type WriteBufferManager struct {
+	c *C.rocksdb_write_buffer_manager_t
+}
+
+// NewWriteBufferManager creates a WriteBufferManager object.
+func NewWriteBufferManager(bufferSize uint64) *WriteBufferManager {
+	return &WriteBufferManager{c: C.rocksdb_write_buffer_manager_create(C.size_t(bufferSize))}
+}
+
+// Destroy deallocates the WriterBufferManager object.
+func (w *WriteBufferManager) Destroy() {
+	C.rocksdb_write_buffer_manager_destory(w.c)
+	w.c = nil
+}