- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 717 for allocable (0.17 sec)
-
pkg/scheduler/framework/plugins/noderesources/most_allocated.go
func mostResourceScorer(resources []config.ResourceSpec) func(requested, allocable []int64) int64 { return func(requested, allocable []int64) int64 { var nodeScore, weightSum int64 for i := range requested { if allocable[i] == 0 { continue } weight := resources[i].Weight resourceScore := mostRequestedScore(requested[i], allocable[i]) nodeScore += resourceScore * weight weightSum += weight }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 21 15:23:47 UTC 2022 - 2.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio.go
} return rawScoringFunction(requested * maxUtilization / capacity) } return func(requested, allocable []int64) int64 { var nodeScore, weightSum int64 for i := range requested { if allocable[i] == 0 { continue } weight := resources[i].Weight resourceScore := resourceScoringFunction(requested[i], allocable[i]) if resourceScore > 0 { nodeScore += resourceScore * weight weightSum += weight }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 21 15:23:47 UTC 2022 - 2.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/least_allocated.go
func leastResourceScorer(resources []config.ResourceSpec) func([]int64, []int64) int64 { return func(requested, allocable []int64) int64 { var nodeScore, weightSum int64 for i := range requested { if allocable[i] == 0 { continue } weight := resources[i].Weight resourceScore := leastRequestedScore(requested[i], allocable[i]) nodeScore += resourceScore * weight weightSum += weight } if weightSum == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Mar 12 01:50:09 UTC 2023 - 2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/balanced_allocation.go
resources: args.Resources, }, }, nil } func balancedResourceScorer(requested, allocable []int64) int64 { var resourceToFractions []float64 var totalFraction float64 for i := range requested { if allocable[i] == 0 { continue } fraction := float64(requested[i]) / float64(allocable[i]) if fraction > 1 { fraction = 1 } totalFraction += fraction
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 6.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/resource_allocation.go
case v1.ResourceCPU: return nodeInfo.Allocatable.MilliCPU, (requested.MilliCPU + podRequest) case v1.ResourceMemory: return nodeInfo.Allocatable.Memory, (requested.Memory + podRequest) case v1.ResourceEphemeralStorage: return nodeInfo.Allocatable.EphemeralStorage, (nodeInfo.Requested.EphemeralStorage + podRequest) default: if _, exists := nodeInfo.Allocatable.ScalarResources[resource]; exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 14:53:43 UTC 2023 - 5.3K bytes - Viewed (0) -
src/debug/elf/file.go
s.Size = binary.BigEndian.Uint64(b[4:12]) zrd = zlib.NewReader } else if s.Flags&SHF_ALLOC != 0 { return errorReader{&FormatError{int64(s.Offset), "SHF_COMPRESSED applies only to non-allocable sections", s.compressionType}} } switch s.compressionType { case COMPRESS_ZLIB: zrd = zlib.NewReader case COMPRESS_ZSTD: zrd = func(r io.Reader) (io.ReadCloser, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 23 16:49:58 UTC 2024 - 43.1K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
t.Fatalf("timeout while waiting for manager update") } capacity, allocatable, _ := m.GetCapacity() resourceCapacity := capacity[v1.ResourceName(testResourceName)] resourceAllocatable := allocatable[v1.ResourceName(testResourceName)] require.Equal(t, resourceCapacity.Value(), resourceAllocatable.Value(), "capacity should equal to allocatable") require.Equal(t, int64(2), resourceAllocatable.Value(), "Devices are not updated.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/fake_memory_manager.go
} func (m *fakeManager) State() state.Reader { return m.state } // GetAllocatableMemory returns the amount of allocatable memory for each NUMA node func (m *fakeManager) GetAllocatableMemory() []state.Block { klog.InfoS("Get Allocatable Memory") return []state.Block{} } // GetMemory returns the memory allocated by a container from NUMA nodes
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/memory_manager.go
AddContainer(p *v1.Pod, c *v1.Container, containerID string) // Allocate is called to pre-allocate memory resources during Pod admission. // This must be called at some point prior to the AddContainer() call for a container, e.g. at pod admission time. Allocate(pod *v1.Pod, container *v1.Container) error // RemoveContainer is called after Kubelet decides to kill or delete a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/memorymanager/memory_manager_test.go
testCases := []struct { description string nodeAllocatableReservation v1.ResourceList machineInfo *cadvisorapi.MachineInfo systemReservedMemory []kubeletconfig.MemoryReservation expectedError string }{ { "Node Allocatable not set, reserved not set", v1.ResourceList{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 05 13:01:40 UTC 2023 - 70.2K bytes - Viewed (0)