- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 218 for Informer (0.37 sec)
-
pkg/scheduler/apis/config/types.go
Extenders []Extender // DelayCacheUntilActive specifies when to start caching. If this is true and leader election is enabled, // the scheduler will wait to fill informer caches until it is the leader. Doing so will have slower // failover with the benefit of lower memory overhead while waiting to become leader. // Defaults to false. DelayCacheUntilActive bool }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 18:47:23 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
classLister: storageClassInformer.Lister(), nodeLister: nodeInformer.Lister(), csiNodeLister: csiNodeInformer.Lister(), pvcCache: NewPVCAssumeCache(logger, pvcInformer.Informer()), pvCache: NewPVAssumeCache(logger, pvInformer.Informer()), bindTimeout: bindTimeout, translator: csitrans.New(), } b.csiDriverLister = capacityCheck.CSIDriverInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
} func (vm *volumeManager) Run(sourcesReady config.SourcesReady, stopCh <-chan struct{}) { defer runtime.HandleCrash() if vm.kubeClient != nil { // start informer for CSIDriver go vm.volumePluginMgr.Run(stopCh) } go vm.desiredStateOfWorldPopulator.Run(sourcesReady, stopCh) klog.V(2).InfoS("The desired_state_of_world populator starts")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go
} for _, pv := range item.pvs { client.CoreV1().PersistentVolumes().Create(ctx, pv, metav1.CreateOptions{}) } t.Log("Start informer factory after initialization") informerFactory.Start(ctx.Done()) t.Log("Wait for all started informers' cache were synced") informerFactory.WaitForCacheSync(ctx.Done()) t.Log("Verify") p := pl.(*VolumeBinding)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 32K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
logger.Error(err, "Error scheduling pod; retrying", "pod", klog.KObj(pod)) } // Check if the Pod exists in informer cache. podLister := fwk.SharedInformerFactory().Core().V1().Pods().Lister() cachedPod, e := podLister.Pods(pod.Namespace).Get(pod.Name) if e != nil { logger.Info("Pod doesn't exist in informer cache", "pod", klog.KObj(pod), "err", e)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/ipallocator_test.go
"k8s.io/apimachinery/pkg/util/sets" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" k8stesting "k8s.io/client-go/testing" "k8s.io/component-base/metrics/testutil" api "k8s.io/kubernetes/pkg/apis/core" netutils "k8s.io/utils/net" ) func newTestAllocator(cidr *net.IPNet) (*Allocator, error) { client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0*time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jun 25 13:14:46 UTC 2023 - 24.2K bytes - Viewed (0) -
pkg/controller/deployment/util/deployment_util_test.go
} if t1.Labels == nil || t2.Labels == nil { t.Errorf("%q%s: unexpected labels becomes nil", test.Name, reverseString) } } runTest(&test.former, &test.latter, false) // Test the same case in reverse order runTest(&test.latter, &test.former, true) }) } } func TestFindNewReplicaSet(t *testing.T) { now := metav1.Now() later := metav1.Time{Time: now.Add(time.Minute)}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 37.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler_test.go
testHandlerConversion(t, false) } func testHandlerConversion(t *testing.T, enableWatchCache bool) { cl := fake.NewSimpleClientset() informers := informers.NewSharedInformerFactory(fake.NewSimpleClientset(), 0) crdInformer := informers.Apiextensions().V1().CustomResourceDefinitions() server, storageConfig := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) defer server.Terminate(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 15:27:39 UTC 2023 - 34.6K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission.go
p.dynamicResourceAllocationEnabled = featureGates.Enabled(features.DynamicResourceAllocation) } // SetExternalKubeInformerFactory registers an informer factory into Plugin func (p *Plugin) SetExternalKubeInformerFactory(f informers.SharedInformerFactory) { p.podsGetter = f.Core().V1().Pods().Lister() p.nodesGetter = f.Core().V1().Nodes().Lister() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 23.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
} } return obj, nil } versionedClient := rootClientBuilder.ClientOrDie("shared-informers") sharedInformers := informers.NewSharedInformerFactoryWithOptions(versionedClient, ResyncPeriod(s)(), informers.WithTransform(trim)) metadataClient := metadata.NewForConfigOrDie(rootClientBuilder.ConfigOrDie("metadata-informers"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0)