- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 111 for NewSharedInformerFactory (0.62 sec)
-
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/scheduler/scheduler_test.go
}, } for _, tc := range cases { t.Run(tc.name, func(t *testing.T) { client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0) eventBroadcaster := events.NewBroadcaster(&events.EventSinkImpl{Interface: client.EventsV1()}) _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
t.Fatalf("Failed to init plugins while creating fake volume host: %v", err) } host.subpather = &subpath.FakeSubpath{} host.informerFactory = informers.NewSharedInformerFactory(kubeClient, time.Minute) // Wait until the InitPlugins setup is finished before returning from this setup func if err := host.WaitForKubeletErrNil(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K 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/security/podsecurity/admission_test.go
warnBaselineNamespace, warnRestrictedNamespace, enforceWarnAuditBaseline, warnBaselineAuditRestrictedNamespace, ) p.SetExternalKubeClientSet(c) informerFactory := informers.NewSharedInformerFactory(c, 0) p.SetExternalKubeInformerFactory(informerFactory) stopCh := make(chan struct{}) defer close(stopCh) informerFactory.Start(stopCh) informerFactory.WaitForCacheSync(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 15 01:29:47 UTC 2022 - 10.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) -
pkg/volume/util/volumeattributesclass_test.go
expect: vac4, }, } for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc()) for _, c := range tc.classes { err := informerFactory.Storage().V1alpha1().VolumeAttributesClasses().Informer().GetStore().Add(c) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 03:18:56 UTC 2023 - 5.9K bytes - Viewed (0)