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
}