kubernetes/pkg/volume/flexvolume/util.go

func addSecretsToOptions(options map[string]string, spec *volume.Spec, namespace string, driverName string, host volume.VolumeHost) error { … }

var errNotFlexVolume …

func getDriver(spec *volume.Spec) (string, error) { … }

func getFSType(spec *volume.Spec) (string, error) { … }

func getSecretNameAndNamespace(spec *volume.Spec, podNamespace string) (string, string, error) { … }

func getReadOnly(spec *volume.Spec) (bool, error) { … }

func getOptions(spec *volume.Spec) (map[string]string, error) { … }

func prepareForMount(mounter mount.Interface, deviceMountPath string) (bool, error) { … }

// Mounts the device at the given path.
// It is expected that prepareForMount has been called before.
func doMount(mounter mount.Interface, devicePath, deviceMountPath, fsType string, options []string) error { … }

func isNotMounted(mounter mount.Interface, deviceMountPath string) (bool, error) { … }