fix: keep alive enforcement policy (#499)

* fix: keep alive enforcement policy * fix: half min
hatchet-dev · May 15, 2024 · 0ffc3e9 · 0ffc3e9
1 parent 63c0b0c
commit 0ffc3e9
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/internal/services/grpc/server.go b/internal/services/grpc/server.go
@@ -245,6 +245,13 @@ func (s *Server) startGRPC() (func() error, error) {
 		recovery.UnaryServerInterceptor(recovery.WithRecoveryHandler(grpcPanicRecoveryHandler)),
 	))
 
+	var enforcement = keepalive.EnforcementPolicy{
+		MinTime:             5 * time.Second,
+		PermitWithoutStream: true,
+	}
+
+	serverOpts = append(serverOpts, grpc.KeepaliveEnforcementPolicy(enforcement))
+
 	var kasp = keepalive.ServerParameters{
 		// ping the client every 30 seconds if idle to ensure the connection is still active
 		Time: 30 * time.Second,