hanzoai/otel-collector
2
0
Fork 0
mirror of https://github.com/hanzoai/otel-collector.git synced 2026-10-30 18:26:25 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
main
otel-collector/components/components.go
T
zeekayandHanzo Dev 1cb42b507b chore(components): drop redisreceiver — the last go-redis dependency 
redisreceiver scrapes EXTERNAL Redis servers. We do not do that: this
distro exists for OUR telemetry only, and no config we ship or run
enables it.

Proof it is dead:
  - Live cluster (do-sfo3-hanzo-k8s, ns hanzo), all four otel ConfigMaps:
      otel-collector-config  receivers [zap, otlp]
      otel-agent-config      receivers [filelog]
      otel-logs-agent-config receivers [filelog]
      alertmanager-config    not a collector config
  - universe infra/k8s o11y/ + monitoring/: zero "redis" matches.
  - The staged langfuse fan-out overlay needs only basicauthextension,
    filterprocessor and otlphttpexporter — all retained.
  - In-repo, redisreceiver appeared only in go.mod, go.sum and the
    components.go import + factory registration. No test, no config,
    no doc referenced it.

Dependency that falls out:
  github.com/redis/go-redis/v9 v9.17.2 — `go mod why` showed it entered
  solely via components -> redisreceiver. It is now absent from the
  module graph entirely (`go list -m all` = 0 hits), so this repo no
  longer carries a foreign Redis client. Our KV client is
  github.com/hanzokv/go, which is what exporter/metadataexporter/cache
  already uses.

Remaining go.sum "redis" lines are cloud.google.com/go/redis, an
unrelated GCP API client pulled by the googlecloud receivers.

Verified: `CGO_ENABLED=0 GOWORK=off GOFLAGS=-mod=mod go build ./...`
exit 0 before and after; `go test ./components/... ./o11ycol/...` ok;
cmd/o11yotelcollector links clean.

Co-authored-by: Hanzo Dev <[email protected]>
2026-07-26 10:33:38 -07:00

535 lines
27 KiB
Go
Raw Permalink Blame History

