@@ -37,7 +37,7 @@ public K8SHub(IKubernetes client, ILogger<K8SHub> logger)
37
37
/// <returns></returns>
38
38
public async IAsyncEnumerable < Pair < WatchEventType ? , V1Namespace > > Namespaces ( [ EnumeratorCancellation ] CancellationToken cancellationToken )
39
39
{
40
- var watcher = _kubernetesClient . ListNamespaceWithHttpMessagesAsync ( allowWatchBookmarks : false , watch : true , cancellationToken : cancellationToken ) ;
40
+ var watcher = _kubernetesClient . CoreV1 . ListNamespaceWithHttpMessagesAsync ( allowWatchBookmarks : false , watch : true , cancellationToken : cancellationToken ) ;
41
41
42
42
await foreach ( var ( type , item ) in watcher . WatchAsync < V1Namespace , V1NamespaceList > ( ) )
43
43
{
@@ -54,7 +54,7 @@ public K8SHub(IKubernetes client, ILogger<K8SHub> logger)
54
54
/// <returns></returns>
55
55
public async IAsyncEnumerable < Pair < WatchEventType ? , V1Deployment > > Deployments ( [ EnumeratorCancellation ] CancellationToken cancellationToken )
56
56
{
57
- var watcher = _kubernetesClient . ListDeploymentForAllNamespacesWithHttpMessagesAsync ( allowWatchBookmarks : false , watch : true , cancellationToken : cancellationToken ) ;
57
+ var watcher = _kubernetesClient . AppsV1 . ListDeploymentForAllNamespacesWithHttpMessagesAsync ( allowWatchBookmarks : false , watch : true , cancellationToken : cancellationToken ) ;
58
58
59
59
await foreach ( var ( type , item ) in watcher . WatchAsync < V1Deployment , V1DeploymentList > ( ) )
60
60
{
@@ -71,7 +71,7 @@ public K8SHub(IKubernetes client, ILogger<K8SHub> logger)
71
71
/// <returns></returns>
72
72
public async IAsyncEnumerable < Pair < WatchEventType ? , V1Pod > > Pods ( [ EnumeratorCancellation ] CancellationToken cancellationToken )
73
73
{
74
- var watcher = _kubernetesClient . ListPodForAllNamespacesWithHttpMessagesAsync ( allowWatchBookmarks : false , watch : true , cancellationToken : cancellationToken ) ;
74
+ var watcher = _kubernetesClient . CoreV1 . ListPodForAllNamespacesWithHttpMessagesAsync ( allowWatchBookmarks : false , watch : true , cancellationToken : cancellationToken ) ;
75
75
76
76
await foreach ( var ( type , item ) in watcher . WatchAsync < V1Pod , V1PodList > ( ) )
77
77
{
0 commit comments