summaryrefslogtreecommitdiff
path: root/doDroplet.go
diff options
context:
space:
mode:
Diffstat (limited to 'doDroplet.go')
-rw-r--r--doDroplet.go11
1 files changed, 7 insertions, 4 deletions
diff --git a/doDroplet.go b/doDroplet.go
index 8a7cafc..804897e 100644
--- a/doDroplet.go
+++ b/doDroplet.go
@@ -35,6 +35,9 @@ func doDroplet() (string, error) {
for c := range me.clusters.IterAll() {
var err error
admin := new(adminT)
+ if admin.cluster == nil {
+ admin.cluster = new(virtpb.Cluster)
+ }
me.cmap[c] = admin
log.Info("found in the config file", c.URL[0])
// a.makeClusterGroup(c)
@@ -48,15 +51,15 @@ func doDroplet() (string, error) {
log.Info("/DropletsPB Error:", err)
continue
} else {
- admin.droplets = new(virtpb.Droplets)
- if err := admin.droplets.Unmarshal(data); err != nil {
+ admin.cluster.Droplets = new(virtpb.Droplets)
+ if err := admin.cluster.Droplets.Unmarshal(data); err != nil {
log.Printf("DropletsPB Response len:%d\n", len(data))
log.Println("droplets marshal failed", err)
continue
}
}
log.Printf("Cluster Name: %s\n", c.Name)
- log.Printf("Number of Droplets: %d\n", admin.droplets.Len())
+ log.Printf("Number of Droplets: %d\n", admin.cluster.Droplets.Len())
if argv.Droplet.Name == "" {
return "", fmt.Errorf("--name droplet name was empty")
@@ -64,7 +67,7 @@ func doDroplet() (string, error) {
var found *virtpb.Droplets
found = virtpb.NewDroplets()
- all := admin.droplets.All()
+ all := admin.cluster.Droplets.All()
for all.Scan() {
vm := all.Next()
if argv.Droplet.Name == vm.Hostname {