Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for setupController (0.41 sec)

  1. pkg/controller/storageversiongc/gc_controller_test.go

    	"k8s.io/client-go/informers"
    	"k8s.io/client-go/kubernetes"
    	"k8s.io/client-go/kubernetes/fake"
    	"k8s.io/klog/v2/ktesting"
    	utilpointer "k8s.io/utils/pointer"
    )
    
    func setupController(ctx context.Context, clientset kubernetes.Interface) {
    	informerFactory := informers.NewSharedInformerFactory(clientset, 100*time.Millisecond)
    	leaseInformer := informerFactory.Coordination().V1().Leases()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 12:19:43 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_control_test.go

    	"k8s.io/kubernetes/pkg/controller"
    	"k8s.io/kubernetes/pkg/controller/history"
    	"k8s.io/kubernetes/pkg/features"
    )
    
    type invariantFunc func(set *apps.StatefulSet, om *fakeObjectManager) error
    
    func setupController(client clientset.Interface) (*fakeObjectManager, *fakeStatefulSetStatusUpdater, StatefulSetControlInterface) {
    	informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  3. pkg/controller/podautoscaler/horizontal_test.go

    		}
    		assert.Equal(t, l, m.metricComputationErrorLabels[metricType][0], "the metric computation error should be recorded in monitor expectedly")
    	}
    }
    
    func (tc *testCase) setupController(t *testing.T) (*HorizontalController, informers.SharedInformerFactory) {
    	testClient, testMetricsClient, testCMClient, testEMClient, testScaleClient := tc.prepareTestClient(t)
    	if tc.testClient != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 199.3K bytes
    - Viewed (0)
Back to top