frodovdr/vsphere-influxdb-go
1
0
Fork 0
mirror of https://github.com/Oxalide/vsphere-influxdb-go.git synced 2023-10-10 11:36:51 +00:00
Code Issues Releases Wiki Activity

Fix respool* casing

Browse Source
This commit is contained in:
ADO
2017-05-24 14:43:35 +02:00
parent 9794d33b2f
commit eba6b58ffc
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
vsphere-influxdb.go
View File

@@ -263,9 +263,9 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
hostRefs = append(hostRefs, mor) hostRefs = append(hostRefs, mor)
newMors = append(newMors, mor) newMors = append(newMors, mor)
} else if mor.Type == "ClusterComputeResource" { } else if mor.Type == "ClusterComputeResource" {
clusterRefs = append(cluster_refs, mor) clusterRefs = append(clusterRefs, mor)
} else if mor.Type == "ResourcePool" { } else if mor.Type == "ResourcePool" {
respoolRefs = append(respool_refs, mor) respoolRefs = append(respoolRefs, mor)
} }
} }
// Copy the mors without the clusters // Copy the mors without the clusters
@@ -306,7 +306,7 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
stdlog.Println("going inside ResourcePools") stdlog.Println("going inside ResourcePools")
} }
var respool []mo.ResourcePool var respool []mo.ResourcePool
err = pc.Retrieve(ctx, respool_refs, []string{"name", "config", "vm"}, &respool) err = pc.Retrieve(ctx, respoolRefs, []string{"name", "config", "vm"}, &respool)
if err != nil { if err != nil {
fmt.Println(err) fmt.Println(err)
return return
@@ -364,10 +364,10 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
} }
// Retrieve properties for the pools // Retrieve properties for the pools
respool_summary := make(map[types.ManagedObjectReference]map[string]string) respoolSummary := make(map[types.ManagedObjectReference]map[string]string)
for _, pools := range rpmo { for _, pools := range rpmo {
respool_summary[pools.Self] = make(map[string]string) respoolSummary[pools.Self] = make(map[string]string)
respool_summary[pools.Self]["name"] = pools.Summary.GetResourcePoolSummary().Name respoolSummary[pools.Self]["name"] = pools.Summary.GetResourcePoolSummary().Name
} }
// Retrieve properties for the hosts // Retrieve properties for the hosts
@@ -513,7 +513,7 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
} }
} }
if summary, ok := respool_summary[pem.Entity]; ok { if summary, ok := respoolSummary[pem.Entity]; ok {
for key, tag := range summary { for key, tag := range summary {
tags[key] = tag tags[key] = tag
} }
@@ -604,7 +604,7 @@ func (vcenter *VCenter) Query(config Configuration, InfluxDBClient influxclient.
} }
var respool []mo.ResourcePool var respool []mo.ResourcePool
err = pc.Retrieve(ctx, respool_refs, []string{"name", "config", "vm"}, &respool) err = pc.Retrieve(ctx, respoolRefs, []string{"name", "config", "vm"}, &respool)
if err != nil { if err != nil {
errlog.Println(err) errlog.Println(err)
continue continue