me/neoq
1
0
Fork 0
mirror of https://github.com/acaloiaro/neoq synced 2026-07-21 10:12:18 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

remove duplicate otel imports

Browse source
This commit is contained in:
Adriano Caloiaro 2024-10-27 10:04:02 -07:00
parent 73200931b1
commit bdb8a7bce6
No known key found for this signature in database
GPG key ID: C2BC56DE73CE3F75
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
backends/postgres/postgres_backend.go
View file

@ -28,7 +28,6 @@ import (
"github.com/robfig/cron"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
api "go.opentelemetry.io/otel/metric"
"golang.org/x/exp/slices"
"golang.org/x/exp/slog"
)
@ -196,17 +195,17 @@ func Backend(ctx context.Context, opts ...neoq.ConfigOption) (pb neoq.Neoq, err
// initialize otel meters for observability
if p.config.OpentelemetryMeterProvider != nil {
m := p.config.OpentelemetryMeterProvider.Meter("github.com/acaloiaro/neoq")
p.successGauage, err = m.Int64Counter("neoq.queue.success", api.WithDescription("jobs that have succeeded"))
p.successGauage, err = m.Int64Counter("neoq.queue.success", metric.WithDescription("jobs that have succeeded"))
if err != nil {
p.logger.Error("unable to initialize opentelemetry success metrics", slog.Any("error", err))
return nil, fmt.Errorf("unable to initialize opentelemetry success metrics: %w", err)
}
p.failureGauge, err = m.Int64Counter("neoq.queue.failure", api.WithDescription("jobs that have failed"))
p.failureGauge, err = m.Int64Counter("neoq.queue.failure", metric.WithDescription("jobs that have failed"))
if err != nil {
p.logger.Error("unable to initialize opentelemetry failure metrics", slog.Any("error", err))
return nil, fmt.Errorf("unable to initialize opentelemetry failure metrics: %w", err)
}
p.depthGauge, err = m.Int64Gauge("neoq.queue.depth", api.WithDescription("depth of the queue"))
p.depthGauge, err = m.Int64Gauge("neoq.queue.depth", metric.WithDescription("depth of the queue"))
if err != nil {
p.logger.Error("unable to initialize opentelemetry queue depth metrics", slog.Any("error", err))
return nil, fmt.Errorf("unable to initialize opentelemetry queue depth: %w", err)
@ -907,7 +906,7 @@ func (p *PgBackend) handleJob(ctx context.Context, jobID string) (err error) {
return
}
telemetryAttrs := api.WithAttributes(
telemetryAttrs := metric.WithAttributes(
attribute.Key("queue").String(job.Queue),
)
// the job ended with an error, incrementing the failing counter