Add gRPC initial win size of 4MB for less latency

go-graphite · Jan 10, 2023 · 37e23b3 · 37e23b3
1 parent d8d76ca
commit 37e23b3
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/carbonserver/carbonserver.go b/carbonserver/carbonserver.go
@@ -2084,14 +2084,16 @@ func (listener *CarbonserverListener) ListenGRPC(listen string) error {
 	}
 
 	var opts []grpc.ServerOption
-	opts = append(opts, grpc.KeepaliveEnforcementPolicy(keepalive.EnforcementPolicy{
-		MinTime:             10 * time.Second,
-		PermitWithoutStream: true,
-	}))
-	opts = append(opts, grpc.KeepaliveParams(keepalive.ServerParameters{
-		Time:    60 * time.Second,
-		Timeout: 20 * time.Second,
-	}))
+	opts = append(opts,
+		grpc.KeepaliveEnforcementPolicy(keepalive.EnforcementPolicy{
+			MinTime:             10 * time.Second,
+			PermitWithoutStream: true,
+		}),
+		grpc.KeepaliveParams(keepalive.ServerParameters{
+			Time:    60 * time.Second,
+			Timeout: 20 * time.Second,
+		}))
+	opts = append(opts, grpc.InitialWindowSize(4*1024*1024), grpc.InitialConnWindowSize(4*1024*1024))
 	opts = append(opts, grpc.ChainStreamInterceptor(
 		grpcutil.StreamServerTimeHandler(listener.bucketRequestTimesGRPC),
 		grpcutil.StreamServerStatusMetricHandler(statusCodes, listener.prometheus.request),