- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 541 for allocable (0.14 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt
val address = factory.newHttpsAddress() proxySelector.proxies.add(proxyA) proxySelector.proxies.add(proxyB) var routeSelector = newRouteSelector(address) dns[PROXY_A_HOST] = dns.allocate(1) dns[PROXY_B_HOST] = dns.allocate(1) // Mark the ProxyA route as failed. val selection = routeSelector.next() dns.assertRequests(PROXY_A_HOST) val route = selection.next()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 20.8K bytes - Viewed (0) -
pkg/registry/core/service/allocator/storage/storage.go
baseKey: baseKey, resource: config.GroupResource, destroyFn: func() { once.Do(d) }, }, nil } // Allocate attempts to allocate the item. func (e *Etcd) Allocate(offset int) (bool, error) { e.lock.Lock() defer e.lock.Unlock() err := e.tryUpdate(func() error { ok, err := e.alloc.Allocate(offset) if err != nil { return err } if !ok { return errorUnableToAllocate } return nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 6.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
assert.NoError(t, err) assert.True(t, apiequality.Semantic.DeepEqual(expectedNode.Status.Allocatable, updatedNode.Status.Allocatable), "%s", cmp.Diff(expectedNode.Status.Allocatable, updatedNode.Status.Allocatable)) } func TestUpdateDefaultLabels(t *testing.T) { testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0) -
common-protos/k8s.io/api/policy/v1beta1/generated.proto
// seLinux is the strategy that will dictate the allowable labels that may be set. optional SELinuxStrategyOptions seLinux = 10; // runAsUser is the strategy that will dictate the allowable RunAsUser values that may be set. optional RunAsUserStrategyOptions runAsUser = 11; // RunAsGroup is the strategy that will dictate the allowable RunAsGroup values that may be set.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_assignment_test.go
1, "", cpuset.New(2), }, { "allocate 4 full cores with 3 coming from the first NUMA node (filling it up) and 1 coming from the second NUMA node", topoDualSocketHT, mustParseCPUSet(t, "0-11"), 8, "", mustParseCPUSet(t, "0,6,2,8,4,10,1,7"), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 17:31:37 UTC 2023 - 22.7K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
// many zero-request pods onto one node. NonZeroRequested *Resource // We store allocatedResources (which is Node.Status.Allocatable.*) explicitly // as int64, to avoid conversions and accessing map. Allocatable *Resource // ImageStates holds the entry of an image if and only if this image is on the node. The entry can be used for
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/structured/namedresources/namedresourcesmodel.go
} func (c *Controller) NodeIsSuitable(ctx context.Context, model Model) (bool, error) { indices, err := c.allocate(ctx, model) return len(indices) == len(c.requests), err } func (c *Controller) Allocate(ctx context.Context, model Model) ([]*resourceapi.NamedResourcesAllocationResult, error) { indices, err := c.allocate(ctx, model) if err != nil { return nil, err } if len(indices) != len(c.requests) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:26:16 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/nodestatus.go
} // WithAllocatable sets the Allocatable field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the Allocatable field is set to the value of the last call. func (b *NodeStatusApplyConfiguration) WithAllocatable(value v1.ResourceList) *NodeStatusApplyConfiguration { b.Allocatable = &value return b }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:06:39 UTC 2024 - 8K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
} klog.InfoS("Container manager verified user specified cgroup-root exists", "cgroupRoot", cgroupRoot) // Include the top level cgroup for enforcing node allocatable into cgroup-root. // This way, all sub modules can avoid having to understand the concept of node allocatable. cgroupRoot = NewCgroupName(cgroupRoot, defaultNodeAllocatableCgroupName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters.go
if old, ok := node.Status.Allocatable[k]; !ok || old.Value() != v.Value() { klog.V(2).InfoS("Updated allocatable", "device", k, "allocatable", v.Value()) } node.Status.Allocatable[k] = v } // for every huge page reservation, we need to remove it from allocatable memory for k, v := range node.Status.Capacity { if v1helper.IsHugePageResourceName(k) { allocatableMemory := node.Status.Allocatable[v1.ResourceMemory]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0)