mirrors/apollo-backend
2
0
Fork 0
mirror of https://github.com/christianselig/apollo-backend synced 2024-11-15 08:27:42 +00:00
Code Issues Projects Releases Packages Wiki Activity

add instrumentation around queue acks

Browse source
This commit is contained in:
Andre Medeiros 2022-11-03 14:08:14 -04:00
parent b9577325dd
commit 5adc5ec4e2
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
internal/worker/notifications.go
View file

@ -14,6 +14,7 @@ import (
"github.com/sideshow/apns2/payload" "github.com/sideshow/apns2/payload"
"github.com/sideshow/apns2/token" "github.com/sideshow/apns2/token"
"go.opentelemetry.io/otel/attribute" "go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/codes"
"go.opentelemetry.io/otel/trace" "go.opentelemetry.io/otel/trace"
"go.uber.org/zap" "go.uber.org/zap"
@ -168,11 +169,16 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) {
logger.Debug("starting job") logger.Debug("starting job")
defer func() { defer func(ctx context.Context) {
_, span := nc.tracer.Start(ctx, "queue:ack")
defer span.End()
if err := delivery.Ack(); err != nil { if err := delivery.Ack(); err != nil {
span.SetStatus(codes.Error, "failed to acknowledge message")
span.RecordError(err)
logger.Error("failed to acknowledge message", zap.Error(err)) logger.Error("failed to acknowledge message", zap.Error(err))
} }
}() }(ctx)
account, err := nc.accountRepo.GetByRedditID(ctx, id) account, err := nc.accountRepo.GetByRedditID(ctx, id)
if err != nil { if err != nil {