Skip to content

Commit

Permalink
test: Add additional tests for logs/metrics/traces if pods are up and…
Browse files Browse the repository at this point in the history
… running (#1355)
  • Loading branch information
rakesh-garimella authored Aug 26, 2024
1 parent 65e5aa5 commit c1baeab
Show file tree
Hide file tree
Showing 40 changed files with 178 additions and 21 deletions.
5 changes: 5 additions & 0 deletions test/e2e/logs_basic_v1alpha1_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
"github.com/kyma-project/telemetry-manager/test/testkit/suite"
Expand Down Expand Up @@ -73,6 +74,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have unsupportedMode set to false", func() {
assert.LogPipelineUnsupportedMode(ctx, k8sClient, pipelineName, false)
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_basic_v1beta1_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import (
telemetryv1beta1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1beta1"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
"github.com/kyma-project/telemetry-manager/test/testkit/suite"
Expand Down Expand Up @@ -81,6 +82,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs, suite.LabelExperimental), Or
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have unsupportedMode set to false", func() {
assert.LogPipelineUnsupportedMode(ctx, k8sClient, pipelineName, false)
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_custom_output_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
"github.com/kyma-project/telemetry-manager/test/testkit/suite"
Expand Down Expand Up @@ -72,6 +73,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineUnsupportedMode(ctx, k8sClient, pipelineName, true)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend.DefaultName})
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_dedot_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
. "github.com/kyma-project/telemetry-manager/test/testkit/matchers/log"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
Expand Down Expand Up @@ -66,6 +67,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend.DefaultName})
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_drop_labels_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
. "github.com/kyma-project/telemetry-manager/test/testkit/matchers/log"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
Expand Down Expand Up @@ -69,6 +70,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend.DefaultName})
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_exclude_container_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
. "github.com/kyma-project/telemetry-manager/test/testkit/matchers/log"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
Expand Down Expand Up @@ -67,6 +68,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend.DefaultName})
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_keep_annotation_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
. "github.com/kyma-project/telemetry-manager/test/testkit/matchers/log"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
Expand Down Expand Up @@ -67,6 +68,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend.DefaultName})
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_keep_original_body_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
. "github.com/kyma-project/telemetry-manager/test/testkit/matchers/log"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
Expand Down Expand Up @@ -86,6 +87,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipeline2Name)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have log backends running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend1Name})
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend2Name})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_mtls_about_to_expire_cert_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
"github.com/kyma-project/telemetry-manager/test/testkit/suite"
Expand Down Expand Up @@ -72,6 +73,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a tlsCertAboutToExpire Condition set in pipeline conditions", func() {
assert.LogPipelineHasCondition(ctx, k8sClient, pipelineName, metav1.Condition{
Type: conditions.TypeConfigurationGenerated,
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_mtls_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
"github.com/kyma-project/telemetry-manager/test/testkit/suite"
Expand Down Expand Up @@ -72,6 +73,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend.DefaultName})
})
Expand Down
4 changes: 4 additions & 0 deletions test/e2e/logs_multi_pipeline_broken_pipeline_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, brokenPipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backend.DefaultName, Namespace: mockNs})
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_multi_pipeline_namespace_filter_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
. "github.com/kyma-project/telemetry-manager/test/testkit/matchers/log"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
Expand Down Expand Up @@ -84,6 +85,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipelineExcludeNamespaceName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mock1Ns, Name: backendIncludeNamespaceName})
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mock2Ns, Name: backendExcludeNamespaceName})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_multi_pipeline_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
"github.com/kyma-project/telemetry-manager/test/testkit/suite"
Expand Down Expand Up @@ -71,6 +72,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
assert.LogPipelineHealthy(ctx, k8sClient, pipeline2Name)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backend1Name, Namespace: mockNs})
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backend2Name, Namespace: mockNs})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/logs_parser_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
. "github.com/kyma-project/telemetry-manager/test/testkit/matchers/log"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/loggen"
Expand Down Expand Up @@ -75,6 +76,10 @@ Types user:string pass:string`
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a log backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Namespace: mockNs, Name: backend.DefaultName})
})
Expand Down
6 changes: 3 additions & 3 deletions test/e2e/logs_resources_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {

It("Should have a DaemonSet owned by the LogPipeline", func() {
var daemonSet appsv1.DaemonSet
assert.HasOwnerReference(ctx, k8sClient, &daemonSet, kitkyma.FluentBitDaemonSet, ownerReferenceKind, pipelineName)
assert.HasOwnerReference(ctx, k8sClient, &daemonSet, kitkyma.FluentBitDaemonSetName, ownerReferenceKind, pipelineName)
})

It("Should have a Network Policy owned by the LogPipeline", func() {
Expand All @@ -94,7 +94,7 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {
It("Should have a DaemonSet with correct pod priority class", func() {
Eventually(func(g Gomega) {
var daemonSet appsv1.DaemonSet
g.Expect(k8sClient.Get(ctx, kitkyma.FluentBitDaemonSet, &daemonSet)).To(Succeed())
g.Expect(k8sClient.Get(ctx, kitkyma.FluentBitDaemonSetName, &daemonSet)).To(Succeed())

g.Expect(daemonSet.Spec.Template.Spec.PriorityClassName).To(Equal("telemetry-priority-class-high"))
}, periodic.EventuallyTimeout, periodic.DefaultInterval).Should(Succeed())
Expand Down Expand Up @@ -172,7 +172,7 @@ var _ = Describe(suite.ID(), Label(suite.LabelLogs), Ordered, func() {

Eventually(func(g Gomega) bool {
var daemonSet appsv1.DaemonSet
err := k8sClient.Get(ctx, kitkyma.FluentBitDaemonSet, &daemonSet)
err := k8sClient.Get(ctx, kitkyma.FluentBitDaemonSetName, &daemonSet)
return apierrors.IsNotFound(err)
}, periodic.EventuallyTimeout, periodic.DefaultInterval).Should(BeTrue(), "DaemonSet still exists")

Expand Down
4 changes: 4 additions & 0 deletions test/e2e/logs_self_monitor_healthy_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelSelfMonitoringLogsHealthy), Ordere
assert.LogPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running log agent", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.FluentBitDaemonSetName)
})

It("Should have a running self-monitor", func() {
assert.DeploymentReady(ctx, k8sClient, kitkyma.SelfMonitorName)
})
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/metrics_mtls_about_to_expire_cert_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/telemetrygen"
"github.com/kyma-project/telemetry-manager/test/testkit/suite"
Expand Down Expand Up @@ -73,6 +74,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelMetrics), Ordered, func() {
assert.MetricPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running metrics gateway", func() {
assert.DeploymentReady(ctx, k8sClient, kitkyma.MetricGatewayName)
})

It("Should have a tlsCertAboutToExpire Condition set in pipeline conditions", func() {
assert.MetricPipelineHasCondition(ctx, k8sClient, pipelineName, metav1.Condition{
Type: conditions.TypeConfigurationGenerated,
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/metrics_mtls_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@ import (
"github.com/kyma-project/telemetry-manager/internal/testutils"
"github.com/kyma-project/telemetry-manager/test/testkit/assert"
kitk8s "github.com/kyma-project/telemetry-manager/test/testkit/k8s"
kitkyma "github.com/kyma-project/telemetry-manager/test/testkit/kyma"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/backend"
"github.com/kyma-project/telemetry-manager/test/testkit/mocks/telemetrygen"
"github.com/kyma-project/telemetry-manager/test/testkit/suite"
Expand Down Expand Up @@ -68,6 +69,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelMetrics), Ordered, func() {
assert.MetricPipelineHealthy(ctx, k8sClient, pipelineName)
})

It("Should have running metric gateway", func() {
assert.DeploymentReady(ctx, k8sClient, kitkyma.MetricGatewayName)
})

It("Should have a metric backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backend.DefaultName, Namespace: mockNs})
})
Expand Down
8 changes: 4 additions & 4 deletions test/e2e/metrics_multi_pipeline_namespace_selector_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -90,15 +90,15 @@ var _ = Describe(suite.ID(), Label(suite.LabelMetrics), Ordered, func() {
assert.DeploymentReady(ctx, k8sClient, kitkyma.MetricGatewayName)
})

It("Should have a running metric agent daemonset", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.MetricAgentName)
})

It("Should have a metrics backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backend1Name, Namespace: mockNs})
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backend2Name, Namespace: mockNs})
})

It("Should have a running metric agent daemonset", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.MetricAgentName)
})

// verify metrics from apps1Ns delivered to backend1
It("Should deliver Runtime metrics from app1Ns to backend1", func() {
assert.MetricsFromNamespaceDelivered(proxyClient, backend1ExportURL, app1Ns, kubeletstats.DefaultMetricsNames)
Expand Down
4 changes: 4 additions & 0 deletions test/e2e/metrics_multi_pipeline_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,10 @@ var _ = Describe(suite.ID(), Label(suite.LabelMetrics), Ordered, func() {
assert.DeploymentReady(ctx, k8sClient, kitkyma.MetricGatewayName)
})

It("Should have a running metric agent daemonset", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.MetricAgentName)
})

It("Should have a metrics backend running", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backendRuntimeName, Namespace: mockNs})
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backendPrometheusName, Namespace: mockNs})
Expand Down
8 changes: 4 additions & 4 deletions test/e2e/metrics_prometheus_input_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,14 +67,14 @@ var _ = Describe(suite.ID(), Label(suite.LabelMetrics), Ordered, func() {
assert.DeploymentReady(ctx, k8sClient, kitkyma.MetricGatewayName)
})

It("Ensures the metrics backend is ready", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backend.DefaultName, Namespace: mockNs})
})

It("Ensures the metric agent daemonset is ready", func() {
assert.DaemonSetReady(ctx, k8sClient, kitkyma.MetricAgentName)
})

It("Ensures the metrics backend is ready", func() {
assert.DeploymentReady(ctx, k8sClient, types.NamespacedName{Name: backend.DefaultName, Namespace: mockNs})
})

It("Ensures the metricpipeline is running", func() {
assert.MetricPipelineHealthy(ctx, k8sClient, pipelineName)
})
Expand Down
Loading

0 comments on commit c1baeab

Please sign in to comment.