Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 103 of 103 for newController (0.13 sec)

  1. 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)
  2. 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)
  3. 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