mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
92ffec50e0
#### Description - Predefining the size for maps help to improve perf. When a map grows beyond its current capacity, Go has to perform a "rehash." - Allocating a new, larger memory block for the hash buckets. - Moving every existing element from the old buckets to the new ones. - Garbage collecting the old memory block. - Move map init from hot path. As, variable: `md` is only used in certain conditions, having it allocated on hot paths may lead to unnecessary allocations. Moving the initialization of the var: `md` from hot path to closer to where it is used, would reduce allocs on hot paths where init of md is not necessary. --------- Co-authored-by: Alex Boten <[email protected]>
80 lines
2.9 KiB
Go
80 lines
2.9 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package otelcol // import "go.opentelemetry.io/collector/otelcol"
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"go.opentelemetry.io/collector/component"
|
|
"go.opentelemetry.io/collector/connector"
|
|
"go.opentelemetry.io/collector/exporter"
|
|
"go.opentelemetry.io/collector/extension"
|
|
"go.opentelemetry.io/collector/internal/componentalias"
|
|
"go.opentelemetry.io/collector/processor"
|
|
"go.opentelemetry.io/collector/receiver"
|
|
"go.opentelemetry.io/collector/service/telemetry"
|
|
)
|
|
|
|
// Factories struct holds in a single type all component factories that
|
|
// can be handled by the Config.
|
|
type Factories struct {
|
|
// Receivers maps receiver type names in the config to the respective factory.
|
|
Receivers map[component.Type]receiver.Factory
|
|
|
|
// Processors maps processor type names in the config to the respective factory.
|
|
Processors map[component.Type]processor.Factory
|
|
|
|
// Exporters maps exporter type names in the config to the respective factory.
|
|
Exporters map[component.Type]exporter.Factory
|
|
|
|
// Extensions maps extension type names in the config to the respective factory.
|
|
Extensions map[component.Type]extension.Factory
|
|
|
|
// Connectors maps connector type names in the config to the respective factory.
|
|
Connectors map[component.Type]connector.Factory
|
|
|
|
// Telemetry is the factory to create the telemetry providers for the service.
|
|
Telemetry telemetry.Factory
|
|
|
|
// ReceiverModules maps receiver types to their respective go modules.
|
|
ReceiverModules map[component.Type]string
|
|
|
|
// ProcessorModules maps processor types to their respective go modules.
|
|
ProcessorModules map[component.Type]string
|
|
|
|
// ExporterModules maps exporter types to their respective go modules.
|
|
ExporterModules map[component.Type]string
|
|
|
|
// ExtensionModules maps extension types to their respective go modules.
|
|
ExtensionModules map[component.Type]string
|
|
|
|
// ConnectorModules maps connector types to their respective go modules.
|
|
ConnectorModules map[component.Type]string
|
|
}
|
|
|
|
// MakeFactoryMap takes a list of factories and returns a map with Factory type as keys.
|
|
// It returns a non-nil error when there are factories with duplicate type.
|
|
// If a factory has a deprecated alias, the map will also contain an entry for the alias.
|
|
func MakeFactoryMap[T component.Factory](factories ...T) (map[component.Type]T, error) {
|
|
fMap := make(map[component.Type]T, len(factories))
|
|
for _, f := range factories {
|
|
if _, ok := fMap[f.Type()]; ok {
|
|
return fMap, fmt.Errorf("duplicate component factory %q", f.Type())
|
|
}
|
|
fMap[f.Type()] = f
|
|
|
|
// If factory has a deprecated alias, add it to the map as well
|
|
if aliasHolder, ok := any(f).(componentalias.TypeAliasHolder); ok {
|
|
alias := aliasHolder.DeprecatedAlias()
|
|
if alias.String() != "" {
|
|
if _, exists := fMap[alias]; exists {
|
|
return fMap, fmt.Errorf("duplicate component factory %q (alias of %q)", alias, f.Type())
|
|
}
|
|
fMap[alias] = f
|
|
}
|
|
}
|
|
}
|
|
return fMap, nil
|
|
}
|