- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 39 for NewSharedInformerFactory (1.29 sec)
-
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) -
pkg/scheduler/framework/plugins/helper/spread_test.go
"k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" st "k8s.io/kubernetes/pkg/scheduler/testing" ) func TestGetPodServices(t *testing.T) { fakeInformerFactory := informers.NewSharedInformerFactory(&fake.Clientset{}, 0*time.Second) var services []*v1.Service for i := 0; i < 3; i++ { service := &v1.Service{ ObjectMeta: metav1.ObjectMeta{ Name: fmt.Sprintf("service-%d", i),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 17:48:55 UTC 2022 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/max_seats_test.go
expectedMaxSeats: 5, }, } for _, testcase := range testcases { t.Run(testcase.name, func(t *testing.T) { clientset := clientsetfake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(clientset, time.Second) flowcontrolClient := clientset.FlowcontrolV1() startTime := time.Now() clk, _ := eventclock.NewFake(startTime, 0, nil) c := newTestableController(TestableConfig{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner_test.go
) func newTokenCleaner() (*TokenCleaner, *fake.Clientset, coreinformers.SecretInformer, error) { options := DefaultTokenCleanerOptions() cl := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(cl, options.SecretResync) secrets := informerFactory.Core().V1().Secrets() tcc, err := NewTokenCleaner(cl, secrets, options) if err != nil { return nil, nil, nil, err } return tcc, cl, secrets, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner_test.go
func newSigner() (*Signer, *fake.Clientset, coreinformers.SecretInformer, coreinformers.ConfigMapInformer, error) { 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)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 4.7K bytes - Viewed (0) -
plugin/pkg/admission/namespace/exists/admission_test.go
) // newHandlerForTest returns the admission controller configured for testing. func newHandlerForTest(c kubernetes.Interface) (admission.ValidationInterface, informers.SharedInformerFactory, error) { f := informers.NewSharedInformerFactory(c, 5*time.Minute) handler := NewExists() pluginInitializer := genericadmissioninitializer.New(c, nil, f, nil, nil, nil, nil) pluginInitializer.Initialize(handler) err := admission.ValidateInitialization(handler)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter_test.go
QueueLengthLimit: 10, }, }, }, }, } cfgObjs = append(cfgObjs, fsObj, plcObj) clientset := clientsetfake.NewSimpleClientset(cfgObjs...) informerFactory := informers.NewSharedInformerFactory(clientset, time.Second) flowcontrolClient := clientset.FlowcontrolV1() startTime := time.Now() clk, _ := eventclock.NewFake(startTime, 0, nil) controller := newTestableController(TestableConfig{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 5.6K bytes - Viewed (0)