Branch support

.gitignore

@@ -47,3 +47,4 @@ test-data
 target
 tmp
 compile_commands.json
+.pre-commit-config.yaml

benchmark/eloq_store_bm.cc

@@ -731,7 +731,7 @@ bool Benchmark::OpenEloqStore(const eloqstore::KvOptions &kv_options)
 {
     eloq_store_ = std::make_unique<::eloqstore::EloqStore>(kv_options);
 
-    ::eloqstore::KvError res = eloq_store_->Start();
+    ::eloqstore::KvError res = eloq_store_->Start(eloqstore::MainBranchName, 0);
     if (res != ::eloqstore::KvError::NoError)
     {
         LOG(ERROR) << "EloqStore start failed with error code: "

benchmark/load_bench.cpp

@@ -136,7 +136,10 @@ int main(int argc, char *argv[])
     }
 
     eloqstore::EloqStore store(options);
-    store.Start();
+    if (auto err = store.Start("main", 0); err != eloqstore::KvError::NoError)
+    {
+        LOG(FATAL) << "Failed to start store: " << eloqstore::ErrorString(err);
+    }
 
     std::vector<Writer> writers;
     for (uint32_t i = 0; i < FLAGS_partitions; i++)

benchmark/simple_bench.cpp

@@ -580,7 +580,10 @@ int main(int argc, char *argv[])
     }
 
     eloqstore::EloqStore store(options);
-    store.Start();
+    if (auto err = store.Start("main", 0); err != eloqstore::KvError::NoError)
+    {
+        LOG(FATAL) << "Failed to start store: " << eloqstore::ErrorString(err);
+    }
 
     if (FLAGS_workload == "load")
     {

benchmark/simple_test.cpp

@@ -449,7 +449,7 @@ int main(int argc, char *argv[])
     eloqstore::TableIdent tbl_id("perf_test", 1);
 
     eloqstore::EloqStore store(opts);
-    eloqstore::KvError err = store.Start();
+    eloqstore::KvError err = store.Start("main", 0);
     assert(err == eloqstore::KvError::NoError);
 
     // based on command arguments, we run different tests:

db_stress/concurrent_test.cpp

@@ -69,7 +69,10 @@ int main(int argc, char **argv)
         }
     }
     eloqstore::EloqStore store(options);
-    store.Start();
+    if (auto err = store.Start("main", 0); err != eloqstore::KvError::NoError)
+    {
+        LOG(FATAL) << "Failed to start store: " << eloqstore::ErrorString(err);
+    }
     if (FLAGS_num_client_threads == 1)
     {
         test_util::ConcurrencyTester tester(&store,

db_stress/db_stress_driver.cpp

@@ -149,7 +149,7 @@ void RunStressTest(int argc, char **argv)
     eloqstore::KillPoint::GetInstance().kill_odds_ = FLAGS_kill_odds;
 
     eloqstore::EloqStore store(opts);
-    eloqstore::KvError err = store.Start();
+    eloqstore::KvError err = store.Start("main", 0);
     CHECK(err == eloqstore::KvError::NoError);
 
     std::vector<std::unique_ptr<StressTest>> stress(FLAGS_n_tables);

db_stress/test_client.cpp

@@ -55,7 +55,7 @@ int main(int argc, char **argv)
     }
 
     eloqstore::EloqStore store(options);
-    eloqstore::KvError err = store.Start();
+    eloqstore::KvError err = store.Start("main", 0);
     if (err != eloqstore::KvError::NoError)
     {
         LOG(FATAL) << eloqstore::ErrorString(err) << std::endl;

examples/basic_example.cpp

@@ -22,7 +22,7 @@ int main()
     eloqstore::TableIdent tbl_id("t1", 1);
 
     eloqstore::EloqStore store(opts);
-    eloqstore::KvError err = store.Start();
+    eloqstore::KvError err = store.Start("main", 0);
     assert(err == eloqstore::KvError::NoError);
 
     {