nathan/go-events
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix vm not found
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Nathan Coad
2024-04-08 15:41:11 +10:00
parent c2df4ea3af
commit 2f80601a40
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
main.go
View File

@@ -188,7 +188,7 @@ func getVmInCluster(name string, cluster types.ManagedObjectReference) mo.Virtua
cv, _ := m.CreateContainerView(ctx, cluster, []string{"VirtualMachine"}, true) cv, _ := m.CreateContainerView(ctx, cluster, []string{"VirtualMachine"}, true)
var vms []mo.VirtualMachine var vms []mo.VirtualMachine
log.Printf("Searching for VM '%s'\n", name) log.Printf("Searching for VM '%s' in cluster '%v'\n", name, cluster.Reference().Value)
err := cv.Retrieve(ctx, []string{"VirtualMachine"}, []string{"summary", "name"}, &vms) err := cv.Retrieve(ctx, []string{"VirtualMachine"}, []string{"summary", "name"}, &vms)
if err != nil { if err != nil {
log.Printf("Failed searching for VM %s : %s\n", name, err) log.Printf("Failed searching for VM %s : %s\n", name, err)
@@ -331,6 +331,12 @@ func main() {
vm := getVmInCluster(event.Vm.Name, cluster.Reference()) vm := getVmInCluster(event.Vm.Name, cluster.Reference())
//vm := getVM(event.Vm.Name) //vm := getVM(event.Vm.Name)
// If we couldn't find the vm then skip this event
if len(vm.Reference().String()) == 0 {
log.Printf("No VM matching string '%s' found in cluster '%s'\n", event.Vm.Name, cluster.Reference())
continue
}
// Use VmDisconnectedEvent to see which host this VM was on // Use VmDisconnectedEvent to see which host this VM was on
vmDisconnectedEvents := getEvents([]string{"VmDisconnectedEvent"}, []types.ManagedObjectReference{vm.Reference()}, *begin, *end) vmDisconnectedEvents := getEvents([]string{"VmDisconnectedEvent"}, []types.ManagedObjectReference{vm.Reference()}, *begin, *end)
log.Printf("Retrieved '%d' VmDisconnectedEvent events.\n", len(vmDisconnectedEvents)) log.Printf("Retrieved '%d' VmDisconnectedEvent events.\n", len(vmDisconnectedEvents))