- Sort Score
- Result 10 results
- Languages All
Results 101 - 106 of 106 for newController (0.49 sec)
-
pkg/controller/volume/persistentvolume/framework_test.go
PodInformer: informerFactory.Core().V1().Pods(), NodeInformer: informerFactory.Core().V1().Nodes(), EnableDynamicProvisioning: enableDynamicProvisioning, } ctrl, err := NewController(ctx, params) if err != nil { return nil, fmt.Errorf("failed to construct persistentvolume controller: %v", err) } ctrl.eventRecorder = record.NewFakeRecorder(1000) ctrl.volumeListerSynced = alwaysReady
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
podsWithDelayedDeletionPerIndex map[int]*v1.Pod terminating *int32 } // NewController creates a new Job controller that keeps the relevant pods // in sync with their corresponding Job objects. func NewController(ctx context.Context, podInformer coreinformers.PodInformer, jobInformer batchinformers.JobInformer, kubeClient clientset.Interface) (*Controller, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
_, ctx := ktesting.NewTestContext(t) clientset := fake.NewSimpleClientset() sharedInformers := informers.NewSharedInformerFactory(clientset, controller.NoResyncPeriodFunc()) manager, err := NewController(ctx, sharedInformers.Core().V1().Pods(), sharedInformers.Batch().V1().Jobs(), clientset) if err != nil { t.Fatalf("Error creating Job controller: %v", err) } manager.podStoreSynced = alwaysReady
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
MemoryThrottlingFactor: utilpointer.Float64(0), } var prober volume.DynamicPluginProber tp := noopoteltrace.NewTracerProvider() mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() cadvisor := cadvisortest.NewMockInterface(mockCtrl) cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).AnyTimes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
}, }, }, PodCgroupRoot: "kubepods", } summaryProvider := &fakeSummaryProvider{result: makeMemoryStats("2Gi", map[*v1.Pod]statsapi.PodStats{})} mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() thresholdNotifier := NewMockThresholdNotifier(mockCtrl) thresholdNotifier.EXPECT().UpdateThreshold(summaryProvider.result).Return(nil).Times(2) manager := &managerImpl{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
} leaseDuration := time.Duration(kubeCfg.NodeLeaseDurationSeconds) * time.Second renewInterval := time.Duration(float64(leaseDuration) * nodeLeaseRenewIntervalFraction) klet.nodeLeaseController = lease.NewController( klet.clock, klet.heartbeatClient, string(klet.nodeName), kubeCfg.NodeLeaseDurationSeconds, klet.onRepeatedHeartbeatFailure, renewInterval, string(klet.nodeName), v1.NamespaceNodeLease,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)