Skip to content

Commit f76456e

Browse files
authored
add request timeout #78 (#79)
1 parent 585d2aa commit f76456e

File tree

4 files changed

+23
-1
lines changed

4 files changed

+23
-1
lines changed

src/DtmCommon/Imp/TransBase.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@ public class TransBase
1919

2020
[JsonPropertyName("timeout_to_fail")]
2121
public long TimeoutToFail { get; set; }
22+
[JsonPropertyName("request_timeout")]
23+
public long RequestTimeout { get; set; }
2224

2325
[JsonPropertyName("retry_interval")]
2426
public long RetryInterval { get; set; }

src/Dtmcli/Saga/Saga.cs

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,16 @@ public Saga SetTimeoutToFail(long timeoutToFail)
7070
this._transBase.TimeoutToFail = timeoutToFail;
7171
return this;
7272
}
73-
73+
/// <summary>
74+
/// Set request timeout
75+
/// </summary>
76+
/// <param name="requestTimeout">request timeout</param>
77+
/// <returns></returns>
78+
public Saga SetRequestTimeout(long requestTimeout)
79+
{
80+
this._transBase.RequestTimeout = requestTimeout;
81+
return this;
82+
}
7483
/// <summary>
7584
/// Set retry interval for trans, unit is second
7685
/// </summary>

src/Dtmgrpc/DtmGImp/Utils.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -149,6 +149,7 @@ public static dtmgpb.DtmRequest BuildDtmRequest(TransBase transBase)
149149
TimeoutToFail = transBase.TimeoutToFail,
150150
RetryInterval = transBase.RetryInterval,
151151
RetryLimit = transBase.RetryLimit,
152+
RequestTimeout = transBase.RequestTimeout,
152153
};
153154

154155
if (transBase.BranchHeaders != null)

src/Dtmgrpc/Saga/SagaGrpc.cs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,16 @@ public SagaGrpc SetTimeoutToFail(long timeoutToFail)
7474
this._transBase.TimeoutToFail = timeoutToFail;
7575
return this;
7676
}
77+
/// <summary>
78+
/// Set request timeout
79+
/// </summary>
80+
/// <param name="requestTimeout">request timeout</param>
81+
/// <returns></returns>
82+
public SagaGrpc SetRequestTimeout(long requestTimeout)
83+
{
84+
this._transBase.RequestTimeout = requestTimeout;
85+
return this;
86+
}
7787

7888
/// <summary>
7989
/// Set retry interval for trans, unit is second

0 commit comments

Comments
 (0)