- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 49 for NewSharedInformerFactory (0.42 sec)
-
pkg/scheduler/extender_test.go
}, } for _, test := range tests { t.Run(test.name, func(t *testing.T) { client := clientsetfake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0) var extenders []framework.Extender for ii := range test.extenders { extenders = append(extenders, &test.extenders[ii]) } logger, ctx := ktesting.NewTestContext(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 16.7K bytes - Viewed (0) -
plugin/pkg/admission/runtimeclass/admission_test.go
listerObject *nodev1.RuntimeClass, addClient bool, clientObject *nodev1.RuntimeClass) *RuntimeClass { runtimeClass := NewRuntimeClass() if addLister { informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc()) runtimeClass.SetExternalKubeInformerFactory(informerFactory) if listerObject != nil { informerFactory.Node().V1().RuntimeClasses().Informer().GetStore().Add(listerObject)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 17 01:30:14 UTC 2022 - 17.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator_test.go
k8stesting "k8s.io/client-go/testing" netutils "k8s.io/utils/net" ) func newTestMetaAllocator() (*MetaAllocator, error) { client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0*time.Second) serviceCIDRInformer := informerFactory.Networking().V1alpha1().ServiceCIDRs() serviceCIDRStore := serviceCIDRInformer.Informer().GetIndexer() serviceCIDRInformer.Informer().HasSynced()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/controller/serviceaccount/legacy_serviceaccount_token_cleaner_test.go
t.Run(k, func(t *testing.T) { tc.ClientObjects = append(tc.ClientObjects, tc.ExistingSecret) client := fake.NewSimpleClientset(tc.ClientObjects...) informers := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) secretInformer := informers.Core().V1().Secrets() saInformer := informers.Core().V1().ServiceAccounts() podInformer := informers.Core().V1().Pods()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 03:52:06 UTC 2023 - 21.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go
// newHandlerForTestWithClock returns a configured handler for testing. func newHandlerForTestWithClock(c clientset.Interface, cacheClock clock.Clock) (*Lifecycle, informers.SharedInformerFactory, error) { f := informers.NewSharedInformerFactory(c, 5*time.Minute) handler, err := newLifecycleWithClock(sets.NewString(metav1.NamespaceDefault, metav1.NamespaceSystem), cacheClock) if err != nil { return nil, f, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.2K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) serviceCIDRInformer := informerFactory.Networking().V1alpha1().ServiceCIDRs() cidrStore := serviceCIDRInformer.Informer().GetStore() for _, obj := range cidrs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
} client.Tracker().Add(&api.Node{ ObjectMeta: meta.ObjectMeta{ Name: "fakeNode", }, Spec: api.NodeSpec{}, }) // Start informer for CSIDrivers. factory := informers.NewSharedInformerFactory(client, CsiResyncPeriod) csiDriverInformer := factory.Storage().V1().CSIDrivers() csiDriverLister := csiDriverInformer.Lister() volumeAttachmentInformer := factory.Storage().V1().VolumeAttachments()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller_test.go
client := fake.NewSimpleClientset(tc.ClientObjects...) for _, reactor := range tc.Reactors { client.Fake.PrependReactor(reactor.verb, reactor.resource, reactor.reactor(t)) } informers := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) secretInformer := informers.Core().V1().Secrets().Informer() secrets := secretInformer.GetStore()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 21.5K bytes - Viewed (0) -
plugin/pkg/admission/priority/admission_test.go
v1 "k8s.io/kubernetes/pkg/apis/scheduling/v1" "k8s.io/kubernetes/pkg/controller" ) func addPriorityClasses(ctrl *Plugin, priorityClasses []*scheduling.PriorityClass) error { informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc()) ctrl.SetExternalKubeInformerFactory(informerFactory) // First add the existing classes to the cache. for _, c := range priorityClasses { s := &schedulingv1.PriorityClass{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 03 18:43:48 UTC 2022 - 21.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
} return res }() nativeClient := fake.NewSimpleClientset() dynamicClient := dynamicfake.NewSimpleDynamicClient(policySourceTestScheme) fakeInformerFactory := informers.NewSharedInformerFactory(nativeClient, 30*time.Second) // Make an object tracker specifically for our policies and bindings policiesAndBindingsTracker := clienttesting.NewObjectTracker( policySourceTestScheme,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0)