- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for GetNodeAllocatable (0.43 sec)
-
pkg/kubelet/cm/qos_container_manager_linux.go
m.qosContainersInfo = QOSContainersInfo{ Guaranteed: rootContainer, Burstable: qosClasses[v1.PodQOSBurstable], BestEffort: qosClasses[v1.PodQOSBestEffort], } m.getNodeAllocatable = getNodeAllocatable m.activePods = activePods // update qos cgroup tiers on startup and in periodic intervals // to ensure desired state is in sync with actual state. go wait.Until(func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/volume_host.go
return "" } func (ctrl *PersistentVolumeController) GetHostIP() (net.IP, error) { return nil, fmt.Errorf("PersistentVolumeController.GetHostIP() is not implemented") } func (ctrl *PersistentVolumeController) GetNodeAllocatable() (v1.ResourceList, error) { return v1.ResourceList{}, nil } func (ctrl *PersistentVolumeController) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
func (kvh *kubeletVolumeHost) GetHostIP() (net.IP, error) { hostIPs, err := kvh.kubelet.GetHostIPs() if err != nil { return nil, err } return hostIPs[0], err } func (kvh *kubeletVolumeHost) GetNodeAllocatable() (v1.ResourceList, error) { node, err := kvh.kubelet.getNodeAnyWay() if err != nil { return nil, fmt.Errorf("error retrieving node: %v", err) } return node.Status.Allocatable, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi.go
} else { fileProjection.Data = []byte(values) } } else if fileInfo.ResourceFieldRef != nil { containerName := fileInfo.ResourceFieldRef.ContainerName nodeAllocatable, err := host.GetNodeAllocatable() if err != nil { errlist = append(errlist, err) } else if values, err := resource.ExtractResourceValueByContainerNameAndNodeAllocatable(fileInfo.ResourceFieldRef, pod, containerName, nodeAllocatable); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
} func (expc *expandController) GetHostIP() (net.IP, error) { return nil, fmt.Errorf("GetHostIP not supported by expand controller's VolumeHost implementation") } func (expc *expandController) GetNodeAllocatable() (v1.ResourceList, error) { return v1.ResourceList{}, nil } func (expc *expandController) GetSecretFunc() func(namespace, name string) (*v1.Secret, error) { return func(_, _ string) (*v1.Secret, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
logReduction: logreduction.NewLogReduction(identicalErrorDelay), seccompDefault: seccompDefault, memorySwapBehavior: memorySwapBehavior, getNodeAllocatable: getNodeAllocatable, memoryThrottlingFactor: memoryThrottlingFactor, podLogsDirectory: podLogsDirectory, } typedVersion, err := kubeRuntimeManager.getTypedVersion(ctx) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_linux.go
float64(memoryRequest)+ (float64(memoryLimit)-float64(memoryRequest))*float64(m.memoryThrottlingFactor))/float64(defaultPageSize)) * defaultPageSize } else { allocatable := m.getNodeAllocatable() allocatableMemory, ok := allocatable[v1.ResourceMemory] if ok && allocatableMemory.Value() > 0 { memoryHigh = int64(math.Floor( float64(memoryRequest)+
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
} // Returns host IP or nil in the case of error. func (f *fakeVolumeHost) GetHostIP() (net.IP, error) { return nil, fmt.Errorf("GetHostIP() not implemented") } func (f *fakeVolumeHost) GetNodeAllocatable() (v1.ResourceList, error) { return v1.ResourceList{}, nil } func (f *fakeVolumeHost) GetSecretFunc() func(namespace, name string) (*v1.Secret, error) { return func(namespace, name string) (*v1.Secret, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
if spec.Volume.EmptyDir != nil { // Support a non-specified source as EmptyDir. medium = spec.Volume.EmptyDir.Medium if medium == v1.StorageMediumMemory { nodeAllocatable, err := plugin.host.GetNodeAllocatable() if err != nil { return nil, err } sizeLimit = calculateEmptyDirMemorySize(nodeAllocatable.Memory(), spec, pod) } } return &emptyDir{ pod: pod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
func (adc *attachDetachController) GetHostIP() (net.IP, error) { return nil, fmt.Errorf("GetHostIP() not supported by Attach/Detach controller's VolumeHost implementation") } func (adc *attachDetachController) GetNodeAllocatable() (v1.ResourceList, error) { return v1.ResourceList{}, nil } func (adc *attachDetachController) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0)