Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for NewSharedInformerFactory (0.48 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. 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)
  3. 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)
  4. pkg/controller/cronjob/cronjob_controllerv2_test.go

    			logger, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			kubeClient := fake.NewSimpleClientset()
    			sharedInformers := informers.NewSharedInformerFactory(kubeClient, controller.NoResyncPeriodFunc())
    			jm, err := NewControllerV2(ctx, sharedInformers.Batch().V1().Jobs(), sharedInformers.Batch().V1().CronJobs(), kubeClient)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 70.8K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			podItems := []v1.Pod{}
    			for _, pod := range tt.pods {
    				podItems = append(podItems, *pod)
    			}
    			cs := clientsetfake.NewSimpleClientset(&v1.PodList{Items: podItems})
    			informerFactory := informers.NewSharedInformerFactory(cs, 0)
    			podInformer := informerFactory.Core().V1().Pods().Informer()
    			podInformer.GetStore().Add(tt.pod)
    			for i := range tt.pods {
    				podInformer.GetStore().Add(tt.pods[i])
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  6. pkg/controller/replicaset/replica_set_test.go

    )
    
    func testNewReplicaSetControllerFromClient(tb testing.TB, client clientset.Interface, stopCh chan struct{}, burstReplicas int) (*ReplicaSetController, informers.SharedInformerFactory) {
    	informers := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc())
    
    	tCtx := ktesting.Init(tb)
    	ret := NewReplicaSetController(
    		tCtx,
    		informers.Apps().V1().ReplicaSets(),
    		informers.Core().V1().Pods(),
    		client,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/podtopologyspread/scoring_test.go

    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			informerFactory := informers.NewSharedInformerFactory(fake.NewSimpleClientset(tt.objs...), 0)
    			f, err := frameworkruntime.NewFramework(ctx, nil, nil,
    				frameworkruntime.WithSnapshotSharedLister(cache.NewSnapshot(nil, tt.nodes)),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 60K bytes
    - Viewed (0)
  8. plugin/pkg/admission/limitranger/admission_test.go

    	})
    	return mockClient
    }
    
    // newHandlerForTest returns a handler configured for testing.
    func newHandlerForTest(c clientset.Interface) (*LimitRanger, informers.SharedInformerFactory, error) {
    	f := informers.NewSharedInformerFactory(c, 5*time.Minute)
    	handler, err := NewLimitRanger(&DefaultLimitRangerActions{})
    	if err != nil {
    		return nil, f, err
    	}
    	pluginInitializer := genericadmissioninitializer.New(c, nil, f, nil, nil, nil, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  9. pkg/controller/endpoint/endpoints_controller_test.go

    	client := clientset.NewForConfigOrDie(&restclient.Config{Host: url, ContentConfig: restclient.ContentConfig{GroupVersion: &schema.GroupVersion{Group: "", Version: "v1"}}})
    	informerFactory := informers.NewSharedInformerFactory(client, controllerpkg.NoResyncPeriodFunc())
    	endpoints := NewEndpointController(ctx, informerFactory.Core().V1().Pods(), informerFactory.Core().V1().Services(),
    		informerFactory.Core().V1().Endpoints(), client, batchPeriod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  10. pkg/controller/disruption/disruption_test.go

    func newFakeDisruptionControllerWithTime(ctx context.Context, now time.Time) (*disruptionController, *pdbStates) {
    	ps := &pdbStates{}
    
    	coreClient := fake.NewSimpleClientset()
    	informerFactory := informers.NewSharedInformerFactory(coreClient, controller.NoResyncPeriodFunc())
    
    	scheme := runtime.NewScheme()
    	scheme.AddKnownTypeWithName(customGVK, &v1.Service{})
    	fakeScaleClient := &scalefake.FakeScaleClient{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
Back to top