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
},
}
}