func NewTranslators()

in translator/translate/otel/pipeline/host/translators.go [31:134]
94 lines of code
19 McCabe index (conditional complexity)

func NewTranslators(conf *confmap.Conf, configSection, os string) (common.TranslatorMap[*common.ComponentTranslators, pipeline.ID], error) {
	translators := common.NewTranslatorMap[*common.ComponentTranslators, pipeline.ID]()
	hostReceivers := common.NewTranslatorMap[component.Config, component.ID]()
	hostCustomReceivers := common.NewTranslatorMap[component.Config, component.ID]()
	deltaReceivers := common.NewTranslatorMap[component.Config, component.ID]()
	otlpReceivers := common.NewTranslatorMap[component.Config, component.ID]()

	// Gather adapter receivers
	if configSection == MetricsKey {
		adapterReceivers, err := adaptertranslator.FindReceiversInConfig(conf, os)
		if err != nil {
			return nil, fmt.Errorf("error finding receivers in config: %w", err)
		}
		adapterReceivers.Range(func(translator common.ComponentTranslator) {
			if translator.ID().Type() == adapter.Type(common.DiskIOKey) || translator.ID().Type() == adapter.Type(common.NetKey) {
				deltaReceivers.Set(translator)
			} else if translator.ID().Type() == adapter.Type(common.StatsDMetricKey) || translator.ID().Type() == adapter.Type(common.CollectDPluginKey) {
				hostCustomReceivers.Set(translator)
			} else {
				hostReceivers.Set(translator)
			}
		})
	}

	if shouldAddEbsReceiver(conf, configSection) {
		deltaReceivers.Set(awsebsnvme.NewTranslator())
	}

	// Gather OTLP receivers
	switch v := conf.Get(common.ConfigKey(configSection, common.OtlpKey)).(type) {
	case []any:
		for index := range v {
			otlpReceivers.Set(otlpreceiver.NewTranslator(
				otlpreceiver.WithSignal(pipeline.SignalMetrics),
				otlpreceiver.WithConfigKey(common.ConfigKey(configSection, common.OtlpKey)),
				common.WithIndex(index),
			))
		}
	case map[string]any:
		otlpReceivers.Set(otlpreceiver.NewTranslator(
			otlpreceiver.WithSignal(pipeline.SignalMetrics),
			otlpreceiver.WithConfigKey(common.ConfigKey(configSection, common.OtlpKey)),
		))
	}

	hasHostPipeline := hostReceivers.Len() != 0
	hasHostCustomPipeline := hostCustomReceivers.Len() != 0
	hasDeltaPipeline := deltaReceivers.Len() != 0
	hasOtlpPipeline := otlpReceivers.Len() != 0

	var destinations []string
	switch configSection {
	case LogsKey:
		destinations = common.GetLogsDestinations()
	case MetricsKey:
		destinations = common.GetMetricsDestinations(conf)
	}

	for _, destination := range destinations {
		switch destination {
		case common.AMPKey:
			// PRW exporter does not need the delta conversion.
			receivers := common.NewTranslatorMap[component.Config, component.ID]()
			receivers.Merge(hostReceivers)
			receivers.Merge(deltaReceivers)
			receivers.Merge(otlpReceivers)
			translators.Set(NewTranslator(
				common.PipelineNameHost,
				receivers,
				common.WithDestination(destination),
			))
		default:
			if hasHostPipeline {
				translators.Set(NewTranslator(
					common.PipelineNameHost,
					hostReceivers,
					common.WithDestination(destination),
				))
			}
			if hasHostCustomPipeline {
				translators.Set(NewTranslator(
					common.PipelineNameHostCustomMetrics,
					hostCustomReceivers,
					common.WithDestination(destination)))
			}
			if hasDeltaPipeline {
				translators.Set(NewTranslator(
					common.PipelineNameHostDeltaMetrics,
					deltaReceivers,
					common.WithDestination(destination),
				))
			}
			if hasOtlpPipeline {
				translators.Set(NewTranslator(
					common.PipelineNameHostOtlpMetrics,
					otlpReceivers,
					common.WithDestination(destination),
				))
			}
		}
	}

	return translators, nil
}