Skip to content

Commit

Permalink
Restore create column family with ttl - take 2
Browse files Browse the repository at this point in the history
  • Loading branch information
drdcoda committed May 22, 2024
1 parent 7f4aea3 commit c497351
Showing 1 changed file with 14 additions and 13 deletions.
27 changes: 14 additions & 13 deletions db/c.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1107,19 +1107,8 @@ rocksdb_column_family_handle_t* rocksdb_create_column_family_with_import(
return c_handle;
}

rocksdb_column_family_handle_t* rocksdb_create_column_family_with_ttl(
rocksdb_t* db, const rocksdb_options_t* column_family_options,
const char* column_family_name, int ttl, char** errptr) {
ROCKSDB_NAMESPACE::DBWithTTL* db_with_ttl =
static_cast<ROCKSDB_NAMESPACE::DBWithTTL*>(db->rep);
rocksdb_column_family_handle_t* handle = new rocksdb_column_family_handle_t;
SaveError(errptr, db_with_ttl->CreateColumnFamilyWithTtl(
ColumnFamilyOptions(column_family_options->rep),
std::string(column_family_name), &(handle->rep), ttl));
return handle;
}

rocksdb_export_import_files_metadata_t* rocksdb_checkpoint_export_column_family(rocksdb_t* db,
rocksdb_export_import_files_metadata_t*
rocksdb_checkpoint_export_column_family(rocksdb_t* db,
rocksdb_checkpoint_t* checkpoint,
rocksdb_column_family_handle_t* handle,
const char* export_dir, char** errptr) {
Expand Down Expand Up @@ -1184,6 +1173,18 @@ void rocksdb_create_column_families_destroy(
free(list);
}

rocksdb_column_family_handle_t* rocksdb_create_column_family_with_ttl(
rocksdb_t* db, const rocksdb_options_t* column_family_options,
const char* column_family_name, int ttl, char** errptr) {
ROCKSDB_NAMESPACE::DBWithTTL* db_with_ttl =
static_cast<ROCKSDB_NAMESPACE::DBWithTTL*>(db->rep);
rocksdb_column_family_handle_t* handle = new rocksdb_column_family_handle_t;
SaveError(errptr, db_with_ttl->CreateColumnFamilyWithTtl(
ColumnFamilyOptions(column_family_options->rep),
std::string(column_family_name), &(handle->rep), ttl));
return handle;
}

void rocksdb_drop_column_family(rocksdb_t* db,
rocksdb_column_family_handle_t* handle,
char** errptr) {
Expand Down

0 comments on commit c497351

Please sign in to comment.