Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 541 for allocable (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top