- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 534 for Informer (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/informer.go
// as they will be casted. func NewInformer[T runtime.Object](informe cache.SharedIndexInformer) Informer[T] { return informer[T]{ SharedIndexInformer: informe, lister: NewLister[T](informe.GetIndexer()), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 1.2K bytes - Viewed (0) -
pkg/kube/krt/informer.go
} return a } var _ internalCollection[controllers.Object] = &informer[controllers.Object]{} func (i *informer[I]) _internalHandler() {} func (i *informer[I]) Synced() Syncer { return channelSyncer{ name: i.collectionName, synced: i.synced, } } // nolint: unused // (not true, its to implement an interface) func (i *informer[I]) dump() { i.log.Errorf(">>> BEGIN DUMP")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/kube/informerfactory/factory.go
for informerKey, informer := range f.informers { if f.startedInformers.Contains(informerKey) { informers = append(informers, informer.informer) } } return informers }() for _, informer := range informers { if !cache.WaitForCacheSync(stopCh, informer.HasSynced) { return false } } return true } func (f *informerFactory) Shutdown() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1/example.go
namespace string } // NewExampleInformer constructs a new informer for Example type. // Always prefer using an informer factory to get a shared informer instead of getting an independent // one. This reduces memory footprint and number of connections to the server. func NewExampleInformer(client versioned.Interface, namespace string, resyncPeriod time.Duration, indexers cache.Indexers) cache.SharedIndexInformer {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 08 02:16:47 UTC 2020 - 3.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/pod_controller.go
q.Push(func() error { return handlers.deleted(pod) }) }, }) return &podController{ q: q, informer: informer, } } func (c *podController) Run(stop <-chan struct{}) { go c.informer.Run(stop) kube.WaitForCacheSync("pod controller", stop, c.informer.HasSynced) c.q.Run(stop) } func (c *podController) HasSynced() bool { return c.q.HasSynced() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 09 02:22:47 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/generic.go
// sharedInformers based on type type GenericInformer interface { Informer() cache.SharedIndexInformer Lister() cache.GenericLister } type genericInformer struct { informer cache.SharedIndexInformer resource schema.GroupResource } // Informer returns the SharedIndexInformer. func (f *genericInformer) Informer() cache.SharedIndexInformer { return f.informer } // Lister returns the GenericLister.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 08 09:52:48 UTC 2018 - 2K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner_test.go
options := DefaultSignerOptions() cl := fake.NewSimpleClientset() informers := informers.NewSharedInformerFactory(fake.NewSimpleClientset(), controller.NoResyncPeriodFunc()) secrets := informers.Core().V1().Secrets() configMaps := informers.Core().V1().ConfigMaps() bsc, err := NewSigner(cl, secrets, configMaps, options) if err != nil { return nil, nil, nil, nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go
if exists { return informer } resyncPeriod, exists := f.customResync[informerType] if !exists { resyncPeriod = f.defaultResync } informer = newFunc(f.client, resyncPeriod) informer.SetTransform(f.transform) f.informers[informerType] = informer return informer } // SharedInformerFactory provides shared informers for resources in all known
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
if exists { return informer } resyncPeriod, exists := f.customResync[informerType] if !exists { resyncPeriod = f.defaultResync } informer = newFunc(f.client, resyncPeriod) informer.SetTransform(f.transform) f.informers[informerType] = informer return informer } // SharedInformerFactory provides shared informers for resources in all known
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 9K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache_test.go
// Some error cases (don't occur in practice). informer.add(1) verify(ktesting.WithStep(tCtx, "after nop add"), cache, key, newObj, newObj) informer.add(nil) verify(ktesting.WithStep(tCtx, "after nil add"), cache, key, newObj, newObj) informer.update(oldObj) verify(ktesting.WithStep(tCtx, "after nop update"), cache, key, newObj, newObj) informer.update(nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 9.5K bytes - Viewed (0)