Method refresh

server/controller/prometheus/cache/label.go:157–198

(args ...interface{})

}

func (l *label) refresh(args ...interface{}) error {
	var count int64
	if err := l.org.DB.Model(&metadbmodel.PrometheusLabel{}).Count(&count).Error; err != nil {
		return err
	}

	rows, err := l.org.DB.Model(&metadbmodel.PrometheusLabel{}).Select("id", "name", "value").Rows()
	if err != nil {
		return err
	}
	defer rows.Close()

	newActive := make(map[IDLabelKey]int, count)
	for rows.Next() {
		var id int
		var name, value string
		if scanErr := rows.Scan(&id, &name, &value); scanErr != nil {
			log.Errorf("stream scan prometheus_label interrupted: %v", scanErr, l.org.LogPrefix)
			return scanErr
		}
		nameID, ok1 := l.labelName.GetIDByName(name)
		valueID, ok2 := l.labelValue.GetIDByValue(value)
		if ok1 && ok2 {
			newActive[IDLabelKey{NameID: nameID, ValueID: valueID}] = id
		}
	}
	if err := rows.Err(); err != nil {
		log.Errorf("stream read prometheus_label error: %v", err, l.org.LogPrefix)
		return err
	}

	l.mu.Lock()
	pending := l.pending
	l.pending = make(map[IDLabelKey]int)
	for key, value := range pending {
		newActive[key] = value
	}
	l.mu.Unlock()

	l.replaceActive(newActive)
	return nil
}