- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for GetNodeName (0.18 sec)
-
pkg/kubelet/volume_host.go
for i := range attachedVolumes { attachedVolume := attachedVolumes[i] result[attachedVolume.Name] = attachedVolume.DevicePath } return result, nil } func (kvh *kubeletVolumeHost) GetNodeName() types.NodeName { return kvh.kubelet.nodeName } func (kvh *kubeletVolumeHost) GetEventRecorder() record.EventRecorder { return kvh.kubelet.recorder }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
} } func (expc *expandController) GetNodeLabels() (map[string]string, error) { return nil, fmt.Errorf("GetNodeLabels unsupported in expandController") } func (expc *expandController) GetNodeName() types.NodeName { return "" } func (expc *expandController) GetEventRecorder() record.EventRecorder { return expc.recorder } func (expc *expandController) GetSubpather() subpath.Interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
h.Write(Separator) if len(b.failoverPriorityLabels) > 0 { h.Write(b.failoverPriorityLabels) h.Write(Separator) } if b.service.Attributes.NodeLocal { h.WriteString(b.proxy.GetNodeName()) h.Write(Separator) } if b.push != nil && b.push.AuthnPolicies != nil { h.WriteString(b.push.AuthnPolicies.GetVersion()) } h.Write(Separator)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
if f.nodeLabels == nil { f.nodeLabels = map[string]string{"test-label": "test-value"} } return f.nodeLabels, nil } func (f *fakeVolumeHost) GetNodeName() types.NodeName { return types.NodeName(f.nodeName) } func (f *fakeVolumeHost) GetEventRecorder() record.EventRecorder { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)