func()

in readers/apiserver/watchlist/internal/watchlist/watchlist.go [348:379]


func (r *Reader) createRBACWatcher(ctx context.Context) []spawnWatcher {
	return []spawnWatcher{
		func(options metav1.ListOptions) (watch.Interface, error) {
			wi, err := r.clientset.RbacV1().Roles(metav1.NamespaceAll).Watch(ctx, options)
			if err != nil {
				return nil, err
			}
			return wi, nil
		},
		func(options metav1.ListOptions) (watch.Interface, error) {
			wi, err := r.clientset.RbacV1().RoleBindings(metav1.NamespaceAll).Watch(ctx, options)
			if err != nil {
				return nil, err
			}
			return wi, nil
		},
		func(options metav1.ListOptions) (watch.Interface, error) {
			wi, err := r.clientset.RbacV1().ClusterRoles().Watch(ctx, options)
			if err != nil {
				return nil, err
			}
			return wi, nil
		},
		func(options metav1.ListOptions) (watch.Interface, error) {
			wi, err := r.clientset.RbacV1().ClusterRoleBindings().Watch(ctx, options)
			if err != nil {
				return nil, err
			}
			return wi, nil
		},
	}
}