/
factory.go
39 lines (34 loc) · 932 Bytes
/
factory.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
package opentsdbreceiver
import (
"context"
"go.opentelemetry.io/collector/component"
"go.opentelemetry.io/collector/config/confignet"
"go.opentelemetry.io/collector/consumer"
"go.opentelemetry.io/collector/receiver"
)
const (
typeStr = "opentsdb"
stability = component.StabilityLevelDevelopment
)
func NewFactory() receiver.Factory {
return receiver.NewFactory(
typeStr,
createDefaultConfig,
receiver.WithMetrics(createMetricsReceiver, stability))
}
func createDefaultConfig() component.Config {
return &Config{
TCPAddr: confignet.TCPAddr{
Endpoint: "0.0.0.0:4242",
},
}
}
func createMetricsReceiver(
_ context.Context,
params receiver.CreateSettings,
config component.Config,
nextConsumer consumer.Metrics,
) (receiver.Metrics, error) {
// return newMetricsReceiver(cfg, params.Logger, params.TelemetrySettings, nextConsumer)
return newMetricsReceiver(config.(*Config), params, nextConsumer)
}