Skip to content

Commit 1c96614

Browse files
authored
Merge pull request kubeedge#1885 from guojianyu/master
update GetNodeLabels
2 parents 38106f3 + d0667dc commit 1c96614

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

edge/pkg/edged/volume_host.go

+8-2
Original file line numberDiff line numberDiff line change
@@ -138,8 +138,14 @@ func (evh *edgedVolumeHost) GetConfigMapFunc() func(namespace, name string) (*ap
138138
func (evh *edgedVolumeHost) GetExec(pluginName string) utilexec.Interface { return nil }
139139
func (evh *edgedVolumeHost) GetHostIP() (net.IP, error) { return nil, nil }
140140
func (evh *edgedVolumeHost) GetNodeAllocatable() (api.ResourceList, error) { return nil, nil }
141-
func (evh *edgedVolumeHost) GetNodeLabels() (map[string]string, error) { return nil, nil }
142-
func (evh *edgedVolumeHost) GetNodeName() types.NodeName { return types.NodeName(evh.edge.nodeName) }
141+
func (evh *edgedVolumeHost) GetNodeLabels() (map[string]string, error) {
142+
node, err := evh.edge.initialNode()
143+
if err != nil {
144+
return nil, fmt.Errorf("error retrieving node: %v", err)
145+
}
146+
return node.Labels, nil
147+
}
148+
func (evh *edgedVolumeHost) GetNodeName() types.NodeName { return types.NodeName(evh.edge.nodeName) }
143149
func (evh *edgedVolumeHost) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string {
144150
return ""
145151
}

0 commit comments

Comments
 (0)