bug fix: full gtid replaced with channel gtid

internal/app/replication.go

@@ -19,7 +19,7 @@ const (
 type ReplicationRepairState struct {
 	LastAttempt      time.Time
 	History          map[ReplicationRepairAlgorithmType]int
-	BeforeRepairGTID *mysql.GTIDExecuted
+	BeforeRepairGTID string
 }
 
 func (app *App) MarkReplicationRunning(node *mysql.Node, channel string) {
@@ -31,12 +31,12 @@ func (app *App) MarkReplicationRunning(node *mysql.Node, channel string) {
 		return
 	}
 
-	gtid, err := node.GTIDExecuted()
+	status, err := node.GetReplicaStatus()
 	if err != nil {
 		return
 	}
 	if replState.cooldownPassed(app.config.ReplicationRepairCooldown) &&
-		replState.isGtidExecuted(gtid) {
+		replState.isGtidExecuted(status.GetExecutedGtidSet()) {
 		delete(app.replRepairState, key)
 	}
 }
@@ -148,11 +148,8 @@ func (state *ReplicationRepairState) cooldownPassed(replicationRepairCooldown ti
 	return state.LastAttempt.Before(cooldown)
 }
 
-func (state *ReplicationRepairState) isGtidExecuted(currentGtid *mysql.GTIDExecuted) bool {
-	if state.BeforeRepairGTID.ExecutedGtidSet == currentGtid.ExecutedGtidSet {
-		return false
-	}
-	return true
+func (state *ReplicationRepairState) isGtidExecuted(currentGtid string) bool {
+	return state.BeforeRepairGTID != currentGtid
 }
 
 func (app *App) getOrCreateHostRepairState(stateKey, hostname string) (*ReplicationRepairState, error) {
@@ -161,11 +158,11 @@ func (app *App) getOrCreateHostRepairState(stateKey, hostname string) (*Replicat
 		replState = state
 	} else {
 		replState = app.createRepairState()
-		executedGtid, err := app.cluster.Get(hostname).GTIDExecuted()
+		status, err := app.cluster.Get(hostname).GetReplicaStatus()
 		if err != nil {
 			return nil, err
 		}
-		replState.BeforeRepairGTID = executedGtid
+		replState.BeforeRepairGTID = status.GetExecutedGtidSet()
 		app.replRepairState[stateKey] = replState
 	}
 
@@ -176,7 +173,7 @@ func (app *App) createRepairState() *ReplicationRepairState {
 	result := ReplicationRepairState{
 		LastAttempt:      time.Now(),
 		History:          make(map[ReplicationRepairAlgorithmType]int),
-		BeforeRepairGTID: &mysql.GTIDExecuted{},
+		BeforeRepairGTID: "",
 	}
 
 	for i := range app.getAlgorithmOrder() {