- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for InformerFor (0.59 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1beta1/customresourcedefinition.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 08 02:16:47 UTC 2020 - 3.9K bytes - Viewed (0)