Method RegisterStatsdTable

server/controller/statsd/statsd.go:68–139

(stable Statsdtable)

}

func (s *StatsdMonitor) RegisterStatsdTable(stable Statsdtable) {
	if !s.enable {
		return
	}

	if err := s.initStatsdClient(); err != nil {
		log.Warning(err)
		return
	}

	encoder := new(codec.SimpleEncoder)

	statter := stable.GetStatter()
	keys := []string{}
	for key := range statter.GlobalTags {
		keys = append(keys, key)
	}
	sort.Strings(keys)

	// collect
	timeStamp := time.Now().Unix()
	dfStats := &pb.Stats{}
	for _, e := range statter.Element {
		for mfName, mfValues := range e.MetricsFloatNameToValues {
			name := e.VirtualTableName
			hostName := os.Getenv(common.NODE_NAME_KEY)
			tagNames := []string{e.PrivateTagKey, "host"}
			tagValues := []string{mfName, hostName}

			if e.UseGlobalTag {
				tagNames = append(tagNames, keys...)
				for _, k := range keys {
					tagValues = append(tagValues, statter.GlobalTags[k])
				}
			}

			metricsFloatNames := []string{}
			metricsFloatValues := []float64{}
			var vSum float64
			for _, v := range mfValues {
				vSum += v
			}
			switch e.MetricType {
			case MetricInc:
				metricsFloatNames = []string{"count"}
				metricsFloatValues = []float64{vSum}
			case MetricTiming:
				vLen := float64(len(mfValues))
				vAVG, _ := strconv.ParseFloat(fmt.Sprintf("%.3f", vSum/vLen), 64)
				metricsFloatNames = []string{"avg", "len"}
				if vLen == 1 && vAVG == 0 {
					vLen = 0
				}
				metricsFloatValues = []float64{vAVG, vLen}
			default:
				continue
			}