3 Commits

Author SHA1 Message Date
andrey
8b84c4b1df rename cgroup 2024-04-06 16:39:58 +03:00
andrey
29b2760db4 use cgroup cpu 2024-04-06 16:37:24 +03:00
andrey
a579343fc7 update configure service name 2024-04-06 16:27:21 +03:00
7 changed files with 10 additions and 23 deletions

View File

@@ -1,4 +1,4 @@
package cgroups package cgroup
import "fmt" import "fmt"

View File

@@ -1,6 +1,6 @@
// Code generated by "stringer -type=Controller -linecomment"; DO NOT EDIT. // Code generated by "stringer -type=Controller -linecomment"; DO NOT EDIT.
package cgroups package cgroup
import "strconv" import "strconv"

View File

@@ -1,4 +1,4 @@
package cgroups package cgroup
import ( import (
"context" "context"
@@ -32,9 +32,9 @@ func WithControllers(ctrls ...Controller) Option {
// Option supports configuring optional settings for runtime metrics. // Option supports configuring optional settings for runtime metrics.
type Option func(*config) type Option func(*config)
func newConfig(controllers []Controller, opts ...Option) config { func newConfig(opts ...Option) config {
cfg := config{ cfg := config{
controllers: controllers, controllers: []Controller{ControllerCPU},
provider: otel.GetMeterProvider(), provider: otel.GetMeterProvider(),
prefix: "cgroups.", prefix: "cgroups.",
} }
@@ -179,20 +179,7 @@ func Start(group string, opts ...Option) (metric.Registration, error) {
return nil, fmt.Errorf("load:%w", err) return nil, fmt.Errorf("load:%w", err)
} }
controllers, cerr := manager.Controllers() cfg := newConfig(opts...)
if cerr != nil {
return nil, fmt.Errorf("controllers:%w", cerr)
}
ctrls := make([]Controller, 0, len(controllers))
for _, controller := range controllers {
ctrl, err := ParseController(controller)
if err == nil {
ctrls = append(ctrls, ctrl)
}
}
cfg := newConfig(ctrls, opts...)
cgr := cgroup{ cgr := cgroup{
meter: cfg.provider.Meter( meter: cfg.provider.Meter(

View File

@@ -1,4 +1,4 @@
module gitoa.ru/go-4devs/otel/cgroups module gitoa.ru/go-4devs/otel/cgroup
go 1.22.2 go 1.22.2

View File

@@ -1,4 +1,4 @@
package cgroups package cgroup
func Version() string { func Version() string {
return "0.0.1" return "0.0.1"

View File

@@ -13,8 +13,8 @@ import (
semconv "go.opentelemetry.io/otel/semconv/v1.17.0" semconv "go.opentelemetry.io/otel/semconv/v1.17.0"
) )
func WithServiceName(name string) func(*Option) error { func WithServiceName(name string) func(context.Context, *Option) error {
return func(o *Option) error { return func(_ context.Context, o *Option) error {
o.serviceName = name o.serviceName = name
return nil return nil