e2e test skeleton

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

sample-operators/metrics-processing/k8s/operator.yaml

@@ -17,84 +17,55 @@
 apiVersion: v1
 kind: ServiceAccount
 metadata:
-  name: webpage-operator
+  name: metrics-processing-operator
 
 ---
 apiVersion: apps/v1
 kind: Deployment
 metadata:
-  name: webpage-operator
+  name: metrics-processing-operator
 spec:
   selector:
     matchLabels:
-      app: webpage-operator
+      app: metrics-processing-operator
   replicas: 1
   template:
     metadata:
       labels:
-        app: webpage-operator
+        app: metrics-processing-operator
     spec:
-      serviceAccountName: webpage-operator
+      serviceAccountName: metrics-processing-operator
       containers:
       - name: operator
-        image: webpage-operator
+        image: metrics-processing-operator
         imagePullPolicy: Never
-        ports:
-        - containerPort: 80
-        startupProbe:
-          httpGet:
-            path: /startup
-            port: 8080
-          initialDelaySeconds: 1
-          periodSeconds: 2
-          timeoutSeconds: 1
-          failureThreshold: 10
-        livenessProbe:
-          httpGet:
-            path: /healthz
-            port: 8080
-          initialDelaySeconds: 5
-          timeoutSeconds: 1
-          periodSeconds: 2
-          failureThreshold: 3
 
 ---
 apiVersion: rbac.authorization.k8s.io/v1
 kind: ClusterRoleBinding
 metadata:
-  name: operator-admin
+  name: metrics-processing-operator-admin
 subjects:
 - kind: ServiceAccount
-  name: webpage-operator
+  name: metrics-processing-operator
   namespace: default
 roleRef:
   kind: ClusterRole
-  name: webpage-operator
-  apiGroup: ""
+  name: metrics-processing-operator
+  apiGroup: rbac.authorization.k8s.io
 
 ---
 apiVersion: rbac.authorization.k8s.io/v1
 kind: ClusterRole
 metadata:
-  name: webpage-operator
+  name: metrics-processing-operator
 rules:
 - apiGroups:
   - ""
   resources:
-  - deployments
-  - services
-  - configmaps
   - pods
   verbs:
   - '*'
-- apiGroups:
-  - "apps"
-  resources:
-  - deployments
-  - services
-  - configmaps
-  verbs:
-  - '*'
 - apiGroups:
   - "apiextensions.k8s.io"
   resources:
@@ -104,14 +75,10 @@ rules:
 - apiGroups:
   - "sample.javaoperatorsdk"
   resources:
-  - webpages
-  - webpages/status
+  - metricshandlingcustomresource1s
+  - metricshandlingcustomresource1s/status
+  - metricshandlingcustomresource2s
+  - metricshandlingcustomresource2s/status
   verbs:
   - '*'
-- apiGroups:
-    - "networking.k8s.io"
-  resources:
-    - ingresses
-  verbs:
-    - '*'
 

sample-operators/metrics-processing/k8s/test-resource1-fail.yaml

@@ -0,0 +1,22 @@
+#
+# Copyright Java Operator SDK Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+apiVersion: sample.javaoperatorsdk/v1
+kind: MetricsHandlingCustomResource1
+metadata:
+  name: test-fail-1
+spec:
+  number: 100

sample-operators/metrics-processing/k8s/test-resource1-success.yaml

@@ -0,0 +1,22 @@
+#
+# Copyright Java Operator SDK Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+apiVersion: sample.javaoperatorsdk/v1
+kind: MetricsHandlingCustomResource1
+metadata:
+  name: test-success-1
+spec:
+  number: 42

sample-operators/metrics-processing/k8s/test-resource2-error.yaml

@@ -0,0 +1,22 @@
+#
+# Copyright Java Operator SDK Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+apiVersion: sample.javaoperatorsdk/v1
+kind: MetricsHandlingCustomResource2
+metadata:
+  name: test-error-2
+spec:
+  number: 200

sample-operators/metrics-processing/k8s/test-resource2-success.yaml

@@ -0,0 +1,22 @@
+#
+# Copyright Java Operator SDK Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+apiVersion: sample.javaoperatorsdk/v1
+kind: MetricsHandlingCustomResource2
+metadata:
+  name: test-success-2
+spec:
+  number: 77

sample-operators/metrics-processing/src/main/java/io/javaoperatorsdk/operator/sample/metrics/MetricsHandlingReconciler1.java

@@ -24,28 +24,55 @@
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
 import io.javaoperatorsdk.operator.sample.metrics.customresource.MetricsHandlingCustomResource1;
