fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change default timeout of aggregation to 10 seconds #399

Browse Source
This commit is contained in:
Francis Dong
2022-01-27 10:08:37 +08:00
committed by dxfeng10
parent 612fd0ef61
commit 24848e65a5
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fizz-core/src/main/java/we/fizz/input/extension/dubbo/DubboInput.java
View File

@@ -64,7 +64,7 @@ public class DubboInput extends RPCInput {
protected Mono<RPCResponse> getClientSpecFromContext(InputConfig aConfig, InputContext inputContext) {
DubboInputConfig config = (DubboInputConfig) aConfig;
int timeout = config.getTimeout() < 1 ? 3000 : config.getTimeout() > 10000 ? 10000 : config.getTimeout();
int timeout = config.getTimeout() < 1 ? 10000 : config.getTimeout() > 30000 ? 30000 : config.getTimeout();
long numRetries = config.getNumRetries() > 0 ? config.getNumRetries() : 0;
long retryInterval = config.getRetryInterval() > 0 ? config.getRetryInterval() : 0;
Map<String, String> attachments = (Map<String, String>) request.get("attachments");

2
fizz-core/src/main/java/we/fizz/input/extension/grpc/GrpcInput.java
View File

@@ -58,7 +58,7 @@ public class GrpcInput extends RPCInput implements IInput {
protected Mono<RPCResponse> getClientSpecFromContext(InputConfig aConfig, InputContext inputContext) {
GrpcInputConfig config = (GrpcInputConfig) aConfig;
int timeout = config.getTimeout() < 1 ? 3000 : config.getTimeout() > 10000 ? 10000 : config.getTimeout();
int timeout = config.getTimeout() < 1 ? 10000 : config.getTimeout() > 30000 ? 30000 : config.getTimeout();
long numRetries = config.getNumRetries() > 0 ? config.getNumRetries() : 0;
long retryInterval = config.getRetryInterval() > 0 ? config.getRetryInterval() : 0;
Map<String, String> attachments = (Map<String, String>) request.get("attachments");

2
fizz-core/src/main/java/we/fizz/input/extension/request/RequestInput.java
View File

@@ -336,7 +336,7 @@ public class RequestInput extends RPCInput implements IInput{
protected Mono<RPCResponse> getClientSpecFromContext(InputConfig aConfig, InputContext inputContext) {
RequestInputConfig config = (RequestInputConfig) aConfig;
int timeout = config.getTimeout() < 1 ? 3000 : config.getTimeout() > 10000 ? 10000 : config.getTimeout();
int timeout = config.getTimeout() < 1 ? 10000 : config.getTimeout() > 30000 ? 30000 : config.getTimeout();
long numRetries = config.getNumRetries() > 0 ? config.getNumRetries() : 0;
long retryInterval = config.getRetryInterval() > 0 ? config.getRetryInterval() : 0;