Update Stack Monitoring data stream to 9

metricbeat/helper/elastic/elastic.go

@@ -84,7 +84,7 @@
 // MakeXPackMonitoringIndexName method returns the name of the monitoring index for
 // a given product { elasticsearch, kibana, logstash, beats }
 func MakeXPackMonitoringIndexName(product Product) string {
-	const version = "8"
+	const version = "9"
 
 	return fmt.Sprintf(".monitoring-%v-%v-mb", product.xPackMonitoringIndexString(), version)
 }
@@ -100,7 +100,7 @@
 // MakeErrorForMissingField returns an error message for the given field being missing in an API
 // response received from a given product
 func MakeErrorForMissingField(field string, product Product) error {
 	return fmt.Errorf("Could not find field '%v' in %v API response", field, strings.Title(product.String()))
 }
 
 // IsFeatureAvailable returns whether a feature is available in the current product version
@@ -120,7 +120,7 @@
 // for it's date fields: https://github.com/elastic/elasticsearch/pull/36691
 func FixTimestampField(m mapstr.M, field string) error {
 	v, err := m.GetValue(field)
 	if err == mapstr.ErrKeyNotFound {
 		return nil
 	}
 	if err != nil {
@@ -161,10 +161,10 @@
 	metricsets := xpackEnabledMetricsets
 	if err == nil && cfgdMetricsets != nil {
 		// Type cast the metricsets to a slice of strings
 		cfgdMetricsetsSlice := cfgdMetricsets.([]interface{})
 		cfgdMetricsetsStrings := make([]string, len(cfgdMetricsetsSlice))
 		for i := range cfgdMetricsetsSlice {
 			cfgdMetricsetsStrings[i] = cfgdMetricsetsSlice[i].(string)
 		}
 
 		// Add any optional metricsets which are not already configured

metricbeat/helper/elastic/elastic_test.go

@@ -38,22 +38,22 @@ func TestMakeXPackMonitoringIndexName(t *testing.T) {
 		{
 			"Elasticsearch monitoring index",
 			Elasticsearch,
-			".monitoring-es-8-mb",
+			".monitoring-es-9-mb",
 		},
 		{
 			"Kibana monitoring index",
 			Kibana,
-			".monitoring-kibana-8-mb",
+			".monitoring-kibana-9-mb",
 		},
 		{
 			"Logstash monitoring index",
 			Logstash,
-			".monitoring-logstash-8-mb",
+			".monitoring-logstash-9-mb",
 		},
 		{
 			"Beats monitoring index",
 			Beats,
-			".monitoring-beats-8-mb",
+			".monitoring-beats-9-mb",
 		},
 	}