No longer need this

Author: davissp14

cmd/monitor/monitor_cluster_state.go

@@ -8,7 +8,6 @@ import (
 	"time"
 
 	"github.com/fly-apps/postgres-flex/internal/flypg"
-	"github.com/jackc/pgx/v5"
 )
 
 func monitorClusterState(ctx context.Context, node *flypg.Node) {
@@ -63,31 +62,3 @@ func clusterStateMonitorTick(ctx context.Context, node *flypg.Node) error {
 
 	return nil
 }
-
-func evaluateClusterState(ctx context.Context, conn *pgx.Conn, node *flypg.Node) error {
-	primary, err := node.EvaluateClusterState(ctx, conn)
-	if errors.Is(err, flypg.ErrZombieDiagnosisUndecided) || errors.Is(err, flypg.ErrZombieDiscovered) {
-		// Quarantine primary
-		if err := flypg.Quarantine(ctx, conn, node, primary); err != nil {
-			return fmt.Errorf("failed to quarantine failed primary: %s", err)
-		}
-		return fmt.Errorf("primary has been quarantined: %s", err)
-	} else if err != nil {
-		return fmt.Errorf("failed to run zombie diagnosis: %s", err)
-	}
-
-	// Clear zombie lock if it exists
-	if flypg.ZombieLockExists() {
-		log.Println("Clearing zombie lock and enabling read/write")
-		if err := flypg.RemoveZombieLock(); err != nil {
-			return fmt.Errorf("failed to remove zombie lock: %s", err)
-		}
-
-		log.Println("Broadcasting readonly state change")
-		if err := flypg.BroadcastReadonlyChange(ctx, node, false); err != nil {
-			log.Printf("errors while disabling readonly: %s", err)
-		}
-	}
-
-	return nil
-}