Compare commits
3 Commits
cgroups/v0
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8b84c4b1df | ||
|
|
29b2760db4 | ||
|
|
a579343fc7 |
@@ -1,4 +1,4 @@
|
|||||||
package cgroups
|
package cgroup
|
||||||
|
|
||||||
import "fmt"
|
import "fmt"
|
||||||
|
|
||||||
@@ -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"
|
||||||
|
|
||||||
@@ -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(
|
||||||
@@ -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
|
||||||
|
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
package cgroups
|
package cgroup
|
||||||
|
|
||||||
func Version() string {
|
func Version() string {
|
||||||
return "0.0.1"
|
return "0.0.1"
|
||||||
@@ -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
|
||||||
|
|||||||
Reference in New Issue
Block a user