diff --git a/benchmarks/KubernetesDiagnostics/Program.cs b/benchmarks/KubernetesDiagnostics/Program.cs index 46b2181e1a..cb3298171a 100644 --- a/benchmarks/KubernetesDiagnostics/Program.cs +++ b/benchmarks/KubernetesDiagnostics/Program.cs @@ -42,10 +42,7 @@ var app = builder.Build(); -app.MapGet("/", async (Cluster cluster) => -{ - -}); +app.MapGet("/", (Cluster cluster) => Task.CompletedTask); app.MapHealthChecks("/health"); diff --git a/src/Proto.Cluster.Kubernetes/KubernetesProvider.cs b/src/Proto.Cluster.Kubernetes/KubernetesProvider.cs index 4728d47849..0e67e3f189 100644 --- a/src/Proto.Cluster.Kubernetes/KubernetesProvider.cs +++ b/src/Proto.Cluster.Kubernetes/KubernetesProvider.cs @@ -48,9 +48,8 @@ public async Task GetDiagnostics() var res = await client.ListNamespacedPodWithHttpMessagesAsync( KubernetesExtensions.GetKubeNamespace(), labelSelector: selector, - watch: false, - timeoutSeconds: _config.WatchTimeoutSeconds - ).ConfigureAwait(false); + timeoutSeconds: _config.WatchTimeoutSeconds, + watch: false).ConfigureAwait(false); var pods = new DiagnosticsEntry("KubernetesProvider", "Pods", res.Body); diff --git a/src/Proto.Cluster.Kubernetes/Proto.Cluster.Kubernetes.csproj b/src/Proto.Cluster.Kubernetes/Proto.Cluster.Kubernetes.csproj index b91c099b1e..9342a7a1eb 100644 --- a/src/Proto.Cluster.Kubernetes/Proto.Cluster.Kubernetes.csproj +++ b/src/Proto.Cluster.Kubernetes/Proto.Cluster.Kubernetes.csproj @@ -7,7 +7,7 @@ - + diff --git a/src/Proto.Cluster/ClusterConfig.cs b/src/Proto.Cluster/ClusterConfig.cs index 84a2ac3303..a48169719a 100644 --- a/src/Proto.Cluster/ClusterConfig.cs +++ b/src/Proto.Cluster/ClusterConfig.cs @@ -42,7 +42,7 @@ private ClusterConfig(string clusterName, IClusterProvider clusterProvider, IIde GossipRequestTimeout = TimeSpan.FromMilliseconds(1500); GossipFanout = 3; GossipMaxSend = 50; - HeartbeatExpiration = TimeSpan.FromSeconds(20); + HeartbeatExpiration = TimeSpan.Zero; ClusterRequestDeDuplicationWindow = TimeSpan.FromSeconds(30); IdentityLookup = identityLookup; MemberStrategyBuilder = (_, _) => new SimpleMemberStrategy();