diff --git a/src/DtmCommon/Imp/TransBase.cs b/src/DtmCommon/Imp/TransBase.cs
index e958473..1b81d67 100644
--- a/src/DtmCommon/Imp/TransBase.cs
+++ b/src/DtmCommon/Imp/TransBase.cs
@@ -19,6 +19,8 @@ public class TransBase
[JsonPropertyName("timeout_to_fail")]
public long TimeoutToFail { get; set; }
+ [JsonPropertyName("request_timeout")]
+ public long RequestTimeout { get; set; }
[JsonPropertyName("retry_interval")]
public long RetryInterval { get; set; }
diff --git a/src/Dtmcli/Saga/Saga.cs b/src/Dtmcli/Saga/Saga.cs
index ba581c3..c0478d8 100644
--- a/src/Dtmcli/Saga/Saga.cs
+++ b/src/Dtmcli/Saga/Saga.cs
@@ -70,7 +70,16 @@ public Saga SetTimeoutToFail(long timeoutToFail)
this._transBase.TimeoutToFail = timeoutToFail;
return this;
}
-
+ ///
+ /// Set request timeout
+ ///
+ /// request timeout
+ ///
+ public Saga SetRequestTimeout(long requestTimeout)
+ {
+ this._transBase.RequestTimeout = requestTimeout;
+ return this;
+ }
///
/// Set retry interval for trans, unit is second
///
diff --git a/src/Dtmgrpc/DtmGImp/Utils.cs b/src/Dtmgrpc/DtmGImp/Utils.cs
index d144814..d79a26c 100644
--- a/src/Dtmgrpc/DtmGImp/Utils.cs
+++ b/src/Dtmgrpc/DtmGImp/Utils.cs
@@ -149,6 +149,7 @@ public static dtmgpb.DtmRequest BuildDtmRequest(TransBase transBase)
TimeoutToFail = transBase.TimeoutToFail,
RetryInterval = transBase.RetryInterval,
RetryLimit = transBase.RetryLimit,
+ RequestTimeout = transBase.RequestTimeout,
};
if (transBase.BranchHeaders != null)
diff --git a/src/Dtmgrpc/Saga/SagaGrpc.cs b/src/Dtmgrpc/Saga/SagaGrpc.cs
index cfd4019..f5b77f5 100644
--- a/src/Dtmgrpc/Saga/SagaGrpc.cs
+++ b/src/Dtmgrpc/Saga/SagaGrpc.cs
@@ -74,6 +74,16 @@ public SagaGrpc SetTimeoutToFail(long timeoutToFail)
this._transBase.TimeoutToFail = timeoutToFail;
return this;
}
+ ///
+ /// Set request timeout
+ ///
+ /// request timeout
+ ///
+ public SagaGrpc SetRequestTimeout(long requestTimeout)
+ {
+ this._transBase.RequestTimeout = requestTimeout;
+ return this;
+ }
///
/// Set retry interval for trans, unit is second