- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 111 for NewSharedInformerFactory (0.42 sec)
-
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
) func TestFindAndAddActivePods_FindAndRemoveDeletedPods(t *testing.T) { fakeVolumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t) fakeClient := &fake.Clientset{} fakeInformerFactory := informers.NewSharedInformerFactory(fakeClient, controller.NoResyncPeriodFunc()) fakePodInformer := fakeInformerFactory.Core().V1().Pods() fakesDSW := cache.NewDesiredStateOfWorld(fakeVolumePluginMgr) pod := &v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/resource_access_test.go
} for _, tc := range testcases { t.Run(tc.description, func(t *testing.T) { liveLookupCache := lru.New(1) kubeClient := fake.NewSimpleClientset(tc.clientInput...) informerFactory := informers.NewSharedInformerFactory(kubeClient, 0) accessor, _ := newQuotaAccessor() accessor.client = kubeClient accessor.lister = informerFactory.Core().V1().ResourceQuotas().Lister() accessor.liveLookupCache = liveLookupCache
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 13:54:56 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller_test.go
csr := &certificates.CertificateSigningRequest{ ObjectMeta: metav1.ObjectMeta{ Name: "test-csr", }, } client := fake.NewSimpleClientset(csr) informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(csr), controller.NoResyncPeriodFunc()) handler := func(ctx context.Context, csr *certificates.CertificateSigningRequest) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 15 03:26:08 UTC 2023 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/validating_webhook_manager_test.go
func TestGetValidatingWebhookConfig(t *testing.T) { // Build a test client that the admission plugin can use to look up the ValidatingWebhookConfiguration client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0) stop := make(chan struct{}) defer close(stop) manager := NewValidatingWebhookConfigurationManager(informerFactory) informerFactory.Start(stop) informerFactory.WaitForCacheSync(stop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 15:20:14 UTC 2023 - 9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/testing/testing.go
sharedLister framework.SharedLister, objs []runtime.Object, ) framework.Plugin { objs = append([]runtime.Object{&v1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: ""}}}, objs...) informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(objs...), 0) fh, err := frameworkruntime.NewFramework(ctx, nil, nil, frameworkruntime.WithSnapshotSharedLister(sharedLister), frameworkruntime.WithInformerFactory(informerFactory))
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/options/coreapi.go
if err != nil { return fmt.Errorf("failed to create Kubernetes clientset: %v", err) } config.ClientConfig = kubeconfig config.SharedInformerFactory = clientgoinformers.NewSharedInformerFactory(clientgoExternalClient, 10*time.Minute) return nil } func (o *CoreAPIOptions) Validate() []error { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 16:55:02 UTC 2022 - 2.7K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/test/utils.go
func FakeNodeInformer(fakeNodeHandler *testutil.FakeNodeHandler) coreinformers.NodeInformer { fakeClient := &fake.Clientset{} fakeInformerFactory := informers.NewSharedInformerFactory(fakeClient, controller.NoResyncPeriodFunc()) fakeNodeInformer := fakeInformerFactory.Core().V1().Nodes() for _, node := range fakeNodeHandler.Existing { fakeNodeInformer.Informer().GetStore().Add(node) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 06 00:10:39 UTC 2022 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/mutating_webhook_manager_test.go
func TestGetMutatingWebhookConfig(t *testing.T) { // Build a test client that the admission plugin can use to look up the MutatingWebhookConfiguration client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0) stop := make(chan struct{}) defer close(stop) manager := NewMutatingWebhookConfigurationManager(informerFactory).(*mutatingWebhookConfigurationManager) informerFactory.Start(stop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 15:20:14 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/volume/util/storageclass_test.go
classes: []*storagev1.StorageClass{sc4, sc5}, expect: sc4, }, } for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc()) for _, c := range tc.classes { informerFactory.Storage().V1().StorageClasses().Informer().GetStore().Add(c) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 18 14:18:11 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/kube/informerfactory/factory.go
// // Shutdown may be called multiple times, even concurrently. All such calls will // block until all goroutines have terminated. Shutdown() } // NewSharedInformerFactory constructs a new instance of informerFactory for all namespaces. func NewSharedInformerFactory() InformerFactory { return &informerFactory{ informers: map[informerKey]builtInformer{}, startedInformers: sets.New[informerKey](), } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0)