Reset replication on master after failover

Author: Arsenii Pastushenko

pkg/controller/orchestrator/orchestrator_reconcile.go

@@ -293,6 +293,10 @@ func (ou *orcUpdater) updateClusterFailoverInProgressStatus(master *orc.Instance
 	if master != nil && master.SecondsSinceLastSeen.Valid && master.SecondsSinceLastSeen.Int64 < 5 {
 		ou.cluster.UpdateStatusCondition(api.ClusterConditionFailoverInProgress, core.ConditionFalse,
 			"ClusterMasterHealthy", "Master is healthy in orchestrator")
+
+		if err := ou.orcClient.ResetReplication(master.Key); err != nil {
+			ou.log.Error(err, "Error resetting master replication!")
+		}
 	}
 }
 

pkg/orchestrator/orchestrator.go

@@ -39,6 +39,8 @@ type Interface interface {
 	BeginMaintenance(key InstanceKey, owner, reason string) error
 	EndMaintenance(key InstanceKey) error
 	Maintenance() ([]Maintenance, error)
+
+	ResetReplication(key InstanceKey) error
 }
 
 type orchestrator struct {
@@ -154,3 +156,10 @@ func (o *orchestrator) Maintenance() ([]Maintenance, error) {
 
 	return maintenances, nil
 }
+
+func (o *orchestrator) ResetReplication(key InstanceKey) error {
+	if err := o.makeGetAPIRequest(fmt.Sprintf("reset-slave/%s/%d", key.Hostname, key.Port), nil); err != nil {
+		return err
+	}
+	return nil
+}