larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change names

Browse Source
This commit is contained in:
Abhishek Pandey 2023-10-06 16:52:52 +05:30
parent 633524379d
commit 61f96e17be
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/internal/events/adot_sdk_client.go
View File

@ -32,7 +32,7 @@ type randomMetricCollector struct {
func NewRandomMetricCollector(mp metric.MeterProvider) randomMetricCollector { func NewRandomMetricCollector(mp metric.MeterProvider) randomMetricCollector {
rmc := randomMetricCollector{} rmc := randomMetricCollector{}
rmc.meter = mp.Meter("corso-collection") rmc.meter = mp.Meter("corso-meters")
rmc.registerCounter() rmc.registerCounter()
// rmc.registerCpuUsage() // rmc.registerCpuUsage()
return rmc return rmc
@ -61,6 +61,7 @@ func (rmc *randomMetricCollector) registerCounter() {
func (rmc *randomMetricCollector) updateCounter(ctx context.Context) { func (rmc *randomMetricCollector) updateCounter(ctx context.Context) {
logger.Ctx(ctx).Info("updateCounter") logger.Ctx(ctx).Info("updateCounter")
rmc.growCounter.Add(ctx, 1) rmc.growCounter.Add(ctx, 1)
} }
@ -87,13 +88,6 @@ const totalBytesSent = "total_bytes_sent"
const totalApiRequests = "total_api_requests" const totalApiRequests = "total_api_requests"
const latencyTime = "latency_time" const latencyTime = "latency_time"
// Common attributes for traces and metrics (random, request)
var requestMetricCommonLabels = []attribute.KeyValue{
attribute.String("signal", "metric"),
attribute.String("language", serviceName),
attribute.String("metricType", "request"),
}
var randomMetricCommonLabels = []attribute.KeyValue{ var randomMetricCommonLabels = []attribute.KeyValue{
attribute.String("signal", "metric"), attribute.String("signal", "metric"),
attribute.String("language", serviceName), attribute.String("language", serviceName),
@ -116,7 +110,7 @@ func StartClient(ctx context.Context) (func(context.Context) error, error) {
} }
res := resource.NewWithAttributes( res := resource.NewWithAttributes(
semconv.SchemaURL, semconv.SchemaURL,
semconv.ServiceName("go-sample-app"), semconv.ServiceName("corso-metrics"),
) )
if _, present := os.LookupEnv("OTEL_RESOURCE_ATTRIBUTES"); present { if _, present := os.LookupEnv("OTEL_RESOURCE_ATTRIBUTES"); present {
envResource, err := resource.New(ctx, resource.WithFromEnv()) envResource, err := resource.New(ctx, resource.WithFromEnv())