enable grpc retry
Change-Id: Id9f1cd18324e2788b2e6c4a9838ffff80ee49f0f
diff --git a/internal/pkg/config/config.go b/internal/pkg/config/config.go
index 14342a4..7f1e047 100644
--- a/internal/pkg/config/config.go
+++ b/internal/pkg/config/config.go
@@ -73,6 +73,8 @@
CoreEndpoint string
RPCTimeout time.Duration
MaxConcurrentFlowsPerUni int
+ PerRPCRetryTimeout time.Duration
+ MaxRetries uint
}
// ParseCommandArguments parses the arguments when running read-write adaptercore service
@@ -281,7 +283,14 @@
"max_concurrent_flows_per_uni",
16,
"The max number of concurrent flows (add/remove) that can be queued per UNI")
-
+ fs.DurationVar(&(so.PerRPCRetryTimeout),
+ "per_rpc_retry_timeout",
+ 0*time.Second,
+ "The default timeout per RPC retry")
+ fs.UintVar(&(so.MaxRetries),
+ "max_grpc_client_retry",
+ 0,
+ "The maximum number of times olt adaptor will retry in case grpc request timeouts")
_ = fs.Parse(args)
containerName := getContainerInfo()
if len(containerName) > 0 {