From 11d39a3756333f91a70d35362d8e216ef9d23b64 Mon Sep 17 00:00:00 2001 From: tmdiep Date: Mon, 5 Jul 2021 21:32:23 -0400 Subject: [PATCH] fix(pubsublite): lower gRPC keepalive timeouts --- 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, })), } }