bugfix

main.go

@@ -91,14 +91,14 @@ func getEvents(eventTypes []string, entities []types.ManagedObjectReference, beg
 	}
 
 	for _, e := range entities {
-		// Only log the entity we're filtering if it isn't the vcenter root
+		if e == root {
-		if e != root {
+			log.Printf("getEvents leaving event filter spec at root\n")
+		} else { // Only log the entity we're filtering if it isn't the vcenter root
 			log.Printf("getEvents setting entity '%v' to filter\n", e)
-		}
+			filter.Entity = &types.EventFilterSpecByEntity{
-
+				Entity:    e,
-		filter.Entity = &types.EventFilterSpecByEntity{
+				Recursion: types.EventFilterSpecRecursionOptionAll,
-			Entity:    e,
+			}
-			Recursion: types.EventFilterSpecRecursionOptionAll,
 		}
 
 		collector, err := m.CreateCollectorForEvents(ctx, filter)
@@ -315,6 +315,7 @@ func main() {
 			return hostFailures[i].CreatedTime.Before(hostFailures[j].CreatedTime)
 		})
 
+		log.Printf("Searching for all vm disconnected events\n")
 		allVmDisconnectedEvents := getEvents([]string{"VmDisconnectedEvent"}, []types.ManagedObjectReference{}, *begin, *end)
 		log.Printf("Retrieved '%d' VmDisconnectedEvent events from '%s' to '%s'.\n", len(allVmDisconnectedEvents), begin.String(), end.String())
 		if len(allVmDisconnectedEvents) > 0 {