Retry every github.com/lib/pq database error, including "pq: ..."

Some errors created within github.com/lib/pq are created with fmt.Errorf, prefixed with "pq: ". Thus, they are not of the *pq.Error type, but are clearly database errors. A change request was created upstream in: lib/pq#1169 Co-Authored-By: Alvar Penning <[email protected]>
Icinga · Sep 24, 2024 · 2eab550 · 2eab550
1 parent 296f480
commit 2eab550
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/retry/retry.go b/retry/retry.go
@@ -9,6 +9,7 @@ import (
 	"github.com/pkg/errors"
 	"io"
 	"net"
+	"strings"
 	"syscall"
 	"time"
 )
@@ -197,5 +198,12 @@ func Retryable(err error) bool {
 		return true
 	}
 
+	// For errors without a five-digit code, github.com/lib/pq uses fmt.Errorf().
+	// This returns an unexported error type prefixed with "pq: "
+	// Until this gets changed upstream <https://github.com/lib/pq/issues/1169>, we can only check the error message.
+	if strings.HasPrefix(err.Error(), "pq: ") {
+		return true
+	}
+
 	return false
 }