func getVolumeTypeFromNode()

in pkg/csi/cache.go [154:170]


func getVolumeTypeFromNode(node *corev1.Node) (volumeTypeInfo, error) {
	labels := node.GetLabels()
	volumeType, found := labels[common.VolumeTypeLabel]
	if !found {
		return volumeTypeInfo{}, fmt.Errorf("%s label not found on node %s", common.VolumeTypeLabel, node.GetName())
	}
	vti := volumeTypeInfo{VolumeType: volumeType}
	szStr, found := labels[common.SizeLabel]
	if found {
		q, err := resource.ParseQuantity(szStr)
		if err != nil {
			return volumeTypeInfo{}, fmt.Errorf("bad size label %s=%s on %s", common.SizeLabel, szStr, node.GetName())
		}
		vti.Size = q
	}
	return vti, nil
}