mirror of
https://github.com/grafana/grafana.git
synced 2024-12-02 05:29:42 -06:00
85 lines
2.1 KiB
Go
85 lines
2.1 KiB
Go
package metrics
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/grafana/grafana/pkg/bus"
|
|
"github.com/grafana/grafana/pkg/log"
|
|
m "github.com/grafana/grafana/pkg/models"
|
|
"github.com/grafana/grafana/pkg/setting"
|
|
)
|
|
|
|
func StartUsageReportLoop() chan struct{} {
|
|
M_Instance_Start.Inc(1)
|
|
|
|
ticker := time.NewTicker(time.Hour * 24)
|
|
for {
|
|
select {
|
|
case <-ticker.C:
|
|
sendUsageStats()
|
|
}
|
|
}
|
|
}
|
|
|
|
func sendUsageStats() {
|
|
log.Trace("Sending anonymous usage stats to stats.grafana.org")
|
|
|
|
version := strings.Replace(setting.BuildVersion, ".", "_", -1)
|
|
|
|
metrics := map[string]interface{}{}
|
|
report := map[string]interface{}{
|
|
"version": version,
|
|
"metrics": metrics,
|
|
}
|
|
|
|
UsageStats.Each(func(name string, i interface{}) {
|
|
switch metric := i.(type) {
|
|
case Counter:
|
|
if metric.Count() > 0 {
|
|
metrics[name+".count"] = metric.Count()
|
|
metric.Clear()
|
|
}
|
|
}
|
|
})
|
|
|
|
statsQuery := m.GetSystemStatsQuery{}
|
|
if err := bus.Dispatch(&statsQuery); err != nil {
|
|
log.Error(3, "Failed to get system stats", err)
|
|
return
|
|
}
|
|
|
|
metrics["stats.dashboards.count"] = statsQuery.Result.DashboardCount
|
|
metrics["stats.users.count"] = statsQuery.Result.UserCount
|
|
metrics["stats.orgs.count"] = statsQuery.Result.OrgCount
|
|
metrics["stats.playlist.count"] = statsQuery.Result.PlaylistCount
|
|
|
|
dsStats := m.GetDataSourceStatsQuery{}
|
|
if err := bus.Dispatch(&dsStats); err != nil {
|
|
log.Error(3, "Failed to get datasource stats", err)
|
|
return
|
|
}
|
|
|
|
// send counters for each data source
|
|
// but ignore any custom data sources
|
|
// as sending that name could be sensitive information
|
|
dsOtherCount := 0
|
|
for _, dsStat := range dsStats.Result {
|
|
if m.IsKnownDataSourcePlugin(dsStat.Type) {
|
|
metrics["stats.ds."+dsStat.Type+".count"] = dsStat.Count
|
|
} else {
|
|
dsOtherCount += dsStat.Count
|
|
}
|
|
}
|
|
metrics["stats.ds.other.count"] = dsOtherCount
|
|
|
|
out, _ := json.MarshalIndent(report, "", " ")
|
|
data := bytes.NewBuffer(out)
|
|
|
|
client := http.Client{Timeout: time.Duration(5 * time.Second)}
|
|
go client.Post("https://stats.grafana.org/grafana-usage-report", "application/json", data)
|
|
}
|