From 35d98c8cad3a71400c2b47218a0fb9c80154e613 Mon Sep 17 00:00:00 2001 From: tmdiep Date: Tue, 6 Jul 2021 12:09:35 +1000 Subject: [PATCH] fix(pubsublite): lower gRPC keepalive timeouts (#4378) --- pubsublite/internal/wire/rpc.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pubsublite/internal/wire/rpc.go b/pubsublite/internal/wire/rpc.go index 188f148bb9c..b77df47db41 100644 --- a/pubsublite/internal/wire/rpc.go +++ b/pubsublite/internal/wire/rpc.go @@ -183,9 +183,11 @@ func isStreamResetSignal(err error) bool { func defaultClientOptions(region string) []option.ClientOption { return []option.ClientOption{ internaloption.WithDefaultEndpoint(region + pubsubLiteDefaultEndpoint), - // Keep inactive connections alive. + // Detect if transport is still alive if there is inactivity. option.WithGRPCDialOption(grpc.WithKeepaliveParams(keepalive.ClientParameters{ - Time: 5 * time.Minute, + Time: 1 * time.Minute, + Timeout: 1 * time.Minute, + PermitWithoutStream: true, })), } }