Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 873 for NodeName (0.2 sec)

  1. pkg/scheduler/internal/cache/node_tree.go

    // is added to the array of nodes in that zone.
    func (nt *nodeTree) addNode(logger klog.Logger, n *v1.Node) {
    	zone := utilnode.GetZoneKey(n)
    	if na, ok := nt.tree[zone]; ok {
    		for _, nodeName := range na {
    			if nodeName == n.Name {
    				logger.Info("Did not add to the NodeTree because it already exists", "node", klog.KObj(n))
    				return
    			}
    		}
    		nt.tree[zone] = append(na, n.Name)
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/testdata/HEAD/core.v1.Endpoints.yaml

      - hostname: hostnameValue
        ip: ipValue
        nodeName: nodeNameValue
        targetRef:
          apiVersion: apiVersionValue
          fieldPath: fieldPathValue
          kind: kindValue
          name: nameValue
          namespace: namespaceValue
          resourceVersion: resourceVersionValue
          uid: uidValue
      notReadyAddresses:
      - hostname: hostnameValue
        ip: ipValue
        nodeName: nodeNameValue
        targetRef:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 06 21:25:20 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/testdata/v1.29.0/core.v1.Endpoints.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/testdata/v1.29.0/core.v1.Endpoints.yaml

      - hostname: hostnameValue
        ip: ipValue
        nodeName: nodeNameValue
        targetRef:
          apiVersion: apiVersionValue
          fieldPath: fieldPathValue
          kind: kindValue
          name: nameValue
          namespace: namespaceValue
          resourceVersion: resourceVersionValue
          uid: uidValue
      notReadyAddresses:
      - hostname: hostnameValue
        ip: ipValue
        nodeName: nodeNameValue
        targetRef:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  5. pkg/proxy/kubemark/hollow_proxy.go

    			},
    
    			Client:      client,
    			Proxier:     &FakeProxier{},
    			Broadcaster: broadcaster,
    			Recorder:    recorder,
    			NodeRef: &v1.ObjectReference{
    				Kind:      "Node",
    				Name:      nodeName,
    				UID:       types.UID(nodeName),
    				Namespace: "",
    			},
    		},
    	}
    }
    
    func (hp *HollowProxy) Run() error {
    
    	if err := hp.ProxyServer.Run(context.TODO()); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/names/names.go

    	DynamicResources                = "DynamicResources"
    	ImageLocality                   = "ImageLocality"
    	InterPodAffinity                = "InterPodAffinity"
    	NodeAffinity                    = "NodeAffinity"
    	NodeName                        = "NodeName"
    	NodePorts                       = "NodePorts"
    	NodeResourcesBalancedAllocation = "NodeResourcesBalancedAllocation"
    	NodeResourcesFit                = "NodeResourcesFit"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 28 14:11:33 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/cache/debugger/comparer_test.go

    	compare := CacheComparer{}
    	nodes := []*v1.Node{}
    	for _, nodeName := range actual {
    		node := &v1.Node{}
    		node.Name = nodeName
    		nodes = append(nodes, node)
    	}
    
    	nodeInfo := make(map[string]*framework.NodeInfo)
    	for _, nodeName := range cached {
    		nodeInfo[nodeName] = &framework.NodeInfo{}
    	}
    
    	m, r := compare.CompareNodes(nodes, nodeInfo)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 08:00:25 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  8. pkg/kubelet/volumemanager/cache/actual_state_of_world.go

    }
    
    // NewActualStateOfWorld returns a new instance of ActualStateOfWorld.
    func NewActualStateOfWorld(
    	nodeName types.NodeName,
    	volumePluginMgr *volume.VolumePluginMgr) ActualStateOfWorld {
    	return &actualStateOfWorld{
    		nodeName:                  nodeName,
    		attachedVolumes:           make(map[v1.UniqueVolumeName]attachedVolume),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 45.8K bytes
    - Viewed (0)
  9. pkg/kubelet/certificate/kubelet.go

    // or returns an error.
    func NewKubeletServerCertificateManager(kubeClient clientset.Interface, kubeCfg *kubeletconfig.KubeletConfiguration, nodeName types.NodeName, getAddresses func() []v1.NodeAddress, certDirectory string) (certificate.Manager, error) {
    	var clientsetFn certificate.ClientsetFunc
    	if kubeClient != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 03:07:16 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. pkg/volume/csi/nodeinfomanager/nodeinfomanager.go

    	UninstallCSIDriver(driverName string) error
    }
    
    // NewNodeInfoManager initializes nodeInfoManager
    func NewNodeInfoManager(
    	nodeName types.NodeName,
    	volumeHost volume.VolumeHost,
    	migratedPlugins map[string](func() bool)) Interface {
    	return &nodeInfoManager{
    		nodeName:        nodeName,
    		volumeHost:      volumeHost,
    		migratedPlugins: migratedPlugins,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 20.1K bytes
    - Viewed (0)
Back to top