- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 228 for Informer (0.21 sec)
-
pkg/kubemark/controller.go
"sync" "time" apiv1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/labels" "k8s.io/client-go/informers" informersv1 "k8s.io/client-go/informers/core/v1" kubeclient "k8s.io/client-go/kubernetes" listersv1 "k8s.io/client-go/listers/core/v1" "k8s.io/client-go/tools/cache" "k8s.io/klog/v2" ) const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 17 23:02:17 UTC 2020 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
// NewCRDFinalizer creates a new CRDFinalizer. func NewCRDFinalizer( crdInformer informers.CustomResourceDefinitionInformer, crdClient client.CustomResourceDefinitionsGetter, crClientGetter CRClientGetter, ) *CRDFinalizer { c := &CRDFinalizer{ crdClient: crdClient, crdLister: crdInformer.Lister(), crdSynced: crdInformer.Informer().HasSynced, crClientGetter: crClientGetter,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
nc := NewNamespaceController(client, m.caBundleWatcher) // Start informers again. This fixes the case where informers for namespace do not start, // as we create them only after acquiring the leader lock // Note: stop here should be the overall pilot stop, NOT the leader election stop. We are // basically lazy loading the informer, if we stop it when we lose the lock we will never // recreate it again.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
crdLister: crdInformer.Lister(), crdsSynced: crdInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[schema.GroupVersion](), workqueue.TypedRateLimitingQueueConfig[schema.GroupVersion]{Name: "DiscoveryController"}, ), } crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller_test.go
} // Create client with initial data client := fake.NewSimpleClientset(clientObjs...) // Create informers informers := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) pvcInformer := informers.Core().V1().PersistentVolumeClaims() podInformer := informers.Core().V1().Pods() // Create the controller logger, _ := ktesting.NewTestContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 15.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_dispatcher.go
} // If the param informer for this admission policy has not yet // had time to perform an initial listing, don't attempt to use // it. timeoutCtx, cancel := context.WithTimeout(context.Background(), 1*time.Second) defer cancel() if !cache.WaitForCacheSync(timeoutCtx.Done(), paramInformer.Informer().HasSynced) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 12.1K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
scrt := c.secrets.Get(key.Name, key.Namespace) if scrt != nil { log.Debugf("secret %s exists in informer cache, processing it", key) if err := c.addSecret(key, scrt); err != nil { return fmt.Errorf("error adding secret %s: %v", key, err) } } else { log.Debugf("secret %s does not exist in informer cache, deleting it", key) c.deleteSecret(key.String()) } remoteClusters.Record(float64(c.cs.Len()))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
), } logger := klog.FromContext(ctx) jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { tc.addJob(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { tc.updateJob(logger, oldObj, newObj) }, }) tc.jLister = jobInformer.Lister() tc.jListerSynced = jobInformer.Informer().HasSynced tc.clock = clock.RealClock{} return tc
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller_test.go
} informers := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) secretInformer := informers.Core().V1().Secrets().Informer() secrets := secretInformer.GetStore() serviceAccounts := informers.Core().V1().ServiceAccounts().Informer().GetStore()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 21.5K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) serviceCIDRInformer := informerFactory.Networking().V1alpha1().ServiceCIDRs() cidrStore := serviceCIDRInformer.Informer().GetStore() for _, obj := range cidrs { err := cidrStore.Add(obj) if err != nil { t.Fatal(err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0)