compiles after protobuf changes
Signed-off-by: Jeff Carr <jcarr@wit.com>
This commit is contained in:
parent
748f9b4608
commit
ec9d464997
4
event.go
4
event.go
|
@ -76,7 +76,9 @@ func (h *HyperT) start(d *pb.Droplet) (bool, string) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func findDroplet(name string) *pb.Droplet {
|
func findDroplet(name string) *pb.Droplet {
|
||||||
for _, d := range me.cluster.Droplets {
|
loop := me.cluster.DropletsAll() // get the list of droplets
|
||||||
|
for loop.Scan() {
|
||||||
|
d := loop.Droplet()
|
||||||
if d.Hostname == name {
|
if d.Hostname == name {
|
||||||
return d
|
return d
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,7 +20,7 @@ func (b *virtigoT) Enable() {
|
||||||
|
|
||||||
// this app's variables
|
// this app's variables
|
||||||
type virtigoT struct {
|
type virtigoT struct {
|
||||||
cluster *pb.Cluster // basic cluster settings
|
cluster *pb.NewCluster // basic cluster settings
|
||||||
hmap map[*pb.Hypervisor]*HyperT // map to the local struct
|
hmap map[*pb.Hypervisor]*HyperT // map to the local struct
|
||||||
names []string
|
names []string
|
||||||
hypers []*HyperT
|
hypers []*HyperT
|
||||||
|
|
26
watchdog.go
26
watchdog.go
|
@ -2,9 +2,6 @@ package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
pb "go.wit.com/lib/protobuf/virtbuf"
|
|
||||||
"go.wit.com/log"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// timeFunction takes a function as an argument and returns the execution time.
|
// timeFunction takes a function as an argument and returns the execution time.
|
||||||
|
@ -13,26 +10,3 @@ func TimeFunction(f func()) time.Duration {
|
||||||
f() // Execute the function
|
f() // Execute the function
|
||||||
return time.Since(startTime) // Calculate the elapsed time
|
return time.Since(startTime) // Calculate the elapsed time
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *HyperT) sendDirs() {
|
|
||||||
url := "http://" + h.pb.Hostname + ":2520/cluster"
|
|
||||||
var msg string
|
|
||||||
var data []byte
|
|
||||||
|
|
||||||
var c *pb.Cluster
|
|
||||||
c = new(pb.Cluster)
|
|
||||||
for _, dir := range me.cluster.Dirs {
|
|
||||||
c.Dirs = append(c.Dirs, dir)
|
|
||||||
}
|
|
||||||
msg = c.FormatJSON()
|
|
||||||
data = []byte(msg) // Convert the string to []byte
|
|
||||||
req, err := httpPost(url, data)
|
|
||||||
if err != nil {
|
|
||||||
log.Info("error:", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
// log.Info("http post url:", url)
|
|
||||||
// log.Info("http post data:", msg)
|
|
||||||
|
|
||||||
log.Info("EVENT start droplet response: " + string(req))
|
|
||||||
}
|
|
||||||
|
|
Loading…
Reference in New Issue