diff --git a/eventDispatcher.go b/eventDispatcher.go index 5f27e68..54e9cc8 100644 --- a/eventDispatcher.go +++ b/eventDispatcher.go @@ -314,9 +314,5 @@ func getDroppedMessageReason(err error) string { } // check for http `Do` related errors - if reason := getDoErrReason(err); reason != genericDoReason { - return reason - } - - return unknown + return getDoErrReason(err) } diff --git a/metrics.go b/metrics.go index 48be8dc..96932ac 100644 --- a/metrics.go +++ b/metrics.go @@ -70,7 +70,6 @@ const ( unroutableDestinationReason = "unroutable_destination" encodeErrReason = "encoding_err" fullQueueReason = "full outbound queue" - genericDoReason = "do_error" deadlineExceededReason = "context_deadline_exceeded" contextCanceledReason = "context_canceled" addressErrReason = "address_error" diff --git a/workerPool.go b/workerPool.go index 4117117..d6e59ef 100644 --- a/workerPool.go +++ b/workerPool.go @@ -144,5 +144,5 @@ func getDoErrReason(err error) string { } } - return genericDoReason + return unknown }