use error.Is

open-telemetry · May 31, 2021 · fbff122 · fbff122
1 parent 45d180a
commit fbff122
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/exporter/exporterhelper/logs.go b/exporter/exporterhelper/logs.go
@@ -16,6 +16,7 @@ package exporterhelper
 
 import (
 	"context"
+	"errors"
 
 	"go.uber.org/zap"
 
@@ -94,7 +95,7 @@ func NewLogsExporter(
 	lc, err := consumerhelper.NewLogs(func(ctx context.Context, ld pdata.Logs) error {
 		req := newLogsRequest(ctx, ld, pusher)
 		err := be.sender.send(req)
-		if err == errSendingQueueIsFull {
+		if errors.Is(err, errSendingQueueIsFull) {
 			be.obsrep.RecordLogsEnqueueFailure(req.context(), req.count())
 		}
 		return err

diff --git a/exporter/exporterhelper/metrics.go b/exporter/exporterhelper/metrics.go
@@ -16,6 +16,7 @@ package exporterhelper
 
 import (
 	"context"
+	"errors"
 
 	"go.uber.org/zap"
 
@@ -98,7 +99,7 @@ func NewMetricsExporter(
 		}
 		req := newMetricsRequest(ctx, md, pusher)
 		err := be.sender.send(req)
-		if err == errSendingQueueIsFull {
+		if errors.Is(err, errSendingQueueIsFull) {
 			be.obsrep.RecordMetricsEnqueueFailure(req.context(), req.count())
 		}
 		return err

diff --git a/exporter/exporterhelper/traces.go b/exporter/exporterhelper/traces.go
@@ -16,6 +16,7 @@ package exporterhelper
 
 import (
 	"context"
+	"errors"
 
 	"go.uber.org/zap"
 
@@ -95,7 +96,7 @@ func NewTracesExporter(
 	tc, err := consumerhelper.NewTraces(func(ctx context.Context, td pdata.Traces) error {
 		req := newTracesRequest(ctx, td, pusher)
 		err := be.sender.send(req)
-		if err == errSendingQueueIsFull {
+		if errors.Is(err, errSendingQueueIsFull) {
 			be.obsrep.RecordTracesEnqueueFailure(req.context(), req.count())
 		}
 		return err