in collector/receiver/prometheusreceiver/internal/appendable.go [43:76]
func NewAppendable(
sink consumer.Metrics,
set receiver.Settings,
gcInterval time.Duration,
useStartTimeMetric bool,
startTimeMetricRegex *regexp.Regexp,
useCreatedMetric bool,
useCollectorStartTimeFallback bool,
allowCumulativeResets bool,
externalLabels labels.Labels,
trimSuffixes bool) (storage.Appendable, error) {
var metricAdjuster MetricsAdjuster
if !useStartTimeMetric {
metricAdjuster = NewInitialPointAdjuster(set.Logger, gcInterval, useCreatedMetric)
} else {
metricAdjuster = NewStartTimeMetricAdjuster(set.Logger, gcInterval, startTimeMetricRegex, useCollectorStartTimeFallback, allowCumulativeResets)
}
obsrecv, err := receiverhelper.NewObsReport(receiverhelper.ObsReportSettings{ReceiverID: set.ID, Transport: transport, ReceiverCreateSettings: set})
if err != nil {
return nil, err
}
return &appendable{
sink: sink,
settings: set,
metricAdjuster: metricAdjuster,
useStartTimeMetric: useStartTimeMetric,
trimSuffixes: trimSuffixes,
startTimeMetricRegex: startTimeMetricRegex,
externalLabels: externalLabels,
obsrecv: obsrecv,
}, nil
}