[feat][sdk]Support txn async commit

Author: LiuRuoyu01

include/dingosdk/client.h

@@ -262,6 +262,8 @@ class Transaction {
 
   bool IsOnePc() const;
 
+  bool IsAsyncCommit() const;
+
  private:
   friend class Client;
   friend class TestBase;

src/sdk/CMakeLists.txt

@@ -55,6 +55,7 @@ set(SDK_SRCS
   transaction/txn_task/txn_check_status_task.cc
   transaction/txn_task/txn_resolve_lock_task.cc
   transaction/txn_task/txn_heartbeat_task.cc
+    transaction/txn_task/txn_check_secondary_locks_task.cc
   vector/vector_client.cc
   vector/vector_index_cache.cc
   vector/vector_index_creator.cc

src/sdk/client.cc

@@ -599,6 +599,8 @@ Status Transaction::Rollback() { return data_->impl->Rollback(); }
 
 bool Transaction::IsOnePc() const { return data_->impl->IsOnePc(); }
 
+bool Transaction::IsAsyncCommit() const { return data_->impl->IsAsyncCommit(); }
+
 RegionCreator::RegionCreator(Data* data) : data_(data) {}
 
 RegionCreator::~RegionCreator() { delete data_; }

src/sdk/common/common.h

@@ -39,7 +39,7 @@ static const int64_t kLogicalMask = (1 << kPhysicalShiftBits) - 1;
 namespace dingodb {
 namespace sdk {
 
-enum LogLevel { kDEBUG = 0, kINFO = 1, kWARNING = 2, kERROR = 3, kFATAL = 4 };
+enum LogLevel : std::uint8_t { kDEBUG = 0, kINFO = 1, kWARNING = 2, kERROR = 3, kFATAL = 4 };
 
 struct Range {
   std::string start_key;

src/sdk/common/param_config.cc

@@ -58,10 +58,11 @@ DEFINE_int64(vector_op_max_retry, 30, "vector task max retry times");
 
 DEFINE_int64(txn_max_batch_count, 1000, "txn max batch count");
 DEFINE_int64(txn_max_async_commit_count, 256, "txn max async commit count");
+DEFINE_bool(enable_txn_async_commit, true, "enable txn async commit");
 
 DEFINE_bool(log_rpc_time, false, "log rpc time");
 
-DEFINE_int64(txn_heartbeat_interval_ms, 5000, "txn heartbeat interval time");
+DEFINE_int64(txn_heartbeat_interval_ms, 8000, "txn heartbeat interval time");
 DEFINE_int64(txn_heartbeat_lock_delay_ms, 20000, "txn heartbeat lock delay time");
 
 DEFINE_uint32(stale_period_us, 1000, "stale period us default 1000 us, used for tso provider");

src/sdk/common/param_config.h

@@ -72,6 +72,8 @@ DECLARE_int64(vector_op_max_retry);
 
 DECLARE_int64(txn_max_batch_count);
 DECLARE_int64(txn_max_async_commit_count);
+DECLARE_bool(enable_txn_async_commit);
+
 DECLARE_bool(log_rpc_time);
 
 DECLARE_int64(txn_heartbeat_interval_ms);

src/sdk/rpc/brpc/store_rpc.cc

@@ -44,6 +44,7 @@ DEFINE_STORE_RPC(TxnScan);
 DEFINE_STORE_RPC(TxnHeartBeat);
 DEFINE_STORE_RPC(TxnCheckTxnStatus);
 DEFINE_STORE_RPC(TxnResolveLock);
+DEFINE_STORE_RPC(TxnCheckSecondaryLocks);
 
 }  // namespace sdk
 }  // namespace dingodb

src/sdk/rpc/brpc/store_rpc.h

@@ -48,6 +48,7 @@ DECLARE_STORE_RPC(TxnScan);
 DECLARE_STORE_RPC(TxnHeartBeat);
 DECLARE_STORE_RPC(TxnCheckTxnStatus);
 DECLARE_STORE_RPC(TxnResolveLock);
+DECLARE_STORE_RPC(TxnCheckSecondaryLocks);
 
 }  // namespace sdk
 }  // namespace dingodb

src/sdk/rpc/grpc/store_rpc.cc

@@ -44,6 +44,7 @@ DEFINE_STORE_RPC(TxnScan);
 DEFINE_STORE_RPC(TxnHeartBeat);
 DEFINE_STORE_RPC(TxnCheckTxnStatus);
 DEFINE_STORE_RPC(TxnResolveLock);
+DEFINE_STORE_RPC(TxnCheckSecondaryLocks);
 
 }  // namespace sdk
 }  // namespace dingodb

src/sdk/rpc/grpc/store_rpc.h

@@ -48,6 +48,7 @@ DECLARE_STORE_RPC(TxnScan);
 DECLARE_STORE_RPC(TxnHeartBeat);
 DECLARE_STORE_RPC(TxnCheckTxnStatus);
 DECLARE_STORE_RPC(TxnResolveLock);
+DECLARE_STORE_RPC(TxnCheckSecondaryLocks);
 
 }  // namespace sdk
 }  // namespace dingodb