update kubernetes client (#2038)

asynkron · Sep 6, 2023 · cdd0329 · cdd0329
1 parent 32fc17b
commit cdd0329
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/src/Proto.Cluster.Kubernetes/KubernetesClusterMonitor.cs b/src/Proto.Cluster.Kubernetes/KubernetesClusterMonitor.cs
@@ -202,7 +202,7 @@ private Task<HttpOperationResponse<V1PodList>> GetListTask(string clusterName, b
         Logger.Log(_config.DebugLogLevel, "[Cluster][KubernetesProvider] Starting to watch pods with {Selector}",
             selector);
 
-        return _kubernetes.ListNamespacedPodWithHttpMessagesAsync(
+        return _kubernetes.CoreV1.ListNamespacedPodWithHttpMessagesAsync(
             KubernetesExtensions.GetKubeNamespace(),
             labelSelector: selector,
             watch: watch,

diff --git a/src/Proto.Cluster.Kubernetes/KubernetesExtensions.cs b/src/Proto.Cluster.Kubernetes/KubernetesExtensions.cs
@@ -49,7 +49,7 @@ IDictionary<string, string> annotations
         var expected = JsonSerializer.SerializeToDocument(pod);
         var patch = old.CreatePatch(expected);
 
-        return kubernetes.PatchNamespacedPodAsync(new V1Patch(patch, V1Patch.PatchType.JsonPatch), podName,
+        return kubernetes.CoreV1.PatchNamespacedPodAsync(new V1Patch(patch, V1Patch.PatchType.JsonPatch), podName,
             podNamespace);
     }
 

diff --git a/src/Proto.Cluster.Kubernetes/KubernetesProvider.cs b/src/Proto.Cluster.Kubernetes/KubernetesProvider.cs
@@ -45,7 +45,7 @@ public async Task<DiagnosticsEntry[]> GetDiagnostics()
         {
             var selector = $"{LabelCluster}={_clusterName}";
             using var client = _config.ClientFactory();
-            var res = await client.ListNamespacedPodWithHttpMessagesAsync(
+            var res = await client.CoreV1.ListNamespacedPodWithHttpMessagesAsync(
                 KubernetesExtensions.GetKubeNamespace(),
                 labelSelector: selector,
                 timeoutSeconds: _config.WatchTimeoutSeconds,
@@ -139,7 +139,7 @@ public async Task RegisterMemberInner()
         Logger.LogInformation("[Cluster][KubernetesProvider] Registering service {PodName} on {PodIp}", _podName,
             _address);
 
-        var pod = await kubernetes.ReadNamespacedPodAsync(_podName, KubernetesExtensions.GetKubeNamespace()).ConfigureAwait(false);
+        var pod = await kubernetes.CoreV1.ReadNamespacedPodAsync(_podName, KubernetesExtensions.GetKubeNamespace()).ConfigureAwait(false);
 
         if (pod is null)
         {
@@ -230,7 +230,7 @@ private async Task DeregisterMemberInner(Cluster cluster)
 
         var kubeNamespace = KubernetesExtensions.GetKubeNamespace();
 
-        var pod = await kubernetes.ReadNamespacedPodAsync(_podName, kubeNamespace).ConfigureAwait(false);
+        var pod = await kubernetes.CoreV1.ReadNamespacedPodAsync(_podName, kubeNamespace).ConfigureAwait(false);
 
         var labels = pod.Metadata.Labels
             .Where(label => !label.Key.StartsWith(ProtoClusterPrefix, StringComparison.Ordinal))

diff --git a/src/Proto.Cluster.Kubernetes/Proto.Cluster.Kubernetes.csproj b/src/Proto.Cluster.Kubernetes/Proto.Cluster.Kubernetes.csproj
@@ -7,7 +7,7 @@
 
     <ItemGroup>
         <PackageReference Include="JsonPatch.Net" Version="1.1.2" />
-        <PackageReference Include="KubernetesClient" Version="7.2.19" />
+        <PackageReference Include="KubernetesClient" Version="12.0.16" />
     </ItemGroup>
 
     <ItemGroup>