func()

in validator/validators/feature/feature_validator.go [31:56]


func (s *FeatureValidator) GenerateLoad() error {
	var (
		multiErr              error
		metricSendingInterval = time.Minute
		logGroup              = awsservice.GetInstanceId()
		metricNamespace       = s.vConfig.GetMetricNamespace()
		dataRate              = s.vConfig.GetDataRate()
		agentCollectionPeriod = s.vConfig.GetAgentCollectionPeriod()
		agentConfigFilePath   = s.vConfig.GetCloudWatchAgentConfigPath()
		receivers             = s.vConfig.GetPluginsConfig()
		validationLog         = s.vConfig.GetLogValidation()
	)

	if err := common.GenerateLogs(agentConfigFilePath, agentCollectionPeriod, metricSendingInterval, dataRate, validationLog); err != nil {
		multiErr = multierr.Append(multiErr, err)
	}

	// Sending metrics based on the receivers; however, for scraping plugin  (e.g prometheus), we would need to scrape it instead of sending
	for _, receiver := range receivers {
		if err := common.StartSendingMetrics(receiver, agentCollectionPeriod, metricSendingInterval, dataRate, logGroup, metricNamespace); err != nil {
			multiErr = multierr.Append(multiErr, err)
		}
	}

	return multiErr
}