diff --git a/plugins/outputs/cloudwatch_logs/cloudwatch_logs.go b/plugins/outputs/cloudwatch_logs/cloudwatch_logs.go index d27fb009d..f3397e100 100644 --- a/plugins/outputs/cloudwatch_logs/cloudwatch_logs.go +++ b/plugins/outputs/cloudwatch_logs/cloudwatch_logs.go @@ -205,7 +205,7 @@ func (c *CloudWatchLogs) Connect() error { c.Log.Debugf("Log stream %q...", c.lsSource) } - c.ls = map[string]*logStreamContainer{} + c.ls = make(map[string]*logStreamContainer) } return nil diff --git a/plugins/outputs/loki/stream.go b/plugins/outputs/loki/stream.go index 4f9f9c072..5f1687ef2 100644 --- a/plugins/outputs/loki/stream.go +++ b/plugins/outputs/loki/stream.go @@ -59,7 +59,7 @@ func uniqKeyFromTagList(ts []*telegraf.Tag) (k string) { func newStream(ts []*telegraf.Tag) *Stream { s := &Stream{ Logs: make([]Log, 0), - Labels: map[string]string{}, + Labels: make(map[string]string, len(ts)), } for _, t := range ts { diff --git a/plugins/outputs/mongodb/mongodb.go b/plugins/outputs/mongodb/mongodb.go index 6394494e1..909bfb873 100644 --- a/plugins/outputs/mongodb/mongodb.go +++ b/plugins/outputs/mongodb/mongodb.go @@ -26,11 +26,11 @@ import ( var sampleConfig string func (s *MongoDB) getCollections(ctx context.Context) error { - s.collections = map[string]bson.M{} collections, err := s.client.Database(s.MetricDatabase).ListCollections(ctx, bson.M{}) if err != nil { return fmt.Errorf("unable to execute ListCollections: %w", err) } + s.collections = make(map[string]bson.M, collections.RemainingBatchLength()) for collections.Next(ctx) { var collection bson.M if err = collections.Decode(&collection); err != nil { diff --git a/plugins/outputs/nebius_cloud_monitoring/nebius_cloud_monitoring.go b/plugins/outputs/nebius_cloud_monitoring/nebius_cloud_monitoring.go index 89cf4f55c..421ae978d 100644 --- a/plugins/outputs/nebius_cloud_monitoring/nebius_cloud_monitoring.go +++ b/plugins/outputs/nebius_cloud_monitoring/nebius_cloud_monitoring.go @@ -103,7 +103,7 @@ func (a *NebiusCloudMonitoring) Init() error { }, Timeout: time.Duration(a.Timeout), } - tags := map[string]string{} + tags := make(map[string]string) a.MetricOutsideWindow = selfstat.Register("nebius_cloud_monitoring", "metric_outside_window", tags) return nil } diff --git a/plugins/outputs/postgresql/table_source.go b/plugins/outputs/postgresql/table_source.go index e8fd507bf..26bf2d6e1 100644 --- a/plugins/outputs/postgresql/table_source.go +++ b/plugins/outputs/postgresql/table_source.go @@ -15,7 +15,7 @@ type columnList struct { func newColumnList() *columnList { return &columnList{ - indices: map[string]int{}, + indices: make(map[string]int), } } @@ -65,7 +65,7 @@ type TableSource struct { } func NewTableSources(p *Postgresql, metrics []telegraf.Metric) map[string]*TableSource { - tableSources := map[string]*TableSource{} + tableSources := make(map[string]*TableSource) for _, m := range metrics { tsrc := tableSources[m.Name()] diff --git a/plugins/outputs/registry.go b/plugins/outputs/registry.go index 5787a82b0..935137eca 100644 --- a/plugins/outputs/registry.go +++ b/plugins/outputs/registry.go @@ -6,7 +6,7 @@ import ( type Creator func() telegraf.Output -var Outputs = map[string]Creator{} +var Outputs = make(map[string]Creator) func Add(name string, creator Creator) { Outputs[name] = creator diff --git a/plugins/outputs/yandex_cloud_monitoring/yandex_cloud_monitoring.go b/plugins/outputs/yandex_cloud_monitoring/yandex_cloud_monitoring.go index afe49d263..85f74e2f5 100644 --- a/plugins/outputs/yandex_cloud_monitoring/yandex_cloud_monitoring.go +++ b/plugins/outputs/yandex_cloud_monitoring/yandex_cloud_monitoring.go @@ -107,7 +107,7 @@ func (a *YandexCloudMonitoring) Connect() error { a.Log.Infof("Writing to Yandex.Cloud Monitoring URL: %s", a.EndpointURL) - tags := map[string]string{} + tags := make(map[string]string) a.MetricOutsideWindow = selfstat.Register("yandex_cloud_monitoring", "metric_outside_window", tags) return nil