feat(models): Implement collection of plugin-internal statistics for all types

config/config.go

@@ -1012,6 +1012,11 @@ func (c *Config) addSecretStore(name, source string, table *ast.Table) error {
 		return fmt.Errorf("invalid secret-store ID %q, must only contain letters, numbers or underscore", storeID)
 	}
 
+	tags := map[string]string{
+		"_id":         storeID,
+		"secretstore": name,
+	}
+
 	creator, ok := secretstores.SecretStores[name]
 	if !ok {
 		// Handle removed, deprecated plugins
@@ -1033,6 +1038,7 @@ func (c *Config) addSecretStore(name, source string, table *ast.Table) error {
 
 	logger := logging.New("secretstores", name, "")
 	models.SetLoggerOnPlugin(store, logger)
+	models.SetStatisticsOnPlugin(store, logger, tags)
 
 	if err := store.Init(); err != nil {
 		return fmt.Errorf("error initializing secret-store %q: %w", storeID, err)

models/running_aggregator.go

@@ -42,6 +42,7 @@ func NewRunningAggregator(aggregator telegraf.Aggregator, config *AggregatorConf
 		logger.Error(err)
 	}
 	SetLoggerOnPlugin(aggregator, logger)
+	SetStatisticsOnPlugin(aggregator, logger, tags)
 
 	return &RunningAggregator{
 		Aggregator: aggregator,

models/running_input.go

@@ -55,6 +55,7 @@ func NewRunningInput(input telegraf.Input, config *InputConfig) *RunningInput {
 		logger.Error(err)
 	}
 	SetLoggerOnPlugin(input, logger)
+	SetStatisticsOnPlugin(input, logger, tags)
 
 	return &RunningInput{
 		Input:  input,

models/running_parsers.go

@@ -32,6 +32,7 @@ func NewRunningParser(parser telegraf.Parser, config *ParserConfig) *RunningPars
 		logger.Error(err)
 	}
 	SetLoggerOnPlugin(parser, logger)
+	SetStatisticsOnPlugin(parser, logger, tags)
 
 	return &RunningParser{
 		Parser: parser,

models/running_processor.go

@@ -50,6 +50,7 @@ func NewRunningProcessor(processor telegraf.StreamingProcessor, config *Processo
 		logger.Error(err)
 	}
 	SetLoggerOnPlugin(processor, logger)
+	SetStatisticsOnPlugin(processor, logger, tags)
 
 	return &RunningProcessor{
 		Processor: processor,

models/running_serializer.go

@@ -42,6 +42,7 @@ func NewRunningSerializer(serializer telegraf.Serializer, config *SerializerConf
 		logger.Error(err)
 	}
 	SetLoggerOnPlugin(serializer, logger)
+	SetStatisticsOnPlugin(serializer, logger, tags)
 
 	return &RunningSerializer{
 		Serializer: serializer,