// parseChangelogHeartbeat is called when a heartbeat event is intercepted
parseChangelogHeartbeat is called when a heartbeat event is intercepted
// parseChangelogHeartbeat is called when a heartbeat event is intercepted
func (this *Throttler) parseChangelogHeartbeat(heartbeatValue string) (err error) {
	heartbeatTime, err := time.Parse(time.RFC3339Nano, heartbeatValue)
	if err != nil {
		return log.Errore(err)
	}
	lag := time.Since(heartbeatTime)
	atomic.StoreInt64(&this.migrationContext.CurrentLag, int64(lag))
	return nil
}
func ( this * Throttler ) parseChangelogHeartbeat ( heartbeatValue string ) ( err error ) { heartbeatTime , err := time . Parse ( time . RFC3339Nano , heartbeatValue ) if err != nil { return log . Errore ( err ) } lag := time . Since ( heartbeatTime ) atomic . StoreInt64 ( & this . migrationContext . CurrentLag , int64 ( lag ) ) return nil }
parseChangelogHeartbeat is called when a heartbeat event is intercepted
parseChangelogHeartbeat is called when a heartbeat event is intercepted