Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for GetNodeName (0.32 sec)

  1. pkg/volume/csi/csi_attacher_test.go

    			}
    
    			if tc.deviceMountPath != "" {
    				tc.deviceMountPath = filepath.Join(tmpDir, tc.deviceMountPath)
    			}
    
    			nodeName := string(csiAttacher.plugin.host.GetNodeName())
    			attachID := getAttachmentName(tc.volName, testDriver, nodeName)
    
    			if tc.createAttachment {
    				// Set up volume attachment
    				attachment := makeTestAttachment(attachID, nodeName, pvName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 58.1K bytes
    - Viewed (0)
  2. pilot/pkg/xds/ads.go

    		}
    	}
    	// add topology labels to proxy labels
    	proxy.Labels = labelutil.AugmentLabels(
    		proxy.Labels,
    		proxy.Metadata.ClusterID,
    		util.LocalityToString(proxy.Locality),
    		proxy.GetNodeName(),
    		proxy.Metadata.Network,
    	)
    }
    
    func localityFromProxyLabels(proxy *model.Proxy) *core.Locality {
    	region, f1 := proxy.Labels[labelutil.LabelTopologyRegion]
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	}
    }
    
    func (adc *attachDetachController) GetNodeLabels() (map[string]string, error) {
    	return nil, fmt.Errorf("GetNodeLabels() unsupported in Attach/Detach controller")
    }
    
    func (adc *attachDetachController) GetNodeName() types.NodeName {
    	return ""
    }
    
    func (adc *attachDetachController) GetEventRecorder() record.EventRecorder {
    	return nil
    }
    
    func (adc *attachDetachController) GetSubpather() subpath.Interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  4. pkg/volume/plugins.go

    	GetExec(pluginName string) exec.Interface
    
    	// Returns the labels on the node
    	GetNodeLabels() (map[string]string, error)
    
    	// Returns the name of the node
    	GetNodeName() types.NodeName
    
    	GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error)
    
    	// Returns the event recorder of kubelet.
    	GetEventRecorder() record.EventRecorder
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:13:15 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  5. pilot/pkg/model/context.go

    	return node.Metadata.Labels[constants.TestVMLabel] != ""
    }
    
    func (node *Proxy) IsProxylessGrpc() bool {
    	return node.Metadata != nil && node.Metadata.Generator == "grpc"
    }
    
    func (node *Proxy) GetNodeName() string {
    	if node.Metadata != nil && len(node.Metadata.NodeName) > 0 {
    		return node.Metadata.NodeName
    	}
    	// fall back to get the node name from labels
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/controller.go

    func (c *Controller) GetProxyWorkloadLabels(proxy *model.Proxy) labels.Instance {
    	pod := c.pods.getPodByProxy(proxy)
    	if pod != nil {
    		var locality, nodeName string
    		locality = c.getPodLocality(pod)
    		if len(proxy.GetNodeName()) == 0 {
    			// this can happen for an "old" proxy with no `Metadata.NodeName` set
    			// in this case we set the node name in labels on the fly
    			// TODO: remove this when 1.16 is EOL?
    			nodeName = pod.Spec.NodeName
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top