| 151 | } |
| 152 | |
| 153 | func getEventsFromStore(store ObjectRevisionStore) func() ([]client.Object, error) { |
| 154 | return func() ([]client.Object, error) { |
| 155 | eventRevisionMap := store.List(&eventGVK) |
| 156 | var objects []client.Object |
| 157 | for _, revisionMap := range eventRevisionMap { |
| 158 | revision := int64(-1) |
| 159 | for rev := range revisionMap { |
| 160 | if rev > revision { |
| 161 | revision = rev |
| 162 | } |
| 163 | } |
| 164 | if revision > -1 { |
| 165 | objects = append(objects, revisionMap[revision]) |
| 166 | } |
| 167 | } |
| 168 | return objects, nil |
| 169 | } |
| 170 | } |
| 171 | |
| 172 | func filterEvents(eventLister func() ([]client.Object, error), objectMap map[model.GVKNObjKey]client.Object) (map[model.GVKNObjKey]client.Object, error) { |
| 173 | eventList, err := eventLister() |