Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 113 for NewSharedInformerFactory (0.25 sec)

  1. plugin/pkg/admission/resourcequota/admission_test.go

    func TestAdmissionIgnoresDelete(t *testing.T) {
    	stopCh := make(chan struct{})
    	defer close(stopCh)
    
    	kubeClient := fake.NewSimpleClientset()
    	informerFactory := informers.NewSharedInformerFactory(kubeClient, 0)
    
    	handler, err := createHandler(kubeClient, informerFactory, stopCh)
    	if err != nil {
    		t.Errorf("Error occurred while creating admission plugin: %v", err)
    	}
    
    	namespace := "default"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:28:42 UTC 2024
    - 84.1K bytes
    - Viewed (0)
  2. plugin/pkg/admission/serviceaccount/admission_test.go

    	}
    }
    
    func TestAssignsDefaultServiceAccountAndBoundTokenWithNoSecretTokens(t *testing.T) {
    	ns := "myns"
    
    	admit := NewServiceAccount()
    	informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc())
    	admit.SetExternalKubeInformerFactory(informerFactory)
    	admit.MountServiceAccountToken = true
    
    	// Add the default service account for the ns into the cache
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  3. pkg/proxy/config/api_test.go

    	client.PrependWatchReactor("services", ktesting.DefaultWatchReactor(fakeWatch, nil))
    
    	stopCh := make(chan struct{})
    	defer close(stopCh)
    
    	handler := NewServiceHandlerMock()
    
    	sharedInformers := informers.NewSharedInformerFactory(client, time.Minute)
    
    	serviceConfig := NewServiceConfig(ctx, sharedInformers.Core().V1().Services(), time.Minute)
    	serviceConfig.RegisterEventHandler(handler)
    	go sharedInformers.Start(stopCh)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go

    	return func(factory *sharedInformerFactory) *sharedInformerFactory {
    		factory.transform = transform
    		return factory
    	}
    }
    
    // NewSharedInformerFactory constructs a new instance of sharedInformerFactory for all namespaces.
    func NewSharedInformerFactory(client versioned.Interface, defaultResync time.Duration) SharedInformerFactory {
    	return NewSharedInformerFactoryWithOptions(client, defaultResync)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go

    	return func(factory *sharedInformerFactory) *sharedInformerFactory {
    		factory.transform = transform
    		return factory
    	}
    }
    
    // NewSharedInformerFactory constructs a new instance of sharedInformerFactory for all namespaces.
    func NewSharedInformerFactory(client clientset.Interface, defaultResync time.Duration) SharedInformerFactory {
    	return NewSharedInformerFactoryWithOptions(client, defaultResync)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 18:31:26 UTC 2023
    - 9K bytes
    - Viewed (0)
  6. pkg/proxy/config/config_test.go

    	fakeWatch := watch.NewFake()
    	client.PrependWatchReactor("services", ktesting.DefaultWatchReactor(fakeWatch, nil))
    
    	stopCh := make(chan struct{})
    	defer close(stopCh)
    
    	sharedInformers := informers.NewSharedInformerFactory(client, time.Minute)
    
    	config := NewServiceConfig(ctx, sharedInformers.Core().V1().Services(), time.Minute)
    	handler := NewServiceHandlerMock()
    	config.RegisterEventHandler(handler)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/queue/testing.go

    // populated with the provided objects.
    func NewTestQueueWithObjects(
    	ctx context.Context,
    	lessFn framework.LessFunc,
    	objs []runtime.Object,
    	opts ...Option,
    ) *PriorityQueue {
    	informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(objs...), 0)
    	return NewTestQueueWithInformerFactory(ctx, lessFn, informerFactory, opts...)
    }
    
    func NewTestQueueWithInformerFactory(
    	ctx context.Context,
    	lessFn framework.LessFunc,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 10 00:53:58 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  8. pkg/controller/history/controller_history_test.go

    		revisions []*apps.ControllerRevision
    		want      map[string]bool
    	}
    	testFn := func(test *testcase, t *testing.T) {
    		client := fake.NewSimpleClientset()
    		informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc())
    
    		stop := make(chan struct{})
    		defer close(stop)
    		informerFactory.Start(stop)
    		informer := informerFactory.Apps().V1().ControllerRevisions()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 21 13:31:28 UTC 2023
    - 49.1K bytes
    - Viewed (0)
  9. pkg/controller/volume/attachdetach/attach_detach_controller_test.go

    	fakeKubeClient := controllervolumetesting.CreateTestClient()
    	informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, time.Second*1)
    	//informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, time.Second*1)
    	plugins := controllervolumetesting.CreateTestPlugin()
    	var prober volume.DynamicPluginProber = nil // TODO (#51147) inject mock
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  10. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    	ad := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator(
    		fakeKubeClient,
    		volumePluginMgr,
    		fakeRecorder,
    		fakeHandler))
    	informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc())
    	nsu := statusupdater.NewNodeStatusUpdater(
    		fakeKubeClient, informerFactory.Core().V1().Nodes().Lister(), asw)
    	nodeLister := informerFactory.Core().V1().Nodes().Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
Back to top