forked from open-telemetry/opentelemetry-collector-contrib
-
Notifications
You must be signed in to change notification settings - Fork 0
/
integration_test.go
57 lines (50 loc) · 2.15 KB
/
integration_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
//go:build integration
// +build integration
package apachesparkreceiver // import "github.com/open-telemetry/opentelemetry-collector-contrib/receiver/apachesparkreceiver"
import (
"fmt"
"path/filepath"
"testing"
"time"
"github.com/testcontainers/testcontainers-go"
"github.com/testcontainers/testcontainers-go/wait"
"go.opentelemetry.io/collector/component"
"github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal/scraperinttest"
"github.com/open-telemetry/opentelemetry-collector-contrib/pkg/pdatatest/pmetrictest"
)
const sparkPort = "4040"
func TestIntegration(t *testing.T) {
t.Skip("The test is failing. See https://github.com/open-telemetry/opentelemetry-collector-contrib/issues/23670")
scraperinttest.NewIntegrationTest(
NewFactory(),
scraperinttest.WithContainerRequest(
testcontainers.ContainerRequest{
FromDockerfile: testcontainers.FromDockerfile{
Context: filepath.Join("testdata", "integration"),
Dockerfile: "Dockerfile.apache-spark",
},
ExposedPorts: []string{sparkPort},
WaitingFor: wait.ForListeningPort(sparkPort).WithStartupTimeout(2 * time.Minute),
}),
scraperinttest.WithCustomConfig(
func(t *testing.T, cfg component.Config, ci *scraperinttest.ContainerInfo) {
rCfg := cfg.(*Config)
rCfg.ScraperControllerSettings.CollectionInterval = 3 * time.Second
rCfg.Endpoint = fmt.Sprintf("http:https://%s:%s", ci.Host(t), ci.MappedPort(t, sparkPort))
}),
scraperinttest.WithCompareOptions(
pmetrictest.IgnoreMetricValues(),
pmetrictest.IgnoreStartTimestamp(),
pmetrictest.IgnoreTimestamp(),
pmetrictest.IgnoreResourceAttributeValue("spark.application.id"),
pmetrictest.IgnoreResourceAttributeValue("spark.application.name"),
pmetrictest.IgnoreMetricAttributeValue("active", "spark.stage.status"),
pmetrictest.IgnoreMetricAttributeValue("complete", "spark.stage.status"),
pmetrictest.IgnoreMetricAttributeValue("failed", "spark.stage.status"),
pmetrictest.IgnoreMetricAttributeValue("pending", "spark.stage.status"),
pmetrictest.IgnoreMetricDataPointsOrder(),
),
).Run(t)
}