69 lines
1.7 KiB
Go
69 lines
1.7 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
|
|
"go.wit.com/lib/gui/shell"
|
|
pb "go.wit.com/lib/protobuf/virtbuf"
|
|
)
|
|
|
|
/*
|
|
debugging code to see the state of the
|
|
cluster via http
|
|
*/
|
|
|
|
func dumpCluster(w http.ResponseWriter) {
|
|
umap, macs, err := ValidateDroplets(me.cluster)
|
|
for u, hostname := range umap {
|
|
fmt.Fprintln(w, "uuid:", u, "hostname:", hostname)
|
|
}
|
|
|
|
for mac, uuid := range macs {
|
|
fmt.Fprintln(w, "mac:", mac, "uuid", uuid, "hostname:", umap[uuid])
|
|
}
|
|
if err != nil {
|
|
fmt.Fprintln(w, "ValidateDroplets() failed:", err)
|
|
}
|
|
}
|
|
|
|
// list running droplets and droplets that should be running
|
|
func dumpDroplets(w http.ResponseWriter) {
|
|
for i, d := range me.cluster.Droplets {
|
|
var macs []string
|
|
for _, n := range d.Networks {
|
|
macs = append(macs, n.Mac)
|
|
}
|
|
arp := strings.Join(macs, " ")
|
|
if d.CurrentState == pb.DropletState_ON {
|
|
fmt.Fprintln(w, i, "droplet:", arp, d.Hostname, d.StartState, d.CurrentState)
|
|
continue
|
|
}
|
|
if d.StartState == pb.DropletState_ON {
|
|
fmt.Fprintln(w, i, "droplet:", arp, d.Hostname, d.StartState, d.CurrentState, "(should be on)")
|
|
}
|
|
}
|
|
}
|
|
|
|
// status of the hypervisors
|
|
func dumpHypervisors(w http.ResponseWriter) {
|
|
for _, h := range me.hypers {
|
|
// lastpoll time.Time // the last time the hypervisor polled
|
|
dur := time.Since(h.lastpoll)
|
|
tmp := shell.FormatDuration(dur)
|
|
fmt.Fprintln(w, h.pb.Hostname, "killcount =", h.killcount, "lastpoll:", tmp)
|
|
for name, t := range h.lastDroplets {
|
|
dur := time.Since(t)
|
|
tmp := shell.FormatDuration(dur)
|
|
d := findDroplet(name)
|
|
if d == nil {
|
|
fmt.Fprintln(w, "\t", h.pb.Hostname, "name =", name, "lastpoll:", tmp)
|
|
} else {
|
|
fmt.Fprintln(w, "\t", h.pb.Hostname, "name =", name, "lastpoll:", tmp, d.CurrentState)
|
|
}
|
|
}
|
|
}
|
|
}
|