func()

in readers/apiserver/watchlist/internal/watchlist/watchlist.go [336:346]


func (r *Reader) createPersistentVolumesWatcher(ctx context.Context) []spawnWatcher {
	return []spawnWatcher{
		func(options metav1.ListOptions) (watch.Interface, error) {
			wi, err := r.clientset.CoreV1().PersistentVolumes().Watch(ctx, options)
			if err != nil {
				return nil, err
			}
			return wi, nil
		},
	}
}