deps : Update Fabric8 Kubernetes Client to v6.9.0

Signed-off-by: Rohan Kumar <rohaan@redhat.com>

kubernetes-client-demo-parent/pom.xml

@@ -17,7 +17,7 @@
  <maven-surefire-plugin.version>3.0.0-M7</maven-surefire-plugin.version>
  <maven-failsafe-plugin.version>3.0.0-M7</maven-failsafe-plugin.version>
  <junit.version>5.9.1</junit.version>
- <fabric8.version>6.8.0</fabric8.version>
+ <fabric8.version>6.9.0</fabric8.version>
  </properties>
 
  <modules>

src/main/java/io/fabric8/CustomResourceInformerLabels.java

@@ -0,0 +1,37 @@
+package io.fabric8;
+
+import io.fabric8.crd.mode.v1.Dummy;
+import io.fabric8.kubernetes.client.KubernetesClient;
+import io.fabric8.kubernetes.client.KubernetesClientBuilder;
+import io.fabric8.kubernetes.client.informers.ResourceEventHandler;
+import io.fabric8.kubernetes.client.informers.SharedIndexInformer;
+
+public class CustomResourceInformerLabels {
+ public static void main(String[] args) {
+ try (KubernetesClient client = new KubernetesClientBuilder().build()) {
+ ResourceEventHandler<Dummy> myEventHandler = new ResourceEventHandler<>() {
+ @Override
+ public void onAdd(Dummy dummy) {
+ System.out.printf("ADDED %s/%s\n", dummy.getMetadata().getNamespace(), dummy.getMetadata().getName());
+ }
+
+ @Override
+ public void onUpdate(Dummy dummy, Dummy t1) {
+ System.out.printf("MODIFIED %s/%s\n", dummy.getMetadata().getNamespace(), dummy.getMetadata().getName());
+
+ }
+
+ @Override
+ public void onDelete(Dummy dummy, boolean b) {
+ System.out.printf("DELETED %s/%s\n", dummy.getMetadata().getNamespace(), dummy.getMetadata().getName());
+ }
+ };
+ SharedIndexInformer<Dummy> informer = client.resources(Dummy.class)
+ .inNamespace("default")
+ .withLabel("app", "test-operator")
+ .inform(myEventHandler, 30 * 1000L);
+
+ informer.close();
+ }
+ }
+}

src/main/java/io/fabric8/ServiceAccountInformerLabels.java

@@ -11,26 +11,26 @@
 public class ServiceAccountInformerLabels {
  public static void main(String[] args) {
  try (KubernetesClient client = new KubernetesClientBuilder().build()) {
- SharedIndexInformer<ServiceAccount> serviceAccountSharedIndexInformer = client.serviceAccounts().withLabels(Collections.singletonMap("foo", "bar")).inform(new ResourceEventHandler<ServiceAccount>() {
-  @Override
-  public void onAdd(ServiceAccount serviceAccount) {
-  System.out.printf("ADDED %s/%s\n", serviceAccount.getMetadata().getNamespace(), serviceAccount.getMetadata().getName());
-  }
+ SharedIndexInformer<ServiceAccount> serviceAccountSharedIndexInformer = client.serviceAccounts().withLabels(Collections.singletonMap("foo", "bar")).inform(new ResourceEventHandler<>() {
+ @Override
+ public void onAdd(ServiceAccount serviceAccount) {
+ System.out.printf("ADDED %s/%s\n", serviceAccount.getMetadata().getNamespace(), serviceAccount.getMetadata().getName());
+ }
 
-  @Override
-  public void onUpdate(ServiceAccount serviceAccount, ServiceAccount t1) {
-  System.out.printf("MODIFIED %s/%s\n", serviceAccount.getMetadata().getNamespace(), serviceAccount.getMetadata().getName());
+ @Override
+ public void onUpdate(ServiceAccount serviceAccount, ServiceAccount t1) {
+ System.out.printf("MODIFIED %s/%s\n", serviceAccount.getMetadata().getNamespace(), serviceAccount.getMetadata().getName());
 
-  }
+ }
 
-  @Override
-  public void onDelete(ServiceAccount serviceAccount, boolean b) {
-  System.out.printf("DELETED %s/%s\n", serviceAccount.getMetadata().getNamespace(), serviceAccount.getMetadata().getName());
-  }
+ @Override
+ public void onDelete(ServiceAccount serviceAccount, boolean b) {
+ System.out.printf("DELETED %s/%s\n", serviceAccount.getMetadata().getNamespace(), serviceAccount.getMetadata().getName());
+ }
  });
 
  Thread.sleep(30 * 160 * 1000L);
- serviceAccountSharedIndexInformer.stop();
+ serviceAccountSharedIndexInformer.close();
  } catch (InterruptedException interruptedException) {
  Thread.currentThread().interrupt();
  interruptedException.printStackTrace();

writing-tests-with-fabric8/src/test/java/io/fabric8/demos/tests/mockserver/PodGroupServiceTest.java

@@ -116,7 +116,7 @@ void watch_whenInvoked_shouldMonitorUpdates() throws Exception {
  PodGroupService podGroupService = new PodGroupService(kubernetesClient, Collections.singletonMap("foo", "bar"));
  CountDownLatch eventReceivedLatch = new CountDownLatch(1);
  server.expect()
- .withPath("/api/v1/namespaces/test/pods?labelSelector=foo%3Dbar&allowWatchBookmarks=true&watch=true")
+ .withPath("/api/v1/namespaces/test/pods?allowWatchBookmarks=true&labelSelector=foo%3Dbar&watch=true")
  .andUpgradeToWebSocket()
  .open()
  .waitFor(50)