- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 401 for Informer (0.22 sec)
-
pkg/scheduler/framework/plugins/testing/testing.go
// empty namespace), and start informer factory. func SetupPluginWithInformers( ctx context.Context, tb testing.TB, pf frameworkruntime.PluginFactory, config runtime.Object, sharedLister framework.SharedLister, objs []runtime.Object, ) framework.Plugin { objs = append([]runtime.Object{&v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: ""}}}, objs...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
var _ ControllerRunner = &ConfigMapCAController{} // NewDynamicCAFromConfigMapController returns a CAContentProvider based on a configmap that automatically reloads content. // It is near-realtime via an informer. func NewDynamicCAFromConfigMapController(purpose, namespace, name, key string, kubeClient kubernetes.Interface) (*ConfigMapCAController, error) { if len(purpose) == 0 { return nil, fmt.Errorf("missing purpose for ca bundle")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
podIndexer := podInformer.Informer().GetIndexer() tm := &Controller{ name: controllerName, client: c, broadcaster: eventBroadcaster, recorder: recorder, podLister: podInformer.Lister(), podListerSynced: podInformer.Informer().HasSynced, nodeLister: nodeInformer.Lister(), nodeListerSynced: nodeInformer.Informer().HasSynced,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
return nil } logger := klog.FromContext(ctx) if err != nil { logger.V(5).Info("Error getting PVC from informer", "pvcKey", key, "err", err) return err } pv, err := expc.getPersistentVolume(ctx, pvc) if err != nil { logger.V(5).Info("Error getting Persistent Volume for PVC from informer", "pvcKey", key, "pvcUID", pvc.UID, "err", err) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer_test.go
t.Errorf("expected clientset to be initialized") } } // TestWantsExternalKubeInformerFactory ensures that the informer factory is injected // when the WantsExternalKubeInformerFactory interface is implemented by a plugin. func TestWantsExternalKubeInformerFactory(t *testing.T) { cs := &fake.Clientset{} sf := informers.NewSharedInformerFactory(cs, time.Duration(1)*time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
}) dc.pdbLister = pdbInformer.Lister() dc.pdbListerSynced = pdbInformer.Informer().HasSynced dc.rcLister = rcInformer.Lister() dc.rcListerSynced = rcInformer.Informer().HasSynced dc.rsLister = rsInformer.Lister() dc.rsListerSynced = rsInformer.Informer().HasSynced dc.dLister = dInformer.Lister() dc.dListerSynced = dInformer.Informer().HasSynced dc.ssLister = ssInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
} _, _ = serviceCIDRInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addServiceCIDR, UpdateFunc: c.updateServiceCIDR, DeleteFunc: c.deleteServiceCIDR, }) c.serviceCIDRLister = serviceCIDRInformer.Lister() c.serviceCIDRsSynced = serviceCIDRInformer.Informer().HasSynced _, _ = ipAddressInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
clusterRolesSynced: clusterRoleInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "ClusterRoleAggregator", }, ), } c.syncHandler = c.syncClusterRole clusterRoleInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
e.serviceAccountSynced = serviceAccounts.Informer().HasSynced serviceAccounts.Informer().AddEventHandlerWithResyncPeriod( cache.ResourceEventHandlerFuncs{ AddFunc: e.queueServiceAccountSync, UpdateFunc: e.queueServiceAccountUpdateSync, DeleteFunc: e.queueServiceAccountSync, }, options.ServiceAccountResync, ) secretCache := secrets.Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
plugin/pkg/admission/security/podsecurity/admission.go
}, }, nil } // SetExternalKubeInformerFactory registers an informer func (p *Plugin) SetExternalKubeInformerFactory(f informers.SharedInformerFactory) { namespaceInformer := f.Core().V1().Namespaces() p.namespaceLister = namespaceInformer.Lister() p.podLister = f.Core().V1().Pods().Lister() p.SetReadyFunc(namespaceInformer.Informer().HasSynced) p.updateDelegate() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 08:49:11 UTC 2023 - 8.5K bytes - Viewed (0)