diff options
| author | Jeff Carr <[email protected]> | 2025-04-21 13:42:09 -0500 |
|---|---|---|
| committer | Jeff Carr <[email protected]> | 2025-04-21 20:54:39 -0500 |
| commit | 4121e66e01f5b314e4fe4999d61550fbbbc07946 (patch) | |
| tree | 02ce2190b7dee4525e5aae87303ebdbbbde87617 /doDroplet.go | |
| parent | a4dd085a47b0aa04d9d4475254fac08f62e0bc82 (diff) | |
attempting the cluster protobuf
Diffstat (limited to 'doDroplet.go')
| -rw-r--r-- | doDroplet.go | 11 |
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 { |