package components
import (
"github.com/hanzoai/otel-collector/connectors/o11ymeterconnector"
"github.com/hanzoai/otel-collector/exporter/datastorelogsexporter"
"github.com/hanzoai/otel-collector/exporter/datastoretracesexporter"
"github.com/hanzoai/otel-collector/exporter/jsontypeexporter"
"github.com/hanzoai/otel-collector/exporter/metadataexporter"
"github.com/hanzoai/otel-collector/exporter/o11ydatastoremeter"
"github.com/hanzoai/otel-collector/exporter/o11ydatastoremetrics"
"github.com/hanzoai/otel-collector/exporter/o11ykafkaexporter"
"github.com/hanzoai/otel-collector/exporter/zapexporter"
o11yhealthcheckextension "github.com/hanzoai/otel-collector/extension/healthcheckextension"
_ "github.com/hanzoai/otel-collector/pkg/parser/grok"
"github.com/hanzoai/otel-collector/processor/o11ylogspipelineprocessor"
"github.com/hanzoai/otel-collector/processor/o11yspanmetricsprocessor"
"github.com/hanzoai/otel-collector/processor/o11ytailsampler"
"github.com/hanzoai/otel-collector/processor/o11ytransformprocessor"
"github.com/hanzoai/otel-collector/receiver/datastoresystemtablesreceiver"
"github.com/hanzoai/otel-collector/receiver/httplogreceiver"
"github.com/hanzoai/otel-collector/receiver/o11yawsfirehosereceiver"
"github.com/hanzoai/otel-collector/receiver/o11ykafkareceiver"
"github.com/hanzoai/otel-collector/receiver/zapreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/countconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/datadogconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/exceptionsconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/failoverconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/grafanacloudconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/metricsaslogsconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/otlpjsonconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/roundrobinconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/routingconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/servicegraphconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/signaltometricsconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/slowsqlconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/spanmetricsconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/connector/sumconnector"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/alertmanagerexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/awskinesisexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/awss3exporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/cassandraexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/fileexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/googlecloudpubsubexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/kafkaexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/loadbalancingexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/prometheusexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/prometheusremotewriteexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/pulsarexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/rabbitmqexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/syslogexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/zipkinexporter"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/azureauthextension"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/basicauthextension"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/bearertokenauthextension"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/healthcheckextension"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/jaegerremotesampling"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/oauth2clientauthextension"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/observer/dockerobserver"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/observer/ecsobserver"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/observer/ecstaskobserver"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/observer/hostobserver"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/observer/k8sobserver"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/oidcauthextension"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/pprofextension"
"github.com/open-telemetry/opentelemetry-collector-contrib/extension/storage/filestorage"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/attributesprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/coralogixprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/cumulativetodeltaprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/datadogsemanticsprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/deltatocumulativeprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/deltatorateprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/dnslookupprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/filterprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/geoipprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/groupbyattrsprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/groupbytraceprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/intervalprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/isolationforestprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/k8sattributesprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/logdedupprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/logstransformprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/metricsgenerationprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/metricstarttimeprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/metricstransformprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/probabilisticsamplerprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/redactionprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/remotetapprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/resourcedetectionprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/resourceprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/schemaprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/spanprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/sumologicprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/tailsamplingprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/transformprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/unrollprocessor"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/activedirectorydsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/aerospikereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/apachereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/apachesparkreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/awscloudwatchmetricsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/awscloudwatchreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/awscontainerinsightreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/awsecscontainermetricsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/awsfirehosereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/awss3receiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/awsxrayreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/azureblobreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/azureeventhubreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/azuremonitorreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/bigipreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/carbonreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/chronyreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/ciscoosreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/cloudflarereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/cloudfoundryreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/collectdreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/couchdbreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/datadogreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/dockerstatsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/elasticsearchreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/envoyalsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/expvarreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/faroreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/filelogreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/filestatsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/flinkmetricsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/fluentforwardreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/githubreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/gitlabreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudmonitoringreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudpubsubpushreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudpubsubreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/googlecloudspannerreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/haproxyreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/hostmetricsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/httpcheckreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/huaweicloudcesreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/icmpcheckreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/iisreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/influxdbreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/jaegerreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/jmxreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/journaldreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sclusterreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8seventsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8slogreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/k8sobjectsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkametricsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kafkareceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/libhoneyreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/lokireceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/macosunifiedloggingreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/memcachedreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/mongodbatlasreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/mongodbreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/mysqlreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/namedpipereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/netflowreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/nginxreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/nsxtreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/ntpreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/oracledbreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/osqueryreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/otelarrowreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/otlpjsonfilereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/podmanreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/postgresqlreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/pprofreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/prometheusreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/prometheusremotewritereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/pulsarreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/purefareceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/purefbreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/rabbitmqreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/receivercreator"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/redfishreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/riakreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/saphanareceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/signalfxreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/simpleprometheusreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/skywalkingreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/snmpreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/snowflakereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/solacereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/splunkenterprisereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/splunkhecreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/sqlqueryreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/sqlserverreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/sshcheckreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/statsdreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/stefreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/syslogreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/systemdreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/tcpcheckreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/tcplogreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/tlscheckreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/udplogreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/vcenterreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/wavefrontreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/webhookeventreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/windowseventlogreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/windowsperfcountersreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/windowsservicereceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/yanggrpcreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/zipkinreceiver"
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/zookeeperreceiver"
"go.opentelemetry.io/collector/connector"
"go.opentelemetry.io/collector/connector/forwardconnector"
"go.opentelemetry.io/collector/exporter"
"go.opentelemetry.io/collector/exporter/debugexporter"
"go.opentelemetry.io/collector/exporter/nopexporter"
"go.opentelemetry.io/collector/exporter/otlpexporter"
"go.opentelemetry.io/collector/exporter/otlphttpexporter"
"go.opentelemetry.io/collector/extension"
"go.opentelemetry.io/collector/extension/zpagesextension"
"go.opentelemetry.io/collector/otelcol"
"go.opentelemetry.io/collector/processor"
"go.opentelemetry.io/collector/processor/batchprocessor"
"go.opentelemetry.io/collector/processor/memorylimiterprocessor"
"go.opentelemetry.io/collector/receiver"
"go.opentelemetry.io/collector/receiver/nopreceiver"
"go.opentelemetry.io/collector/receiver/otlpreceiver"
"go.opentelemetry.io/collector/service/telemetry/otelconftelemetry"
"go.uber.org/multierr"
)
func Components() (otelcol.Factories, error) {
extensions := []extension.Factory{}
receivers := []receiver.Factory{
activedirectorydsreceiver.NewFactory(),
aerospikereceiver.NewFactory(),
apachereceiver.NewFactory(),
apachesparkreceiver.NewFactory(),
awscloudwatchmetricsreceiver.NewFactory(),
awscloudwatchreceiver.NewFactory(),
awscontainerinsightreceiver.NewFactory(),
awsecscontainermetricsreceiver.NewFactory(),
awsfirehosereceiver.NewFactory(),
awss3receiver.NewFactory(),
awsxrayreceiver.NewFactory(),
azureblobreceiver.NewFactory(),
azureeventhubreceiver.NewFactory(),
azuremonitorreceiver.NewFactory(),
bigipreceiver.NewFactory(),
carbonreceiver.NewFactory(),
chronyreceiver.NewFactory(),
datastoresystemtablesreceiver.NewFactory(),
cloudflarereceiver.NewFactory(),
cloudfoundryreceiver.NewFactory(),
collectdreceiver.NewFactory(),
couchdbreceiver.NewFactory(),
datadogreceiver.NewFactory(),
dockerstatsreceiver.NewFactory(),
elasticsearchreceiver.NewFactory(),
expvarreceiver.NewFactory(),
filelogreceiver.NewFactory(),
filestatsreceiver.NewFactory(),
flinkmetricsreceiver.NewFactory(),
fluentforwardreceiver.NewFactory(),
githubreceiver.NewFactory(),
googlecloudmonitoringreceiver.NewFactory(),
googlecloudpubsubreceiver.NewFactory(),
googlecloudspannerreceiver.NewFactory(),
haproxyreceiver.NewFactory(),
hostmetricsreceiver.NewFactory(),
httpcheckreceiver.NewFactory(),
httplogreceiver.NewFactory(),
iisreceiver.NewFactory(),
influxdbreceiver.NewFactory(),
jaegerreceiver.NewFactory(),
jmxreceiver.NewFactory(),
journaldreceiver.NewFactory(),
k8sclusterreceiver.NewFactory(),
k8seventsreceiver.NewFactory(),
k8sobjectsreceiver.NewFactory(),
kafkametricsreceiver.NewFactory(),
kafkareceiver.NewFactory(),
kubeletstatsreceiver.NewFactory(),
lokireceiver.NewFactory(),
memcachedreceiver.NewFactory(),
mongodbatlasreceiver.NewFactory(),
mongodbreceiver.NewFactory(),
mysqlreceiver.NewFactory(),
namedpipereceiver.NewFactory(),
nginxreceiver.NewFactory(),
nsxtreceiver.NewFactory(),
oracledbreceiver.NewFactory(),
osqueryreceiver.NewFactory(),
otelarrowreceiver.NewFactory(),
otlpjsonfilereceiver.NewFactory(),
podmanreceiver.NewFactory(),
postgresqlreceiver.NewFactory(),
prometheusreceiver.NewFactory(),
prometheusremotewritereceiver.NewFactory(),
pulsarreceiver.NewFactory(),
purefareceiver.NewFactory(),
purefbreceiver.NewFactory(),
rabbitmqreceiver.NewFactory(),
receivercreator.NewFactory(),
riakreceiver.NewFactory(),
saphanareceiver.NewFactory(),
signalfxreceiver.NewFactory(),
simpleprometheusreceiver.NewFactory(),
skywalkingreceiver.NewFactory(),
snmpreceiver.NewFactory(),
snowflakereceiver.NewFactory(),
solacereceiver.NewFactory(),
splunkenterprisereceiver.NewFactory(),
splunkhecreceiver.NewFactory(),
sqlqueryreceiver.NewFactory(),
sqlserverreceiver.NewFactory(),
sshcheckreceiver.NewFactory(),
statsdreceiver.NewFactory(),
syslogreceiver.NewFactory(),
tcplogreceiver.NewFactory(),
udplogreceiver.NewFactory(),
vcenterreceiver.NewFactory(),
wavefrontreceiver.NewFactory(),
webhookeventreceiver.NewFactory(),
windowseventlogreceiver.NewFactory(),
windowsperfcountersreceiver.NewFactory(),
zipkinreceiver.NewFactory(),
zookeeperreceiver.NewFactory(),
ciscoosreceiver.NewFactory(),
envoyalsreceiver.NewFactory(),
faroreceiver.NewFactory(),
gitlabreceiver.NewFactory(),
googlecloudpubsubpushreceiver.NewFactory(),
huaweicloudcesreceiver.NewFactory(),
icmpcheckreceiver.NewFactory(),
k8slogreceiver.NewFactory(),
libhoneyreceiver.NewFactory(),
macosunifiedloggingreceiver.NewFactory(),
netflowreceiver.NewFactory(),
ntpreceiver.NewFactory(),
pprofreceiver.NewFactory(),
redfishreceiver.NewFactory(),
stefreceiver.NewFactory(),
systemdreceiver.NewFactory(),
tcpcheckreceiver.NewFactory(),
tlscheckreceiver.NewFactory(),
windowsservicereceiver.NewFactory(),
yanggrpcreceiver.NewFactory(),
o11ykafkareceiver.NewFactory(),
o11yawsfirehosereceiver.NewFactory(),
}
exporters := []exporter.Factory{
alertmanagerexporter.NewFactory(),
awskinesisexporter.NewFactory(),
awss3exporter.NewFactory(),
cassandraexporter.NewFactory(),
datastorelogsexporter.NewFactory(),
o11ydatastoremetrics.NewFactory(),
datastoretracesexporter.NewFactory(),
// ZAP-native OTLP exporter — forwards signals to another collector's
// ZAP receiver over the ZAP wire (used by the filelog log-agent).
zapexporter.NewFactory(),
debugexporter.NewFactory(),
fileexporter.NewFactory(),
googlecloudpubsubexporter.NewFactory(),
jsontypeexporter.NewFactory(),
kafkaexporter.NewFactory(),
loadbalancingexporter.NewFactory(),
metadataexporter.NewFactory(),
prometheusexporter.NewFactory(),
prometheusremotewriteexporter.NewFactory(),
pulsarexporter.NewFactory(),
rabbitmqexporter.NewFactory(),
o11ykafkaexporter.NewFactory(),
syslogexporter.NewFactory(),
zipkinexporter.NewFactory(),
nopexporter.NewFactory(),
o11ydatastoremeter.NewFactory(),
}
processors := []processor.Factory{
attributesprocessor.NewFactory(),
cumulativetodeltaprocessor.NewFactory(),
coralogixprocessor.NewFactory(),
datadogsemanticsprocessor.NewFactory(),
deltatorateprocessor.NewFactory(),
deltatocumulativeprocessor.NewFactory(),
dnslookupprocessor.NewFactory(),
filterprocessor.NewFactory(),
geoipprocessor.NewFactory(),
groupbyattrsprocessor.NewFactory(),
groupbytraceprocessor.NewFactory(),
intervalprocessor.NewFactory(),
isolationforestprocessor.NewFactory(),
k8sattributesprocessor.NewFactory(),
logdedupprocessor.NewFactory(),
logstransformprocessor.NewFactory(),
metricsgenerationprocessor.NewFactory(),
metricstransformprocessor.NewFactory(),
metricstarttimeprocessor.NewFactory(),
probabilisticsamplerprocessor.NewFactory(),
redactionprocessor.NewFactory(),
remotetapprocessor.NewFactory(),
resourcedetectionprocessor.NewFactory(),
resourceprocessor.NewFactory(),
schemaprocessor.NewFactory(),
sumologicprocessor.NewFactory(),
o11yspanmetricsprocessor.NewFactory(),
spanprocessor.NewFactory(),
tailsamplingprocessor.NewFactory(),
transformprocessor.NewFactory(),
unrollprocessor.NewFactory(),
o11ytailsampler.NewFactory(),
o11ytransformprocessor.NewFactory(),
o11ylogspipelineprocessor.NewFactory(),
}
connectors := []connector.Factory{
failoverconnector.NewFactory(),
countconnector.NewFactory(),
exceptionsconnector.NewFactory(),
forwardconnector.NewFactory(),
datadogconnector.NewFactory(),
grafanacloudconnector.NewFactory(),
metricsaslogsconnector.NewFactory(),
otlpjsonconnector.NewFactory(),
roundrobinconnector.NewFactory(),
routingconnector.NewFactory(),
servicegraphconnector.NewFactory(),
signaltometricsconnector.NewFactory(),
slowsqlconnector.NewFactory(),
spanmetricsconnector.NewFactory(),
sumconnector.NewFactory(),
o11ymeterconnector.NewFactory(),
}
factories, err := CoreComponents(
extensions,
receivers,
processors,
exporters,
connectors,
)
if err != nil {
return otelcol.Factories{}, err
}
return factories, err
}
func CoreComponents(
extensions []extension.Factory,
receivers []receiver.Factory,
processors []processor.Factory,
exporters []exporter.Factory,
connectors []connector.Factory,
) (
otelcol.Factories,
error,
) {
var errs []error
extensions = append(
extensions,
basicauthextension.NewFactory(),
bearertokenauthextension.NewFactory(),
dockerobserver.NewFactory(),
ecsobserver.NewFactory(),
ecstaskobserver.NewFactory(),
filestorage.NewFactory(),
hostobserver.NewFactory(),
jaegerremotesampling.NewFactory(),
k8sobserver.NewFactory(),
oauth2clientauthextension.NewFactory(),
oidcauthextension.NewFactory(),
healthcheckextension.NewFactory(),
pprofextension.NewFactory(),
o11yhealthcheckextension.NewFactory(),
zpagesextension.NewFactory(),
azureauthextension.NewFactory(),
)
extensionsMap, err := otelcol.MakeFactoryMap(extensions...)
if err != nil {
errs = append(errs, err)
}
receivers = append(
receivers,
otlpreceiver.NewFactory(),
nopreceiver.NewFactory(),
// ZAP-native OTLP receiver — Hanzo services ship telemetry over the
// ZAP wire (zap-proto/http); OTLP above stays as an interop endpoint.
zapreceiver.NewFactory(),
)
receiversMap, err := otelcol.MakeFactoryMap(receivers...)
if err != nil {
errs = append(errs, err)
}
exporters = append(
exporters,
otlpexporter.NewFactory(),
otlphttpexporter.NewFactory(),
)
exportersMap, err := otelcol.MakeFactoryMap(exporters...)
if err != nil {
errs = append(errs, err)
}
processors = append(
processors,
batchprocessor.NewFactory(),
memorylimiterprocessor.NewFactory(),
)
processorsMap, err := otelcol.MakeFactoryMap(processors...)
if err != nil {
errs = append(errs, err)
}
connectorsMap, err := otelcol.MakeFactoryMap(connectors...)
if err != nil {
errs = append(errs, err)
}
factories := otelcol.Factories{
Extensions: extensionsMap,
Receivers: receiversMap,
Processors: processorsMap,
Exporters: exportersMap,
Connectors: connectorsMap,
Telemetry: otelconftelemetry.NewFactory(),
}
return factories, multierr.Combine(errs...)
}
Reference in New Issue View Git Blame Copy Permalink