func createMetricStreams()

in dev/import-beats/streams.go [123:148]

• 24 lines of code
• 4 McCabe index (conditional complexity)

func createMetricStreams(modulePath, moduleName, moduleTitle, dataStreamName string) ([]packages.Stream, agentContent, error) {
	merged, err := mergeMetaConfigFiles(modulePath)
	if err != nil {
		return nil, agentContent{}, errors.Wrapf(err, "merging config files failed")
	}

	vars, err := createMetricStreamVariables(merged, moduleName, dataStreamName)
	if err != nil {
		return nil, agentContent{}, errors.Wrapf(err, "creating metric stream variables failed (modulePath: %s)", modulePath)
	}
	streams := []packages.Stream{
		{
			Input:       moduleName + "/metrics",
			Title:       fmt.Sprintf("%s %s metrics", moduleTitle, dataStreamName),
			Description: fmt.Sprintf("Collect %s %s metrics", moduleTitle, dataStreamName),
			Vars:        vars,
		},
	}

	agent, err := createAgentContentForMetrics(moduleName, dataStreamName, streams)
	if err != nil {
		return nil, agentContent{}, errors.Wrapf(err, "creating agent content for logs failed (modulePath: %s, dataStreamName: %s)",
			modulePath, dataStreamName)
	}
	return streams, agent, nil
}