Method encode

server/controller/prometheus/encoder/label.go:130–172

(toAdd []*controller.PrometheusLabelRequest)

}

func (l *label) encode(toAdd []*controller.PrometheusLabelRequest) ([]*controller.PrometheusLabel, error) {
	l.lock.Lock()
	defer l.lock.Unlock()

	resp := make([]*controller.PrometheusLabel, 0)
	var dbToAdd []*metadbmodel.PrometheusLabel
	for _, item := range toAdd {
		n := item.GetName()
		v := item.GetValue()
		nameID, ok1 := l.labelName.getID(n)
		valueID, ok2 := l.labelValue.getID(v)
		if ok1 && ok2 {
			if id, ok := l.getID(cache.IDLabelKey{NameID: nameID, ValueID: valueID}); ok {
				resp = append(resp, &controller.PrometheusLabel{
					Name:  &n,
					Value: &v,
					Id:    proto.Uint32(uint32(id)),
				})
				continue
			}
		}
		dbToAdd = append(dbToAdd, &metadbmodel.PrometheusLabel{
			Name:  n,
			Value: v,
		})
	}

	err := addBatch(l.org.DB, dbToAdd, l.resourceType)
	if err != nil {
		log.Errorf("add %s error: %s", l.resourceType, err.Error(), l.org.LogPrefix)
		return nil, err
	}
	for _, item := range dbToAdd {
		l.store(item)
		resp = append(resp, &controller.PrometheusLabel{
			Name:  &item.Name,
			Value: &item.Value,
			Id:    proto.Uint32(uint32(item.ID)),
		})

	}
	return resp, nil
}