From 5987b0899c21d40cc2c90c29fcf3c25b27660d0c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Karol=20S=C3=B3jko?= Date: Tue, 2 Jan 2024 10:54:07 +0100 Subject: [PATCH] fix: adjust grpc keepalive parameters --- packages/api-gateway/src/Bootstrap/Container.ts | 4 +--- packages/auth/bin/server.ts | 6 ++++-- packages/syncing-server/bin/server.ts | 6 ++++-- 3 files changed, 9 insertions(+), 7 deletions(-) diff --git a/packages/api-gateway/src/Bootstrap/Container.ts b/packages/api-gateway/src/Bootstrap/Container.ts index 51a115ae9..5d71fc484 100644 --- a/packages/api-gateway/src/Bootstrap/Container.ts +++ b/packages/api-gateway/src/Bootstrap/Container.ts @@ -152,7 +152,7 @@ export class ContainerConfigLoader { container.bind(TYPES.ApiGateway_SYNCING_SERVER_GRPC_URL).toConstantValue(env.get('SYNCING_SERVER_GRPC_URL')) const grpcAgentKeepAliveTimeout = env.get('GRPC_AGENT_KEEP_ALIVE_TIMEOUT', true) ? +env.get('GRPC_AGENT_KEEP_ALIVE_TIMEOUT', true) - : 8_000 + : 20_000 const grpcMaxMessageSize = env.get('GRPC_MAX_MESSAGE_SIZE', true) ? +env.get('GRPC_MAX_MESSAGE_SIZE', true) @@ -163,7 +163,6 @@ export class ContainerConfigLoader { container.get(TYPES.ApiGateway_AUTH_SERVER_GRPC_URL), grpc.credentials.createInsecure(), { - 'grpc.keepalive_time_ms': grpcAgentKeepAliveTimeout * 2, 'grpc.keepalive_timeout_ms': grpcAgentKeepAliveTimeout, 'grpc.default_compression_algorithm': grpc.compressionAlgorithms.gzip, 'grpc.default_compression_level': 2, @@ -177,7 +176,6 @@ export class ContainerConfigLoader { container.get(TYPES.ApiGateway_SYNCING_SERVER_GRPC_URL), grpc.credentials.createInsecure(), { - 'grpc.keepalive_time_ms': grpcAgentKeepAliveTimeout * 2, 'grpc.keepalive_timeout_ms': grpcAgentKeepAliveTimeout, 'grpc.default_compression_algorithm': grpc.compressionAlgorithms.gzip, 'grpc.default_compression_level': 2, diff --git a/packages/auth/bin/server.ts b/packages/auth/bin/server.ts index be4d66933..0f48bd374 100644 --- a/packages/auth/bin/server.ts +++ b/packages/auth/bin/server.ts @@ -84,16 +84,18 @@ void container.load().then((container) => { serverInstance.keepAliveTimeout = httpKeepAliveTimeout + const grpcKeepAliveTime = env.get('GRPC_KEEP_ALIVE_TIME', true) ? +env.get('GRPC_KEEP_ALIVE_TIME', true) : 7_200_000 + const grpcKeepAliveTimeout = env.get('GRPC_KEEP_ALIVE_TIMEOUT', true) ? +env.get('GRPC_KEEP_ALIVE_TIMEOUT', true) - : 10_000 + : 20_000 const grpcMaxMessageSize = env.get('GRPC_MAX_MESSAGE_SIZE', true) ? +env.get('GRPC_MAX_MESSAGE_SIZE', true) : 1024 * 1024 * 50 const grpcServer = new grpc.Server({ - 'grpc.keepalive_time_ms': grpcKeepAliveTimeout * 2, + 'grpc.keepalive_time_ms': grpcKeepAliveTime, 'grpc.keepalive_timeout_ms': grpcKeepAliveTimeout, 'grpc.default_compression_algorithm': grpc.compressionAlgorithms.gzip, 'grpc.max_receive_message_length': grpcMaxMessageSize, diff --git a/packages/syncing-server/bin/server.ts b/packages/syncing-server/bin/server.ts index 6602eba34..964e881da 100644 --- a/packages/syncing-server/bin/server.ts +++ b/packages/syncing-server/bin/server.ts @@ -85,16 +85,18 @@ void container.load().then((container) => { serverInstance.keepAliveTimeout = keepAliveTimeout + const grpcKeepAliveTime = env.get('GRPC_KEEP_ALIVE_TIME', true) ? +env.get('GRPC_KEEP_ALIVE_TIME', true) : 7_200_000 + const grpcKeepAliveTimeout = env.get('GRPC_KEEP_ALIVE_TIMEOUT', true) ? +env.get('GRPC_KEEP_ALIVE_TIMEOUT', true) - : 10_000 + : 20_000 const grpcMaxMessageSize = env.get('GRPC_MAX_MESSAGE_SIZE', true) ? +env.get('GRPC_MAX_MESSAGE_SIZE', true) : 1024 * 1024 * 50 const grpcServer = new grpc.Server({ - 'grpc.keepalive_time_ms': grpcKeepAliveTimeout * 2, + 'grpc.keepalive_time_ms': grpcKeepAliveTime, 'grpc.keepalive_timeout_ms': grpcKeepAliveTimeout, 'grpc.default_compression_algorithm': grpc.compressionAlgorithms.gzip, 'grpc.max_receive_message_length': grpcMaxMessageSize,