Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for InformerFor (0.28 sec)

  1. pkg/config/schema/kubeclient/common.go

    	reg := typemap.Get[TypeRegistration[T]](registerTypes)
    	if reg != nil {
    		// This is registered type
    		tr := *reg
    		return c.Informers().InformerFor(tr.GetGVR(), opts, func() cache.SharedIndexInformer {
    			inf := cache.NewSharedIndexInformer(
    				tr.ListWatch(c, opts),
    				tr.Object(),
    				0,
    				cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 16:38:40 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  2. pkg/config/schema/codegen/templates/clients.go.tmpl

    		}
    	{{- end }}
    {{- end }}
      default:
        panic(fmt.Sprintf("Unknown type %v", g))
    	}
    	return c.Informers().InformerFor(g, opts, func() cache.SharedIndexInformer {
    		inf := cache.NewSharedIndexInformer(
    			&cache.ListWatch{
    				ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
    					options.FieldSelector = opts.FieldSelector
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 13:57:51 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. pkg/scheduler/scheduler.go

    // in-place podInformer.
    func NewInformerFactory(cs clientset.Interface, resyncPeriod time.Duration) informers.SharedInformerFactory {
    	informerFactory := informers.NewSharedInformerFactory(cs, resyncPeriod)
    	informerFactory.InformerFor(&v1.Pod{}, newPodInformer)
    	return informerFactory
    }
    
    func buildExtenders(logger klog.Logger, extenders []schedulerapi.Extender, profiles []schedulerapi.KubeSchedulerProfile) ([]framework.Extender, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  4. pkg/config/schema/kubeclient/resources.gen.go

    			return c.Istio().NetworkingV1alpha3().WorkloadGroups(opts.Namespace).Watch(context.Background(), options)
    		}
    	default:
    		panic(fmt.Sprintf("Unknown type %v", g))
    	}
    	return c.Informers().InformerFor(g, opts, func() cache.SharedIndexInformer {
    		inf := cache.NewSharedIndexInformer(
    			&cache.ListWatch{
    				ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 13:57:51 UTC 2024
    - 31.1K bytes
    - Viewed (0)
Back to top