components_test.go

// Copyright Splunk, Inc.
// Copyright The OpenTelemetry 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.

package components

import (
	"fmt"
	"testing"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
	"go.opentelemetry.io/collector/component"
)

func TestDefaultComponents(t *testing.T) {
	expectedExtensions := []string{
		"ack",
		"basicauth",
		"docker_observer",
		"ecs_observer",
		"ecs_task_observer",
		"file_storage",
		"headers_setter",
		"health_check",
		"host_observer",
		"http_forwarder",
		"k8s_observer",
		"memory_ballast",
		"oauth2client",
		"pprof",
		"smartagent",
		"zpages",
	}
	expectedReceivers := []string{
		"active_directory_ds",
		"apache",
		"apachespark",
		"awscontainerinsightreceiver",
		"awsecscontainermetrics",
		"azureblob",
		"azureeventhub",
		"azuremonitor",
		"carbon",
		"cloudfoundry",
		"collectd",
		"discovery",
		"elasticsearch",
		"filelog",
		"fluentforward",
		"googlecloudpubsub",
		"haproxy",
		"hostmetrics",
		"httpcheck",
		"jaeger",
		"jmx",
		"journald",
		"k8s_cluster",
		"k8s_events",
		"k8sobjects",
		"kafka",
		"kafkametrics",
		"kubeletstats",
		"lightprometheus",
		"mongodb",
		"mongodbatlas",
		"mysql",
		"nginx",
		"nop",
		"oracledb",
		"otlp",
		"postgresql",
		"prometheus",
		"prometheus_simple",
		"rabbitmq",
		"receiver_creator",
		"redis",
		"sapm",
		"scripted_inputs",
		"signalfx",
		"signalfxgatewayprometheusremotewrite",
		"smartagent",
		"solace",
		"splunkenterprise",
		"splunk_hec",
		"sqlquery",
		"sqlserver",
		"sshcheck",
		"statsd",
		"syslog",
		"tcplog",
		"udplog",
		"vcenter",
		"wavefront",
		"windowseventlog",
		"windowsperfcounters",
		"zipkin",
	}
	expectedProcessors := []string{
		"attributes",
		"batch",
		"cumulativetodelta",
		"filter",
		"groupbyattrs",
		"k8sattributes",
		"logstransform",
		"memory_limiter",
		"metricstransform",
		"probabilistic_sampler",
		"redaction",
		"resource",
		"resourcedetection",
		"routing",
		"span",
		"tail_sampling",
		"timestamp",
		"transform",
	}
	expectedExporters := []string{
		"awss3",
		"debug",
		"file",
		"httpsink",
		"kafka",
		"loadbalancing",
		"logging",
		"nop",
		"otlp",
		"otlphttp",
		"pulsar",
		"sapm",
		"signalfx",
		"splunk_hec",
	}
	expectedConnectors := []string{
		"count",
		"forward",
		"routing",
		"spanmetrics",
	}

	factories, err := Get()
	assert.NoError(t, err)

	exts := factories.Extensions
	assert.Len(t, exts, len(expectedExtensions))
	for _, k := range expectedExtensions {
		v, ok := exts[component.MustNewType(k)]
		assert.True(t, ok)
		assert.Equal(t, k, v.Type().String())
	}

	recvs := factories.Receivers
	assert.Len(t, recvs, len(expectedReceivers))
	for _, k := range expectedReceivers {
		v, ok := recvs[component.MustNewType(k)]
		require.True(t, ok, k)
		assert.Equal(t, k, v.Type().String())
	}

	procs := factories.Processors
	assert.Len(t, procs, len(expectedProcessors))
	for _, k := range expectedProcessors {
		v, ok := procs[component.MustNewType(k)]
		require.True(t, ok, fmt.Sprintf("Missing expected processor %s", k))
		assert.Equal(t, k, v.Type().String())
	}

	exps := factories.Exporters
	assert.Len(t, exps, len(expectedExporters))
	for _, k := range expectedExporters {
		v, ok := exps[component.MustNewType(k)]
		require.True(t, ok)
		assert.Equal(t, k, v.Type().String())
	}

	conns := factories.Connectors
	assert.Len(t, conns, len(expectedConnectors))
	for _, k := range expectedConnectors {
		v, ok := conns[component.MustNewType(k)]
		require.True(t, ok, fmt.Sprintf("Missing expected connector %s", k))
		assert.Equal(t, k, v.Type().String())
	}
}