Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 49 for NewSharedInformerFactory (0.42 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top