Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for InformerFor (0.18 sec)

  1. pkg/kube/informerfactory/factory.go

    	// Start initializes all requested informers. They are handled in goroutines
    	// which run until the stop channel gets closed.
    	Start(stopCh <-chan struct{})
    
    	// InformerFor returns the SharedIndexInformer the provided type.
    	InformerFor(resource schema.GroupVersionResource, opts kubetypes.InformerOptions, newFunc NewInformerFunc) StartableInformer
    
    	// WaitForCacheSync blocks until all started informers' caches were synced
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. 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)
  3. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go

    	for informType, informer := range informers {
    		res[informType] = cache.WaitForCacheSync(stopCh, informer.HasSynced)
    	}
    	return res
    }
    
    // InformerFor returns the SharedIndexInformer for obj using an internal
    // client.
    func (f *sharedInformerFactory) InformerFor(obj runtime.Object, newFunc internalinterfaces.NewInformerFunc) cache.SharedIndexInformer {
    	f.lock.Lock()
    	defer f.lock.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go

    	for informType, informer := range informers {
    		res[informType] = cache.WaitForCacheSync(stopCh, informer.HasSynced)
    	}
    	return res
    }
    
    // InformerFor returns the SharedIndexInformer for obj using an internal
    // client.
    func (f *sharedInformerFactory) InformerFor(obj runtime.Object, newFunc internalinterfaces.NewInformerFunc) cache.SharedIndexInformer {
    	f.lock.Lock()
    	defer f.lock.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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