瀏覽代碼

Added backend API for stats

utkarshcmu 10 年之前
父節點
當前提交
c7fae5386d
共有 4 個文件被更改,包括 78 次插入0 次删除
  1. 14 0
      pkg/api/admin.go
  2. 2 0
      pkg/api/api.go
  3. 15 0
      pkg/models/stats.go
  4. 47 0
      pkg/services/sqlstore/stats.go

+ 14 - 0
pkg/api/admin_settings.go → pkg/api/admin.go

@@ -5,6 +5,8 @@ import (
 
 	"github.com/grafana/grafana/pkg/middleware"
 	"github.com/grafana/grafana/pkg/setting"
+  "github.com/grafana/grafana/pkg/bus"
+  m "github.com/grafana/grafana/pkg/models"
 )
 
 func AdminGetSettings(c *middleware.Context) {
@@ -27,3 +29,15 @@ func AdminGetSettings(c *middleware.Context) {
 
 	c.JSON(200, settings)
 }
+
+func AdminGetStats(c *middleware.Context) {
+
+  statsQuery := m.GetAdminStatsQuery{}
+  
+  if err := bus.Dispatch(&statsQuery); err != nil {
+    c.JsonApiErr(500, "Failed to get admin stats from database", err)
+    return
+  }
+
+  c.JSON(200, statsQuery.Result)
+}

+ 2 - 0
pkg/api/api.go

@@ -40,6 +40,7 @@ func Register(r *macaron.Macaron) {
 	r.Get("/admin/users/edit/:id", reqGrafanaAdmin, Index)
 	r.Get("/admin/orgs", reqGrafanaAdmin, Index)
 	r.Get("/admin/orgs/edit/:id", reqGrafanaAdmin, Index)
+  r.Get("/admin/stats", reqGrafanaAdmin, Index)
 
 	r.Get("/apps", reqSignedIn, Index)
 	r.Get("/apps/edit/*", reqSignedIn, Index)
@@ -210,6 +211,7 @@ func Register(r *macaron.Macaron) {
 		r.Delete("/users/:id", AdminDeleteUser)
 		r.Get("/users/:id/quotas", wrap(GetUserQuotas))
 		r.Put("/users/:id/quotas/:target", bind(m.UpdateUserQuotaCmd{}), wrap(UpdateUserQuota))
+    r.Get("/stats", AdminGetStats)
 	}, reqGrafanaAdmin)
 
 	// rendering

+ 15 - 0
pkg/models/stats.go

@@ -18,3 +18,18 @@ type GetSystemStatsQuery struct {
 type GetDataSourceStatsQuery struct {
 	Result []*DataSourceStats
 }
+
+type AdminStats struct {
+  UserCount       int
+  OrgCount        int
+  DashboardCount  int 
+  DBSnapshotCount int
+  DBTagCount      int
+  DataSourceCount int
+  PlaylistCount   int
+  StarredDBCount  int
+}
+
+type GetAdminStatsQuery struct {
+  Result *AdminStats
+}

+ 47 - 0
pkg/services/sqlstore/stats.go

@@ -8,6 +8,7 @@ import (
 func init() {
 	bus.AddHandler("sql", GetSystemStats)
 	bus.AddHandler("sql", GetDataSourceStats)
+  bus.AddHandler("sql", GetAdminStats)
 }
 
 func GetDataSourceStats(query *m.GetDataSourceStatsQuery) error {
@@ -46,3 +47,49 @@ func GetSystemStats(query *m.GetSystemStatsQuery) error {
 	query.Result = &stats
 	return err
 }
+
+func GetAdminStats(query *m.GetAdminStatsQuery) error {
+  var rawSql = `SELECT
+      (
+        SELECT COUNT(*)
+        FROM ` + dialect.Quote("user") + `
+      ) AS user_count,
+      (
+        SELECT COUNT(*)
+        FROM ` + dialect.Quote("org") + `
+      ) AS org_count,
+      (
+        SELECT COUNT(*)
+        FROM ` + dialect.Quote("dashboard") + `
+      ) AS dashboard_count,
+      (
+        SELECT COUNT(*)
+        FROM ` + dialect.Quote("dashboard_snapshot") + `
+      ) AS db_snapshot_count,
+      (
+        SELECT COUNT(*)
+        FROM ` + dialect.Quote("dashboard_tag") + `
+      ) AS db_tag_count,
+      (
+        SELECT COUNT(*)
+        FROM ` + dialect.Quote("data_source") + `
+      ) AS datasource_count,
+      (
+        SELECT COUNT(*)
+        FROM ` + dialect.Quote("playlist") + `
+      ) AS playlist_count,
+      (
+        SELECT DISTINCT(dashboard_id)
+        FROM ` + dialect.Quote("star") + `
+      ) AS starred_db_count
+      `
+
+  var stats m.AdminStats
+  _, err := x.Sql(rawSql).Get(&stats)
+  if err != nil {
+    return err
+  }
+
+  query.Result = &stats
+  return err
+}