wip

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

Author: csviri

observability/install-observability.sh

@@ -28,14 +28,22 @@ echo -e "${GREEN}Installing Observability Stack${NC}"
 echo -e "${GREEN}OpenTelemetry + Prometheus + Grafana${NC}"
 echo -e "${GREEN}========================================${NC}"
 
-# Check if helm is installed
+# Check if helm is installed, download locally if not
 echo -e "\n${YELLOW}Checking helm installation...${NC}"
 if ! command -v helm &> /dev/null; then
-    echo -e "${RED}Error: helm is not installed${NC}"
-    echo "Please install helm: https://helm.sh/docs/intro/install/"
-    exit 1
+    echo -e "${YELLOW}helm not found, downloading locally...${NC}"
+    HELM_INSTALL_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)/.helm"
+    mkdir -p "$HELM_INSTALL_DIR"
+    HELM_BIN="$HELM_INSTALL_DIR/helm"
+    if [ ! -f "$HELM_BIN" ]; then
+        curl -fsSL https://raw.githubusercontent.com/helm/helm/main/scripts/get-helm-3 \
+            | HELM_INSTALL_DIR="$HELM_INSTALL_DIR" USE_SUDO=false bash
+    fi
+    export PATH="$HELM_INSTALL_DIR:$PATH"
+    echo -e "${GREEN}✓ helm downloaded to $HELM_BIN${NC}"
+else
+    echo -e "${GREEN}✓ helm is installed${NC}"
 fi
-echo -e "${GREEN}✓ helm is installed${NC}"
 
 # Add Helm repositories
 echo -e "\n${YELLOW}Adding Helm repositories...${NC}"

sample-operators/metrics-processing/src/test/java/io/javaoperatorsdk/operator/sample/metrics/MetricsHandlingE2E.java

@@ -112,27 +112,46 @@ private void closePortForward(LocalPortForward portForward, String name) {
     }
   }
 
+  // todo check historgram execution time
+  // failoures by controller
+  // delete event rate - delete resources in test
+  // error rate
   @Test
   void testPropagatedMetrics() throws Exception {
-    log.info("Starting metrics propagation test");
-
-    // Create successful resources
-    MetricsHandlingCustomResource1 successResource1 = createResource1("test-success-1", 42);
-    operator.create(successResource1);
-
-    MetricsHandlingCustomResource2 successResource2 = createResource2("test-success-2", 77);
-    operator.create(successResource2);
-
-    // Create resources that will fail
-    MetricsHandlingCustomResource1 failResource1 = createResource1("test-fail-1", 100);
-    operator.create(failResource1);
-
-    MetricsHandlingCustomResource2 errorResource2 = createResource2("test-error-2", 200);
-    operator.create(errorResource2);
+    log.info("Starting longevity metrics test (running for ~50 seconds)");
+
+    // Create initial resources including ones that trigger failures
+    operator.create(createResource1("test-success-1", 42));
+    operator.create(createResource2("test-success-2", 77));
+    operator.create(createResource1("test-fail-1", 100));
+    operator.create(createResource2("test-error-2", 200));
+
+    // Continuously trigger reconciliations for ~50 seconds by alternating between
+    // creating new resources and updating specs of existing ones
+    long deadline = System.currentTimeMillis() + Duration.ofSeconds(50).toMillis();
+    int counter = 0;
+    while (System.currentTimeMillis() < deadline) {
+      counter++;
+      switch (counter % 3) {
+        case 0 -> {
+          operator.create(createResource1("test-dynamic-1-" + counter, counter * 3));
+          log.info("Iteration {}: created test-dynamic-1-{}", counter, counter);
+        }
+        case 1 -> {
+          var r1 = operator.get(MetricsHandlingCustomResource1.class, "test-success-1");
+          r1.getSpec().setNumber(counter * 7);
+          operator.replace(r1);
+          log.info("Iteration {}: updated test-success-1 number to {}", counter, counter * 7);
+        }
+        case 2 -> {
+          operator.create(createResource2("test-dynamic-2-" + counter, counter * 5));
+          log.info("Iteration {}: created test-dynamic-2-{}", counter, counter);
+        }
+      }
+      Thread.sleep(1000);
+    }
 
-    // Wait for reconciliations to happen multiple times
-    log.info("Waiting for reconciliations to occur...");
-    Thread.sleep(10000);
+    log.info("Longevity phase completed ({} iterations), verifying metrics", counter);
     verifyPrometheusMetrics();
   }