Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newController (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top