accumulator

func AddScopeMetricsIntoOtelMetrics ¶

func AddScopeMetricsIntoOtelMetrics(populateDataPoints dataPointPopulator, otelMetrics pmetric.Metrics, measurement string, fields map[string]interface{}, tags map[string]string, t time.Time)

AddDataPointsIntoMetrics will use Telegraf's field (which holds subset metrics from the main metrics) and convert to OTEL's datapoint Example:

	Metric {                                                  -->  Metrics {
	   Name: cpu                         				      -->    ResourceMetrics: [{
	   TagList: [{key: mytag, value: myvalue}]			      -->       Resource: {
	   FieldList: [										      -->         Attributes: [{key: mytag, value: myvalue}]
	       {key: cpu_usage_user, value: 0.005},               -->       }
	   ]                                                      -->       ScopeMetrics: [{
	   Time: 1646946605										  -->         Metrics: [
	   Type: Gauge                                            -->           {Name: cpu_usage_user
	                                                          -->            DataType: Gauge
	}														  -->            DataPoints: [{
                       									      -->              Attributes: [{key: mytag, value: myvalue}]
                       									      -->              Timestamp: 1646946605
                       									      --> 			   Type: Double
                        									  -->              Val: 0.005
                   											  -->            }]
                   											  -->         }]
                   											  -->       }]
                   											  -->    }]
                   											  --> }

func ConvertTelegrafToOtelMetrics ¶

func ConvertTelegrafToOtelMetrics(measurement string, fields map[string]interface{}, tags map[string]string, tp telegraf.ValueType, t time.Time) (pmetric.Metrics, error)