mirror of
https://github.com/weaveworks/scope.git
synced 2026-03-03 18:20:27 +00:00
2ba50b8b3d
```
$ gvt delete golang.org/x/net/context
$ gvt fetch golang.org/x/net/context
2018/07/23 18:03:49 Fetching: golang.org/x/net/context
$ git grep -l "golang.org/x/net/context" | grep -v vendor | xargs sed -i '' 's:golang.org/x/net/context:context:g'
$ git grep -l "context/ctxhttp" | grep -v vendor | xargs sed -i '' 's:context/ctxhttp:golang.org/x/net/context/ctxhttp:g'
$ gofmt -s -w app
$ gofmt -s -w common
$ gofmt -s -w probe
$ gofmt -s -w prog
$ gofmt -s -w tools
```
fixed a bunch of:
```
cannot use func literal (type func("github.com/weaveworks/scope/vendor/golang.org/x/net/context".Context) error) as type func("context".Context) error
```
65 lines
1.6 KiB
Go
65 lines
1.6 KiB
Go
package app
|
|
|
|
import (
|
|
"net/http"
|
|
"time"
|
|
|
|
"context"
|
|
|
|
"github.com/weaveworks/scope/probe/host"
|
|
"github.com/weaveworks/scope/report"
|
|
)
|
|
|
|
// Raw report handler
|
|
func makeRawReportHandler(rep Reporter) CtxHandlerFunc {
|
|
return func(ctx context.Context, w http.ResponseWriter, r *http.Request) {
|
|
report, err := rep.Report(ctx, time.Now())
|
|
if err != nil {
|
|
respondWith(w, http.StatusInternalServerError, err)
|
|
return
|
|
}
|
|
respondWith(w, http.StatusOK, report)
|
|
}
|
|
}
|
|
|
|
type probeDesc struct {
|
|
ID string `json:"id"`
|
|
Hostname string `json:"hostname"`
|
|
Version string `json:"version"`
|
|
LastSeen time.Time `json:"lastSeen"`
|
|
}
|
|
|
|
// Probe handler
|
|
func makeProbeHandler(rep Reporter) CtxHandlerFunc {
|
|
return func(ctx context.Context, w http.ResponseWriter, r *http.Request) {
|
|
r.ParseForm()
|
|
if _, sparse := r.Form["sparse"]; sparse {
|
|
// if we have reports, we must have connected probes
|
|
hasProbes, err := rep.HasReports(ctx, time.Now())
|
|
if err != nil {
|
|
respondWith(w, http.StatusInternalServerError, err)
|
|
}
|
|
respondWith(w, http.StatusOK, hasProbes)
|
|
return
|
|
}
|
|
rpt, err := rep.Report(ctx, time.Now())
|
|
if err != nil {
|
|
respondWith(w, http.StatusInternalServerError, err)
|
|
return
|
|
}
|
|
result := []probeDesc{}
|
|
for _, n := range rpt.Host.Nodes {
|
|
id, _ := n.Latest.Lookup(report.ControlProbeID)
|
|
hostname, _ := n.Latest.Lookup(host.HostName)
|
|
version, dt, _ := n.Latest.LookupEntry(host.ScopeVersion)
|
|
result = append(result, probeDesc{
|
|
ID: id,
|
|
Hostname: hostname,
|
|
Version: version,
|
|
LastSeen: dt,
|
|
})
|
|
}
|
|
respondWith(w, http.StatusOK, result)
|
|
}
|
|
}
|