Method refresh

server/controller/prometheus/cache/target.go:179–209

(args ...interface{})

}

func (t *target) refresh(args ...interface{}) error {
	recorderTargets, selfTargets, err := t.load()
	if err != nil {
		return err
	}

	keyToTargetID := make(map[TargetKey]int)
	targetIDToLabelNames := make(map[int]mapset.Set[string])
	for _, item := range recorderTargets {
		keyToTargetID[NewTargetKey(item.Instance, item.Job, item.VPCID, item.PodClusterID)] = item.ID
		targetIDToLabelNames[item.ID] = mapset.NewSet(t.getTargetLabelNames(item)...)
	}

	dupKeyIDs := make([]int, 0)
	for _, item := range selfTargets {
		tk := NewTargetKey(item.Instance, item.Job, item.VPCID, item.PodClusterID)
		if _, ok := keyToTargetID[tk]; ok {
			dupKeyIDs = append(dupKeyIDs, item.ID)
			continue
		}
		keyToTargetID[tk] = item.ID
		targetIDToLabelNames[item.ID] = mapset.NewSet(t.getTargetLabelNames(item)...)
	}
	if len(dupKeyIDs) != 0 {
		t.dedup(dupKeyIDs)
	}

	t.keyToTargetID.Coverage(keyToTargetID)
	t.targetIDToLabelNames.Coverage(targetIDToLabelNames)
	return nil
}

func (t *target) getTargetLabelNames(tg *metadbmodel.PrometheusTarget) []string {
	lns := []string{common.TargetLabelInstance, common.TargetLabelJob}