diff options
| author | Jeff Carr <[email protected]> | 2024-10-26 20:47:44 -0500 |
|---|---|---|
| committer | Jeff Carr <[email protected]> | 2024-10-26 20:47:44 -0500 |
| commit | 9a0ebc03482ea7ead02c82e7f4e0f1d40e121005 (patch) | |
| tree | 11dd3d8228c89820d34b4d4bdfcc520130ae797c | |
| parent | 170f548a619b0380acb8137f24ffce0478e0b753 (diff) | |
only knows about protobufs
Signed-off-by: Jeff Carr <[email protected]>
| -rw-r--r-- | http.go | 21 | ||||
| -rw-r--r-- | main.go | 20 | ||||
| -rw-r--r-- | start.go | 2 | ||||
| -rw-r--r-- | structs.go | 9 |
4 files changed, 23 insertions, 29 deletions
@@ -67,6 +67,25 @@ func okHandler(w http.ResponseWriter, r *http.Request) { return } + if tmp == "/cluster" { + log.Info("/cluster jcarr actually doing START") + fmt.Fprintln(w, "/cluster jcarr actually doing START") + var c *pb.Cluster + c = new(pb.Cluster) + + fmt.Fprintln(w, "START len(msg) =", len(msg)) + err = c.UnmarshalJSON(msg) + if err != nil { + fmt.Fprintln(w, "START FAILED") + fmt.Fprintln(w, "error =", err) + } + for _, dir := range c.Dirs { + log.Info("append dir", dir) + fmt.Fprintln(w, "append dir", dir) + me.dirs = append(me.dirs, dir) + } + } + if tmp == "/start" { log.Info("/start jcarr actually doing START") fmt.Fprintln(w, "/start jcarr actually doing START") @@ -93,7 +112,7 @@ func okHandler(w http.ResponseWriter, r *http.Request) { fmt.Fprintln(w, "START len(msg) =", len(msg)) err = d.UnmarshalJSON(msg) if d.Hostname == "" { - fmt.Fprintln(w,"START hostname is blank") + fmt.Fprintln(w, "START hostname is blank") log.Info("START hostname is blank") return } @@ -23,7 +23,6 @@ import ( "github.com/digitalocean/go-qemu/hypervisor" "go.wit.com/dev/alexflint/arg" - pb "go.wit.com/lib/protobuf/virtbuf" "go.wit.com/log" ) @@ -48,25 +47,6 @@ func main() { os.Exit(0) } - me.cluster = new(pb.Cluster) - if err := me.cluster.ConfigLoad(); err != nil { - log.Info("config file error:", err) - os.Exit(0) - } - - for i, e := range me.cluster.Events { - log.Info("Event", i, e) - } - for i, d := range me.cluster.Droplets { - log.Info("Event", i, d.Hostname) - } - - if argv.Start != "" { - d := me.cluster.FindDroplet(argv.Start) - newStart(argv.Start, d) - os.Exit(0) - } - log.DaemonMode(true) // fmt.Printf("\nConnecting to %s://%s\n", *network, *address) @@ -26,7 +26,7 @@ func newStart(start string, d *pb.Droplet) error { newAddXml(domcfg, "spice") newAddXml(domcfg, "qcow") - return virtigoxml.GenerateDropletXml(me.cluster, d, domcfg, start) + return virtigoxml.GenerateDropletXml(me.dirs, d, domcfg, start) } func newAddXml(domcfg *libvirtxml.Domain, filename string) error { @@ -1,14 +1,9 @@ package main -import ( - "go.wit.com/lib/protobuf/virtbuf" -) - var me Virtigod // this app's variables type Virtigod struct { - cluster *virtbuf.Cluster - // droplets *virtbuf.Droplets - // events *virtbuf.Events + dirs []string + // cluster *virtbuf.Cluster } |
