Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 39 for NewSharedInformerFactory (1.29 sec)

  1. pkg/controller/nodeipam/ipam/test/utils.go

    func FakeNodeInformer(fakeNodeHandler *testutil.FakeNodeHandler) coreinformers.NodeInformer {
    	fakeClient := &fake.Clientset{}
    	fakeInformerFactory := informers.NewSharedInformerFactory(fakeClient, controller.NoResyncPeriodFunc())
    	fakeNodeInformer := fakeInformerFactory.Core().V1().Nodes()
    
    	for _, node := range fakeNodeHandler.Existing {
    		fakeNodeInformer.Informer().GetStore().Add(node)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Aug 06 00:10:39 UTC 2022
    - 2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/admission/configuration/mutating_webhook_manager_test.go

    func TestGetMutatingWebhookConfig(t *testing.T) {
    	// Build a test client that the admission plugin can use to look up the MutatingWebhookConfiguration
    	client := fake.NewSimpleClientset()
    	informerFactory := informers.NewSharedInformerFactory(client, 0)
    	stop := make(chan struct{})
    	defer close(stop)
    
    	manager := NewMutatingWebhookConfigurationManager(informerFactory).(*mutatingWebhookConfigurationManager)
    	informerFactory.Start(stop)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 15:20:14 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  3. pkg/volume/util/storageclass_test.go

    			classes: []*storagev1.StorageClass{sc4, sc5},
    			expect:  sc4,
    		},
    	}
    
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.T) {
    			informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc())
    			for _, c := range tc.classes {
    				informerFactory.Storage().V1().StorageClasses().Informer().GetStore().Add(c)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 18 14:18:11 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  4. pkg/kube/informerfactory/factory.go

    	//
    	// Shutdown may be called multiple times, even concurrently. All such calls will
    	// block until all goroutines have terminated.
    	Shutdown()
    }
    
    // NewSharedInformerFactory constructs a new instance of informerFactory for all namespaces.
    func NewSharedInformerFactory() InformerFactory {
    	return &informerFactory{
    		informers:        map[informerKey]builtInformer{},
    		startedInformers: sets.New[informerKey](),
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top