-
Notifications
You must be signed in to change notification settings - Fork 1.4k
/
generated_telemetry.go
54 lines (45 loc) · 1.7 KB
/
generated_telemetry.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
// Code generated by mdatagen. DO NOT EDIT.
package metadata
import (
"errors"
"go.opentelemetry.io/otel/metric"
"go.opentelemetry.io/otel/trace"
"go.opentelemetry.io/collector/component"
)
func Meter(settings component.TelemetrySettings) metric.Meter {
return settings.MeterProvider.Meter("go.opentelemetry.io/collector/receiver/scraperhelper")
}
func Tracer(settings component.TelemetrySettings) trace.Tracer {
return settings.TracerProvider.Tracer("go.opentelemetry.io/collector/receiver/scraperhelper")
}
// TelemetryBuilder provides an interface for components to report telemetry
// as defined in metadata and user config.
type TelemetryBuilder struct {
ScraperErroredMetricPoints metric.Int64Counter
ScraperScrapedMetricPoints metric.Int64Counter
}
// telemetryBuilderOption applies changes to default builder.
type telemetryBuilderOption func(*TelemetryBuilder)
// NewTelemetryBuilder provides a struct with methods to update all internal telemetry
// for a component
func NewTelemetryBuilder(settings component.TelemetrySettings, options ...telemetryBuilderOption) (*TelemetryBuilder, error) {
builder := TelemetryBuilder{}
for _, op := range options {
op(&builder)
}
var err, errs error
meter := Meter(settings)
builder.ScraperErroredMetricPoints, err = meter.Int64Counter(
"scraper_errored_metric_points",
metric.WithDescription("Number of metric points that were unable to be scraped."),
metric.WithUnit("1"),
)
errs = errors.Join(errs, err)
builder.ScraperScrapedMetricPoints, err = meter.Int64Counter(
"scraper_scraped_metric_points",
metric.WithDescription("Number of metric points successfully scraped."),
metric.WithUnit("1"),
)
errs = errors.Join(errs, err)
return &builder, errs
}