Merge pull request #598 from KubeKyrie/enhance-db-error

make DB bad connection error message more specific
clusterpedia-io · Nov 23, 2023 · 316fc57 · 316fc57
2 parents 630cf19 + 035d5c9
commit 316fc57
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/storage/internalstorage/errors.go b/pkg/storage/internalstorage/errors.go
@@ -29,7 +29,6 @@ var recoverableErrors = []error{
 	io.ErrUnexpectedEOF,
 	os.ErrDeadlineExceeded,
 	syscall.ECONNREFUSED,
-	driver.ErrBadConn,
 }
 
 func init() {
@@ -65,6 +64,10 @@ func InterpretDBError(key string, err error) error {
 		return storage.NewRecoverableException(err)
 	}
 
+	if errors.Is(err, driver.ErrBadConn) {
+		return storage.NewRecoverableException(fmt.Errorf("storage error: database connection error: %s", err))
+	}
+
 	for _, re := range recoverableErrors {
 		if errors.Is(err, re) {
 			return storage.NewRecoverableException(err)