Rename resource classes from *Resource to *Type and better check for readiness in case of type == null

README.md

@@ -71,12 +71,12 @@ class Test {
 }
 //...
 ```
-### Register `ResourceType` or `NamespacedResoruceType` classes into `KubeResoruceManager`
+### Register `ResourceType` or `NamespacedResourceType` classes into `KubeResourceManager`
 ```java
 KubeResourceManager.getInstance().setResourceTypes(
-        new NamespaceResource(),
-        new JobResource(),
-        new NetworkPolicyResource()
+        new NamespaceType(),
+        new JobType(),
+        new NetworkPolicyType()
 );
 ```
 

test-frame-common/src/main/java/io/skodjob/testframe/resources/KubeResourceManager.java

@@ -15,7 +15,14 @@
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.function.Consumer;
 
+import io.fabric8.kubernetes.api.model.Endpoints;
 import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.fabric8.kubernetes.api.model.Node;
+import io.fabric8.kubernetes.api.model.Pod;
+import io.fabric8.kubernetes.api.model.ReplicationController;
+import io.fabric8.kubernetes.api.model.apps.Deployment;
+import io.fabric8.kubernetes.api.model.apps.ReplicaSet;
+import io.fabric8.kubernetes.api.model.apps.StatefulSet;
 import io.skodjob.testframe.LoggerUtils;
 import io.skodjob.testframe.TestFrameConstants;
 import io.skodjob.testframe.TestFrameEnv;
@@ -244,11 +251,10 @@ private <T extends HasMetadata> void createOrUpdateResource(boolean waitReady,
                 }
                 if (waitReady) {
                     assertTrue(waitResourceCondition(resource, new ResourceCondition<>(p -> {
-                        try {
+                        if (isResourceWithReadiness(resource)) {
                             return client.getClient().resource(resource).isReady();
-                        } catch (Exception ex) {
-                            return client.getClient().resource(resource) != null;
                         }
+                        return client.getClient().resource(resource) != null;
                     }, "ready")),
                             String.format("Timed out waiting for %s/%s in %s to be ready", resource.getKind(),
                                     resource.getMetadata().getName(), resource.getMetadata().getNamespace()));
@@ -425,4 +431,15 @@ private <T extends HasMetadata> ResourceType<T> findResourceType(T resource) {
         }
         return null;
     }
+
+    private <T extends HasMetadata> boolean isResourceWithReadiness(T resource) {
+        return resource instanceof Deployment
+            || resource instanceof io.fabric8.kubernetes.api.model.extensions.Deployment
+            || resource instanceof ReplicaSet
+            || resource instanceof Pod
+            || resource instanceof ReplicationController
+            || resource instanceof Endpoints
+            || resource instanceof Node
+            || resource instanceof StatefulSet;
+    }
 }

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ClusterRoleBindingResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ClusterRoleBindingType.java

@@ -15,15 +15,15 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class ClusterRoleBindingResource implements ResourceType<ClusterRoleBinding> {
+public class ClusterRoleBindingType implements ResourceType<ClusterRoleBinding> {
 
     private final NonNamespaceOperation<ClusterRoleBinding, ClusterRoleBindingList,
             Resource<ClusterRoleBinding>> client;
 
     /**
      * Constructor
      */
-    public ClusterRoleBindingResource() {
+    public ClusterRoleBindingType() {
         this.client = KubeResourceManager.getKubeClient().getClient().rbac().clusterRoleBindings();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ClusterRoleResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ClusterRoleType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class ClusterRoleResource implements ResourceType<ClusterRole> {
+public class ClusterRoleType implements ResourceType<ClusterRole> {
 
     private final NonNamespaceOperation<ClusterRole, ClusterRoleList, Resource<ClusterRole>> client;
 
     /**
      * Constructor
      */
-    public ClusterRoleResource() {
+    public ClusterRoleType() {
         this.client = KubeResourceManager.getKubeClient().getClient().rbac().clusterRoles();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ConfigMapResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ConfigMapType.java

@@ -15,13 +15,13 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class ConfigMapResource implements NamespacedResourceType<ConfigMap> {
+public class ConfigMapType implements NamespacedResourceType<ConfigMap> {
     private final MixedOperation<ConfigMap, ConfigMapList, Resource<ConfigMap>> client;
 
     /**
      * Constructor
      */
-    public ConfigMapResource() {
+    public ConfigMapType() {
         this.client = KubeResourceManager.getKubeClient().getClient().configMaps();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/CustomResourceDefinitionResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/CustomResourceDefinitionType.java

@@ -15,15 +15,15 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class CustomResourceDefinitionResource implements ResourceType<CustomResourceDefinition> {
+public class CustomResourceDefinitionType implements ResourceType<CustomResourceDefinition> {
 
     private final NonNamespaceOperation<CustomResourceDefinition, CustomResourceDefinitionList,
             Resource<CustomResourceDefinition>> client;
 
     /**
      * Constructor
      */
-    public CustomResourceDefinitionResource() {
+    public CustomResourceDefinitionType() {
         this.client = KubeResourceManager.getKubeClient().getClient().apiextensions().v1().customResourceDefinitions();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/DeploymentResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/DeploymentType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class DeploymentResource implements NamespacedResourceType<Deployment> {
+public class DeploymentType implements NamespacedResourceType<Deployment> {
 
     private final MixedOperation<Deployment, DeploymentList, RollableScalableResource<Deployment>> client;
 
     /**
      * Constructor
      */
-    public DeploymentResource() {
+    public DeploymentType() {
         this.client = KubeResourceManager.getKubeClient().getClient().apps().deployments();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/JobResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/JobType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class JobResource implements NamespacedResourceType<Job> {
+public class JobType implements NamespacedResourceType<Job> {
 
     private final MixedOperation<Job, JobList, ScalableResource<Job>> client;
 
     /**
      * Constructor
      */
-    public JobResource() {
+    public JobType() {
         this.client = KubeResourceManager.getKubeClient().getClient().batch().v1().jobs();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/LeaseResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/LeaseType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class LeaseResource implements NamespacedResourceType<Lease> {
+public class LeaseType implements NamespacedResourceType<Lease> {
 
     private MixedOperation<Lease, LeaseList, Resource<Lease>> client;
 
     /**
      * Constructor
      */
-    public LeaseResource() {
+    public LeaseType() {
         this.client = KubeResourceManager.getKubeClient().getClient().leases();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/NamespaceResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/NamespaceType.java

@@ -16,14 +16,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class NamespaceResource implements ResourceType<Namespace> {
+public class NamespaceType implements ResourceType<Namespace> {
 
     private final NonNamespaceOperation<Namespace, NamespaceList, Resource<Namespace>> client;
 
     /**
      * Constructor
      */
-    public NamespaceResource() {
+    public NamespaceType() {
         this.client = KubeResourceManager.getKubeClient().getClient().namespaces();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/NetworkPolicyResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/NetworkPolicyType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class NetworkPolicyResource implements NamespacedResourceType<NetworkPolicy> {
+public class NetworkPolicyType implements NamespacedResourceType<NetworkPolicy> {
 
     private final MixedOperation<NetworkPolicy, NetworkPolicyList, Resource<NetworkPolicy>> client;
 
     /**
      * Constructor
      */
-    public NetworkPolicyResource() {
+    public NetworkPolicyType() {
         this.client = KubeResourceManager.getKubeClient().getClient().network().networkPolicies();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/RoleBindingResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/RoleBindingType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class RoleBindingResource implements NamespacedResourceType<RoleBinding> {
+public class RoleBindingType implements NamespacedResourceType<RoleBinding> {
 
     private final MixedOperation<RoleBinding, RoleBindingList, Resource<RoleBinding>> client;
 
     /**
      * Constructor
      */
-    public RoleBindingResource() {
+    public RoleBindingType() {
         this.client = KubeResourceManager.getKubeClient().getClient().rbac().roleBindings();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/RoleResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/RoleType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class RoleResource implements NamespacedResourceType<Role> {
+public class RoleType implements NamespacedResourceType<Role> {
 
     private final MixedOperation<Role, RoleList, Resource<Role>> client;
 
     /**
      * Constructor
      */
-    public RoleResource() {
+    public RoleType() {
         this.client = KubeResourceManager.getKubeClient().getClient().rbac().roles();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/SecretResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/SecretType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class SecretResource implements NamespacedResourceType<Secret> {
+public class SecretType implements NamespacedResourceType<Secret> {
 
     private final MixedOperation<Secret, SecretList, Resource<Secret>> client;
 
     /**
      * Constructor
      */
-    public SecretResource() {
+    public SecretType() {
         this.client = KubeResourceManager.getKubeClient().getClient().secrets();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ServiceAccountResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ServiceAccountType.java

@@ -9,20 +9,20 @@
 import io.fabric8.kubernetes.api.model.ServiceAccount;
 import io.fabric8.kubernetes.api.model.ServiceAccountList;
 import io.fabric8.kubernetes.client.dsl.MixedOperation;
+import io.fabric8.kubernetes.client.dsl.ServiceAccountResource;
 import io.skodjob.testframe.interfaces.NamespacedResourceType;
 
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class ServiceAccountResource implements NamespacedResourceType<ServiceAccount> {
+public class ServiceAccountType implements NamespacedResourceType<ServiceAccount> {
 
-    private final MixedOperation<ServiceAccount, ServiceAccountList,
-            io.fabric8.kubernetes.client.dsl.ServiceAccountResource> client;
+    private final MixedOperation<ServiceAccount, ServiceAccountList, ServiceAccountResource> client;
 
     /**
      * Constructor
      */
-    public ServiceAccountResource() {
+    public ServiceAccountType() {
         this.client = KubeResourceManager.getKubeClient().getClient().serviceAccounts();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ServiceResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ServiceType.java

@@ -9,20 +9,20 @@
 import io.fabric8.kubernetes.api.model.Service;
 import io.fabric8.kubernetes.api.model.ServiceList;
 import io.fabric8.kubernetes.client.dsl.MixedOperation;
+import io.fabric8.kubernetes.client.dsl.ServiceResource;
 import io.skodjob.testframe.interfaces.NamespacedResourceType;
 
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class ServiceResource implements NamespacedResourceType<Service> {
+public class ServiceType implements NamespacedResourceType<Service> {
 
-    private final MixedOperation<Service, ServiceList,
-            io.fabric8.kubernetes.client.dsl.ServiceResource<Service>> client;
+    private final MixedOperation<Service, ServiceList, ServiceResource<Service>> client;
 
     /**
      * Constructor
      */
-    public ServiceResource() {
+    public ServiceType() {
         this.client = KubeResourceManager.getKubeClient().getClient().services();
     }
 

test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ValidatingWebhookConfigurationResource.java → test-frame-kubernetes/src/main/java/io/skodjob/testframe/resources/ValidatingWebhookConfigurationType.java

@@ -15,7 +15,7 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class ValidatingWebhookConfigurationResource implements ResourceType<ValidatingWebhookConfiguration> {
+public class ValidatingWebhookConfigurationType implements ResourceType<ValidatingWebhookConfiguration> {
 
 
     private final NonNamespaceOperation<ValidatingWebhookConfiguration, ValidatingWebhookConfigurationList,
@@ -24,7 +24,7 @@ public class ValidatingWebhookConfigurationResource implements ResourceType<Vali
     /**
      * Constructor
      */
-    public ValidatingWebhookConfigurationResource() {
+    public ValidatingWebhookConfigurationType() {
         this.client = KubeResourceManager.getKubeClient().getClient()
                 .admissionRegistration()
                 .v1()

test-frame-metrics-collector/src/test/java/io/skodjob/testframe/MetricsCollectorTest.java

@@ -1,6 +1,9 @@
 package io.skodjob.testframe;
 
-import static org.junit.jupiter.api.Assertions.*;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 import io.fabric8.kubernetes.api.model.LabelSelector;
 import io.fabric8.kubernetes.api.model.LabelSelectorBuilder;

test-frame-openshift/src/main/java/io/skodjob/testframe/resources/InstallPlanResource.java → test-frame-openshift/src/main/java/io/skodjob/testframe/resources/InstallPlanType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class InstallPlanResource implements NamespacedResourceType<InstallPlan> {
+public class InstallPlanType implements NamespacedResourceType<InstallPlan> {
 
     private final MixedOperation<InstallPlan, InstallPlanList, Resource<InstallPlan>> client;
 
     /**
      * Constructor
      */
-    public InstallPlanResource() {
+    public InstallPlanType() {
         this.client = KubeResourceManager.getKubeClient().getOpenShiftClient().operatorHub().installPlans();
     }
 

test-frame-openshift/src/main/java/io/skodjob/testframe/resources/OperatorGroupResource.java → test-frame-openshift/src/main/java/io/skodjob/testframe/resources/OperatorGroupType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class OperatorGroupResource implements NamespacedResourceType<OperatorGroup> {
+public class OperatorGroupType implements NamespacedResourceType<OperatorGroup> {
 
     private final MixedOperation<OperatorGroup, OperatorGroupList, Resource<OperatorGroup>> client;
 
     /**
      * Constructor
      */
-    public OperatorGroupResource() {
+    public OperatorGroupType() {
         this.client = KubeResourceManager.getKubeClient().getOpenShiftClient().operatorHub().operatorGroups();
     }
 

test-frame-openshift/src/main/java/io/skodjob/testframe/resources/SubscriptionResource.java → test-frame-openshift/src/main/java/io/skodjob/testframe/resources/SubscriptionType.java

@@ -15,14 +15,14 @@
 /**
  * Implementation of ResourceType for specific kubernetes resource
  */
-public class SubscriptionResource implements NamespacedResourceType<Subscription> {
+public class SubscriptionType implements NamespacedResourceType<Subscription> {
 
     private final MixedOperation<Subscription, SubscriptionList, Resource<Subscription>> client;
 
     /**
      * Constructor
      */
-    public SubscriptionResource() {
+    public SubscriptionType() {
         this.client = KubeResourceManager.getKubeClient().getOpenShiftClient().operatorHub().subscriptions();
     }