+import io.javaoperatorsdk.operator.sample.metrics.customresource.MetricsHandlingStatus;
 
 @ControllerConfiguration
 public class MetricsHandlingReconciler1 implements Reconciler<MetricsHandlingCustomResource1> {
 
-  public static final String INDEX_HTML = "index.html";
-
   private static final Logger log = LoggerFactory.getLogger(MetricsHandlingReconciler1.class);
 
   public MetricsHandlingReconciler1() {}
 
   @Override
   public List<EventSource<?, MetricsHandlingCustomResource1>> prepareEventSources(
       EventSourceContext<MetricsHandlingCustomResource1> context) {
-
     return List.of();
   }
 
   @Override
   public UpdateControl<MetricsHandlingCustomResource1> reconcile(
-      MetricsHandlingCustomResource1 metricsHandlingCustomResource1,
-      Context<MetricsHandlingCustomResource1> context) {
+      MetricsHandlingCustomResource1 resource, Context<MetricsHandlingCustomResource1> context) {
+
+    String name = resource.getMetadata().getName();
+    log.info("Reconciling resource: {}", name);
+
+    // Simulate some work
+    try {
+      Thread.sleep(100);
+    } catch (InterruptedException e) {
+      Thread.currentThread().interrupt();
+      throw new RuntimeException("Interrupted during reconciliation", e);
+    }
+
+    // Throw exception for resources with names containing "fail" or "error"
+    if (name.toLowerCase().contains("fail") || name.toLowerCase().contains("error")) {
+      log.error("Simulating failure for resource: {}", name);
+      throw new IllegalStateException("Simulated reconciliation failure for resource: " + name);
+    }
+
+    // Update status
+    var status = resource.getStatus();
+    if (status == null) {
+      status = new MetricsHandlingStatus();
+      resource.setStatus(status);
+    }
+
+    var spec = resource.getSpec();
+    if (spec != null) {
+      status.setObservedNumber(spec.getObservedNumber());
+    }
 
-    return UpdateControl.noUpdate();
+    log.info("Successfully reconciled resource: {}", name);
+    return UpdateControl.patchStatus(resource);
   }
 }

sample-operators/metrics-processing/src/main/java/io/javaoperatorsdk/operator/sample/metrics/MetricsHandlingReconciler2.java

@@ -15,40 +15,57 @@
  */
 package io.javaoperatorsdk.operator.sample.metrics;
 
-import java.util.List;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
-import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
 import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
 import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
-import io.javaoperatorsdk.operator.processing.event.source.EventSource;
-import io.javaoperatorsdk.operator.sample.metrics.customresource.MetricsHandlingCustomResource1;
+import io.javaoperatorsdk.operator.sample.metrics.customresource.MetricsHandlingCustomResource2;
+import io.javaoperatorsdk.operator.sample.metrics.customresource.MetricsHandlingStatus;
 
 @ControllerConfiguration
-public class MetricsHandlingReconciler2 implements Reconciler<MetricsHandlingCustomResource1> {
-
-  public static final String INDEX_HTML = "index.html";
+public class MetricsHandlingReconciler2 implements Reconciler<MetricsHandlingCustomResource2> {
 
   private static final Logger log = LoggerFactory.getLogger(MetricsHandlingReconciler2.class);
 
   public MetricsHandlingReconciler2() {}
 
   @Override
-  public List<EventSource<?, MetricsHandlingCustomResource1>> prepareEventSources(
-      EventSourceContext<MetricsHandlingCustomResource1> context) {
+  public UpdateControl<MetricsHandlingCustomResource2> reconcile(
+      MetricsHandlingCustomResource2 resource, Context<MetricsHandlingCustomResource2> context) {
 
-    return List.of();
-  }
+    String name = resource.getMetadata().getName();
+    log.info("Reconciling resource: {}", name);
 
-  @Override
-  public UpdateControl<MetricsHandlingCustomResource1> reconcile(
-      MetricsHandlingCustomResource1 metricsHandlingCustomResource1,
-      Context<MetricsHandlingCustomResource1> context) {
+    // Simulate some work (slightly different timing than reconciler1)
+    try {
+      Thread.sleep(150);
+    } catch (InterruptedException e) {
+      Thread.currentThread().interrupt();
+      throw new RuntimeException("Interrupted during reconciliation", e);
+    }
+
+    // Throw exception for resources with names containing "fail" or "error"
+    if (name.toLowerCase().contains("fail") || name.toLowerCase().contains("error")) {
+      log.error("Simulating failure for resource: {}", name);
+      throw new IllegalStateException("Simulated reconciliation failure for resource: " + name);
+    }
+
+    // Update status
+    var status = resource.getStatus();
+    if (status == null) {
+      status = new MetricsHandlingStatus();
+      resource.setStatus(status);
+    }
+
+    var spec = resource.getSpec();
+    if (spec != null) {
+      status.setObservedNumber(spec.getObservedNumber());
+    }
 
-    return UpdateControl.noUpdate();
+    log.info("Successfully reconciled resource: {}", name);
+    return UpdateControl.patchStatus(resource);
   }
 }

sample-operators/metrics-processing/src/main/java/io/javaoperatorsdk/operator/sample/metrics/MetricsHandlingSampleOperator.java

@@ -54,14 +54,16 @@ public class MetricsHandlingSampleOperator {
    * can be implemented using the low level and higher level APIs.
    */
   public static void main(String[] args) throws IOException {
-    log.info("WebServer Operator starting!");
+    log.info("Metrics Handling Sample Operator starting!");
 
-    // TODO add test for checking if there are metrics in prometheus
     // Load configuration from config.yaml
     Metrics metrics = initOTLPMetrics();
     Operator operator =
         new Operator(o -> o.withStopOnInformerErrorDuringStartup(false).withMetrics(metrics));
 
+    operator.register(new MetricsHandlingReconciler1());
+    operator.register(new MetricsHandlingReconciler2());
+
     operator.start();
   }