feat: templatize telegraf config output (#87)

* feat: templatize telegraf config output

* fix: templatize all keys in output

modules/firehose/driver.go

@@ -209,6 +209,20 @@ func (fd *firehoseDriver) getHelmRelease(res resource.Resource, conf Config,
 			return nil, err
 		}
 
+		for key, val := range conf.Telegraf.Config.Output {
+			valAsMap, ok := val.(map[string]interface{})
+			if !ok {
+				continue
+			}
+
+			valAsMap, err = renderTplOfMapStringAny(valAsMap, mergedLabelsAndEnvVariablesMap)
+			if err != nil {
+				return nil, err
+			}
+
+			conf.Telegraf.Config.Output[key] = valAsMap
+		}
+
 		telegrafConf = Telegraf{
 			Enabled: true,
 			Image:   conf.Telegraf.Image,
@@ -420,3 +434,24 @@ func (us UsageSpec) merge(overide UsageSpec) UsageSpec {
 
 	return clone
 }
+
+func renderTplOfMapStringAny(labelsTpl map[string]any, labelsValues map[string]string) (map[string]any, error) {
+	outputMap := make(map[string]string)
+
+	for key, value := range labelsTpl {
+		if strValue, ok := value.(string); ok {
+			outputMap[key] = strValue
+		}
+	}
+
+	outputMap, err := renderTpl(outputMap, labelsValues)
+	if err != nil {
+		return nil, err
+	}
+
+	for key, val := range outputMap {
+		labelsTpl[key] = val
+	}
+
+	return labelsTpl, nil
+}

modules/firehose/driver_test.go

@@ -181,7 +181,7 @@ func TestFirehoseDriver(t *testing.T) {
 							"output": map[string]any{
 								"prometheus_remote_write": map[string]any{
 									"enabled": true,
-									"url":     "http://goto.com",
+									"url":     "http://goto.namespace-1.com",
 								},
 							},
 							"additional_global_tags": map[string]string{
@@ -358,7 +358,7 @@ func TestFirehoseDriver(t *testing.T) {
 							"output": map[string]any{
 								"prometheus_remote_write": map[string]any{
 									"enabled": true,
-									"url":     "http://goto.com",
+									"url":     "http://goto.namespace-1.com",
 								},
 							},
 							"additional_global_tags": map[string]string{
@@ -543,7 +543,7 @@ func TestFirehoseDriver(t *testing.T) {
 							"output": map[string]any{
 								"prometheus_remote_write": map[string]any{
 									"enabled": true,
-									"url":     "http://goto.com",
+									"url":     "http://goto.namespace-1.com",
 								},
 							},
 							"additional_global_tags": map[string]string{
@@ -686,7 +686,7 @@ func firehoseDriverConf() driverConf {
 				Output: map[string]any{
 					"prometheus_remote_write": map[string]any{
 						"enabled": true,
-						"url":     "http://goto.com",
+						"url":     "http://goto.{{ .namespace }}.com",
 					},
 				},
 				AdditionalGlobalTags: map[string]string{