- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for NewSharedInformerFactory (0.37 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)