Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for InformerFor (0.24 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. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go

    // SharedInformerFactory a small interface to allow for adding an informer without an import cycle
    type SharedInformerFactory interface {
    	Start(stopCh <-chan struct{})
    	InformerFor(obj runtime.Object, newFunc NewInformerFunc) cache.SharedIndexInformer
    }
    
    // TweakListOptionsFunc is a function that transforms a v1.ListOptions.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 16 22:25:28 UTC 2018
    - 1.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go

    // SharedInformerFactory a small interface to allow for adding an informer without an import cycle
    type SharedInformerFactory interface {
    	Start(stopCh <-chan struct{})
    	InformerFor(obj runtime.Object, newFunc NewInformerFunc) cache.SharedIndexInformer
    }
    
    // TweakListOptionsFunc is a function that transforms a v1.ListOptions.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 16 22:25:28 UTC 2018
    - 1.4K bytes
    - Viewed (0)
  7. 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)
  8. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1/example.go

    }
    
    func (f *exampleInformer) Informer() cache.SharedIndexInformer {
    	return f.factory.InformerFor(&crv1.Example{}, f.defaultInformer)
    }
    
    func (f *exampleInformer) Lister() v1.ExampleLister {
    	return v1.NewExampleLister(f.Informer().GetIndexer())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1/customresourcedefinition.go

    }
    
    func (f *customResourceDefinitionInformer) Informer() cache.SharedIndexInformer {
    	return f.factory.InformerFor(&apiextensionsv1.CustomResourceDefinition{}, f.defaultInformer)
    }
    
    func (f *customResourceDefinitionInformer) Lister() v1.CustomResourceDefinitionLister {
    	return v1.NewCustomResourceDefinitionLister(f.Informer().GetIndexer())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.8K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1beta1/customresourcedefinition.go

    }
    
    func (f *customResourceDefinitionInformer) Informer() cache.SharedIndexInformer {
    	return f.factory.InformerFor(&apiextensionsv1beta1.CustomResourceDefinition{}, f.defaultInformer)
    }
    
    func (f *customResourceDefinitionInformer) Lister() v1beta1.CustomResourceDefinitionLister {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.9K bytes
    - Viewed (0)
Back to top