in internal/filter/types/watchlist/watchlist.go [112:131]
func (c *Filter) eventToEntry(event watch.Event, wasSnapShot bool) (data.Entry, error) {
var e data.Entry
var err error
if wasSnapShot {
e, err = data.NewEntry(event.Object, data.STWatchList, data.CTSnapshot)
} else {
switch event.Type {
case watch.Added:
e, err = data.NewEntry(event.Object, data.STWatchList, data.CTAdd)
case watch.Modified:
e, err = data.NewEntry(event.Object, data.STWatchList, data.CTUpdate)
case watch.Deleted:
e, err = data.NewEntry(event.Object, data.STWatchList, data.CTDelete)
default:
err = fmt.Errorf("unknown event type: %v", event.Type)
}
}
return e, err
}