Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 534 for Informer (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top