\#920 Log core metrics.

plugins/inputs/uwsgi/stat_types.go

@@ -40,6 +40,7 @@ type Worker struct {
 	AvgRt         int    `json:"avg_rt"`
 
 	Apps  []*App  `json:"apps"`
+	Cores []*Core `json:"cores"`
 }
 
 type App struct {
@@ -54,3 +55,17 @@ type App struct {
 	StartupTime int `json:"startup_time"`
 	Exceptions  int `json:"exceptions"`
 }
+
+type Core struct {
+	// Tags
+	CoreId int `json:"id"`
+
+	// Fields
+	Requests          int `json:"requests"`
+	StaticRequests    int `json:"static_requests"`
+	RoutedRequests    int `json:"routed_requests"`
+	OffloadedRequests int `json:"offloaded_requests"`
+	WriteErrors       int `json:"write_errors"`
+	ReadErrors        int `json:"read_errors"`
+	InRequest         int `json:"in_request"`
+}

plugins/inputs/uwsgi/uwsgi.go

@@ -69,6 +69,7 @@ func (u *Uwsgi) gatherServer(acc telegraf.Accumulator, url *url.URL) error {
 	u.gatherStatServer(acc, &s)
 	u.gatherWorkers(acc, &s)
 	u.gatherApps(acc, &s)
+	u.gatherCores(acc, &s)
 
 	return nil
 }
@@ -147,6 +148,30 @@ func (u *Uwsgi) gatherApps(acc telegraf.Accumulator, s *StatsServer) error {
 	return nil
 }
 
+func (u *Uwsgi) gatherCores(acc telegraf.Accumulator, s *StatsServer) error {
+	for _, w := range s.Workers {
+		for _, c := range w.Cores {
+			fields := map[string]interface{}{
+				"requests":           c.Requests,
+				"static_requests":    c.StaticRequests,
+				"routed_requests":    c.RoutedRequests,
+				"offloaded_requests": c.OffloadedRequests,
+				"write_errors":       c.WriteErrors,
+				"read_errors":        c.ReadErrors,
+				"in_request":         c.InRequest,
+			}
+			tags := map[string]string{
+				"core_id":   strconv.Itoa(c.CoreId),
+				"worker_id": strconv.Itoa(w.WorkerId),
+			}
+			acc.AddFields("uwsgi_cores", fields, tags)
+		}
+
+	}
+
+	return nil
+}
+
 func init() {
 	inputs.Add("uwsgi", func() telegraf.Input { return &Uwsgi{} })
 }