diff --git a/go/vt/vttablet/tabletserver/repltracker/poller.go b/go/vt/vttablet/tabletserver/repltracker/poller.go index dd77cc22188..da85da78008 100644 --- a/go/vt/vttablet/tabletserver/repltracker/poller.go +++ b/go/vt/vttablet/tabletserver/repltracker/poller.go @@ -20,11 +20,15 @@ import ( "sync" "time" + "vitess.io/vitess/go/stats" + "vitess.io/vitess/go/vt/mysqlctl" vtrpcpb "vitess.io/vitess/go/vt/proto/vtrpc" "vitess.io/vitess/go/vt/vterrors" ) +var replicationLagSeconds = stats.NewGauge("replicationLagSec", "replication lag in seconds") + type poller struct { mysqld mysqlctl.MysqlDaemon @@ -55,5 +59,6 @@ func (p *poller) Status() (time.Duration, error) { p.lag = time.Duration(status.SecondsBehindMaster) * time.Second p.timeRecorded = time.Now() + replicationLagSeconds.Set(int64(p.lag.Seconds())) return p.lag, nil }