mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-10-30 18:26:25 +00:00
- imports: ClickHouse/ch-go, clickhouse-go/v2, srikanthccv/ClickHouse-go-mock
-> github.com/hanzo-ds/{native,go,mock} (require, clean semver, NO replace)
- identifiers/aliases/type-names/config-keys/type-IDs: clickhouse -> datastore
(receiver dir clickhousesystemtablesreceiver -> datastoresystemtablesreceiver)
- DSN scheme clickhouse:// -> datastore:// (driver treats non-http/https as Native)
- removed the go.opencensus.io version-pin replace (require-pinned instead)
- kept: real external refs (github.com/ClickHouse, clickhouse.com docs) and the
hanzo-ds/mock test API (NewClickHouseNative) pending the mock's own rename
Full ./... build passes. 0 replace directives, 0 signoz.
537 lines
28 KiB
Go
537 lines
28 KiB
Go
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/redisreceiver"
|
|
"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(),
|
|
redisreceiver.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...)
|
|
}
|