This is an automated email from the ASF dual-hosted git repository.
astefanutti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 98a080981df8bf953c258750a1012f47bc1d74f6
Author: Antonin Stefanutti <anto...@stefanutti.fr>
AuthorDate: Fri Oct 1 08:59:16 2021 +0200
chore(test): Account for platform reconcilation errors in metrics e2e tests
---
e2e/common/operator_metrics_test.go | 18 +++++++++++++++++-
1 file changed, 17 insertions(+), 1 deletion(-)
diff --git a/e2e/common/operator_metrics_test.go
b/e2e/common/operator_metrics_test.go
index e9a0c10..ad3aeb4 100644
--- a/e2e/common/operator_metrics_test.go
+++ b/e2e/common/operator_metrics_test.go
@@ -218,7 +218,23 @@ func TestMetrics(t *testing.T) {
platformRequeuedCount =
*platformRequeued.Histogram.SampleCount
}
- Expect(platformReconciliations).To(BeNumerically("==",
platformReconciledCount+platformRequeuedCount))
+ platformErrored :=
getMetric(metrics["camel_k_reconciliation_duration_seconds"],
+ MatchFieldsP(IgnoreExtras, Fields{
+ "Label": ConsistOf(
+ label("group",
v1.SchemeGroupVersion.Group),
+ label("version",
v1.SchemeGroupVersion.Version),
+ label("kind",
"IntegrationPlatform"),
+ label("namespace", ns),
+ label("result", "Errored"),
+ label("tag", "PlatformError"),
+ ),
+ }))
+ platformErroredCount := uint64(0)
+ if platformErrored != nil {
+ platformErroredCount =
*platformErrored.Histogram.SampleCount
+ }
+
+ Expect(platformReconciliations).To(BeNumerically("==",
platformReconciledCount+platformRequeuedCount+platformErroredCount))
// Count the number of Integration reconciliations
integrationReconciliations, err :=
counter.Count(MatchFields(IgnoreExtras, Fields{
