@@ -18,6 +18,7 @@ import (
18
18
"github.com/DataDog/datadog-agent/pkg/collector/corechecks/servicediscovery/model"
19
19
pkgconfigsetup "github.com/DataDog/datadog-agent/pkg/config/setup"
20
20
sysprobeclient "github.com/DataDog/datadog-agent/pkg/system-probe/api/client"
21
+ "github.com/DataDog/datadog-agent/pkg/telemetry"
21
22
"github.com/DataDog/datadog-agent/pkg/util/log"
22
23
"github.com/DataDog/datadog-agent/pkg/util/option"
23
24
)
@@ -40,8 +41,9 @@ var newOSImpl func() (osImpl, error)
40
41
// Check reports discovered services.
41
42
type Check struct {
42
43
corechecks.CheckBase
43
- os osImpl
44
- sender * telemetrySender
44
+ os osImpl
45
+ sender * telemetrySender
46
+ metricDiscoveredServices telemetry.Gauge
45
47
}
46
48
47
49
// Factory creates a new check factory
@@ -87,6 +89,14 @@ func (c *Check) Configure(senderManager sender.SenderManager, _ uint64, instance
87
89
return err
88
90
}
89
91
92
+ c .metricDiscoveredServices = telemetry .NewGaugeWithOpts (
93
+ CheckName ,
94
+ "discovered_services" ,
95
+ []string {},
96
+ "Number of discovered alive services." ,
97
+ telemetry.Options {NoDoubleUnderscoreSep : true },
98
+ )
99
+
90
100
return nil
91
101
}
92
102
@@ -98,7 +108,7 @@ func (c *Check) Run() error {
98
108
}
99
109
100
110
log .Debugf ("runningServices: %d" , response .RunningServicesCount )
101
- metricDiscoveredServices .Set (float64 (response .RunningServicesCount ))
111
+ c . metricDiscoveredServices .Set (float64 (response .RunningServicesCount ))
102
112
103
113
for _ , p := range response .StartedServices {
104
114
c .sender .sendStartServiceEvent (p )
0 commit comments