core/service/pg: fatal exit when db connection is read-only

core/services/pg/lease_lock.go

@@ -8,10 +8,12 @@ import (
 	"time"
 
 	"github.com/google/uuid"
+	"github.com/jackc/pgconn"
 	"github.com/pkg/errors"
-	"github.com/smartcontractkit/sqlx"
 	"go.uber.org/multierr"
 
+	"github.com/smartcontractkit/sqlx"
+
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/utils"
 )
@@ -220,6 +222,11 @@ func (l *leaseLock) loop(ctx context.Context) {
 			}
 			cancel()
 			if err != nil {
+				var pgErr pgconn.PgError
+				const ReadOnlyTransaction = "25006"
+				if errors.As(err, &pgErr) && pgErr.Code == ReadOnlyTransaction {
+					l.logger.Fatal("Read-only connection, exiting immediately")
+				}
 				l.logger.Errorw("Error trying to refresh database lease", "err", err)
 			} else if !gotLease {
 				if err := l.db.Close(); err != nil {