remove job status (stage) in metrics

Author: ffffwh

drivers/mysql/common/models.go

@@ -69,7 +69,6 @@ type TaskStatistics struct {
 	MsgStat            gonats.Statistics
 	BufferStat         BufferStat
 	Stage              string
-	Status             string
 	Timestamp          int64
 	MemoryStat         MemoryStat
 }

drivers/mysql/handle.go

@@ -169,10 +169,8 @@ func (h *taskHandle) run(taskConfig *common.DtleTaskConfig, d *Driver) {
 			}
 		}
 	}()
-
 }
 
-
 func (h *taskHandle) emitStats(ru *common.TaskStatistics) {
 	const srcFullFactor float32 = 4.5
 	const dstFullFactor float32 = 5
@@ -204,7 +202,6 @@ func (h *taskHandle) emitStats(ru *common.TaskStatistics) {
 
 	metrics.SetGaugeWithLabels([]string{"memory.full_kb_count"}, float32(ru.MemoryStat.Full) / 1024, labels)
 	metrics.SetGaugeWithLabels([]string{"memory.incr_kb_count"}, float32(ru.MemoryStat.Incr) / 1024, labels)
-	metrics.SetGaugeWithLabels([]string{"job status ",ru.Status}, float32(1), labels)
 
 	if ru.TableStats != nil {
 		metrics.SetGaugeWithLabels([]string{"table", "insert"}, float32(ru.TableStats.InsertCount), labels)

drivers/mysql/mysql/applier.go

@@ -88,11 +88,11 @@ type Applier struct {
 	storeManager *common.StoreManager
 	gtidCh       chan *common.BinlogCoordinateTx
 
-	status      string
-	memory1     *int64
-	memory2     *int64
-	event       *eventer.Eventer
-	taskConfig  *drivers.TaskConfig
+	stage      string
+	memory1    *int64
+	memory2    *int64
+	event      *eventer.Eventer
+	taskConfig *drivers.TaskConfig
 }
 
 func NewApplier(
@@ -268,8 +268,8 @@ func (a *Applier) Run() {
 
 	go a.updateGtidLoop()
 
-	if a.status != jobFullCopy {
-		a.status = jobFullCopy
+	if a.stage != jobFullCopy {
+		a.stage = jobFullCopy
 		a.sendEvent(jobFullCopy)
 	}
 
@@ -444,8 +444,8 @@ func (a *Applier) subscribeNats() error {
 		a.gtidCh <- nil // coord == nil is a flag for update/upload gtid
 
 		a.mysqlContext.Stage = common.StageSlaveWaitingForWorkersToProcessQueue
-		if a.status != jobIncrCopy {
-			a.status = jobIncrCopy
+		if a.stage != jobIncrCopy {
+			a.stage = jobIncrCopy
 			a.sendEvent(jobIncrCopy)
 		}
 		close(a.rowCopyComplete)
@@ -892,7 +892,6 @@ func (a *Applier) Stats() (*common.TaskStatistics, error) {
 			Full: *a.memory1,
 			Incr: *a.memory2,
 		},
-		Status: a.status,
 	}
 	if a.natsConn != nil {
 		taskResUsage.MsgStat = a.natsConn.Statistics