package main import ( "fmt" "net/http" "time" pb "go.wit.com/lib/protobuf/virtbuf" "go.wit.com/log" ) /* debugging code to see the state of the cluster via http */ func dumpCluster(w http.ResponseWriter) { umap, macs, err := ValidateDroplets() 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, full bool) { loop := me.cluster.DropletsAll() // get the list of droplets for loop.Scan() { d := loop.Droplet() // this line in golang could replace 80 lines of COBOL header := d.SprintDumpHeader() + " " // check if this is a locally defined libvirt domain that needs to be imported if d.LocalOnly != "" { header += "(local)" } header += d.Hostname if d.Current.State == pb.DropletState_ON { // everything is as it should be with this vm fmt.Fprintln(w, header) continue } if d.StartState == pb.DropletState_ON { // this is supposed to be ON and needs to be turned on fmt.Fprintln(w, header, "(should be on). todo: start() here") continue } if d.LocalOnly != "" { // this is supposed to be ON and needs to be turned on fmt.Fprintln(w, header, "this libvirt/domain/xml needs to be imported") continue } if full { var filenames string for _, disk := range d.Disks { filenames += disk.Filename + " " } // this needs to be turned on fmt.Fprintln(w, header, filenames) } } } // status of the hypervisors func dumpHypervisors(w http.ResponseWriter) { var totalDroplets int var totalUnknownDroplets int for _, h := range me.hypers { dur := time.Since(h.lastpoll) tmp := pb.FormatDuration(dur) fmt.Fprintln(w, h.pb.Hostname, "killcount =", h.killcount, "lastpoll:", tmp) for name, _ := range h.lastDroplets { totalDroplets += 1 d := me.cluster.FindDropletByName(name) header := d.SprintDumpHeader() + " " if d == nil { totalUnknownDroplets += 1 } log.Info("\t", header, d.Hostname) } } if totalUnknownDroplets == 0 { fmt.Fprintln(w, "\tTotal Droplets", totalDroplets) } else { fmt.Fprintln(w, "\tTotal Droplets", totalDroplets, "total libvirt only droplets =", totalUnknownDroplets) } }