Merge pull request #2934 from haircommander/kube-file
Add File mounts to play kube
This commit is contained in:
commit
a2e9626d92
|
|
@ -28,6 +28,8 @@ import (
|
||||||
const (
|
const (
|
||||||
// https://kubernetes.io/docs/concepts/storage/volumes/#hostpath
|
// https://kubernetes.io/docs/concepts/storage/volumes/#hostpath
|
||||||
createDirectoryPermission = 0755
|
createDirectoryPermission = 0755
|
||||||
|
// https://kubernetes.io/docs/concepts/storage/volumes/#hostpath
|
||||||
|
createFilePermission = 0644
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
|
@ -170,7 +172,23 @@ func playKubeYAMLCmd(c *cliconfig.KubePlayValues) error {
|
||||||
return errors.Wrapf(err, "Error giving %s a label", hostPath.Path)
|
return errors.Wrapf(err, "Error giving %s a label", hostPath.Path)
|
||||||
}
|
}
|
||||||
break
|
break
|
||||||
|
case v1.HostPathFileOrCreate:
|
||||||
|
if _, err := os.Stat(hostPath.Path); os.IsNotExist(err) {
|
||||||
|
f, err := os.OpenFile(hostPath.Path, os.O_RDONLY|os.O_CREATE, createFilePermission)
|
||||||
|
if err != nil {
|
||||||
|
return errors.Errorf("Error creating HostPath %s at %s", volume.Name, hostPath.Path)
|
||||||
|
}
|
||||||
|
if err := f.Close(); err != nil {
|
||||||
|
logrus.Warnf("Error in closing newly created HostPath file: %v", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// unconditionally label a newly created volume as private
|
||||||
|
if err := libpod.LabelVolumePath(hostPath.Path, false); err != nil {
|
||||||
|
return errors.Wrapf(err, "Error giving %s a label", hostPath.Path)
|
||||||
|
}
|
||||||
|
break
|
||||||
case v1.HostPathDirectory:
|
case v1.HostPathDirectory:
|
||||||
|
case v1.HostPathFile:
|
||||||
case v1.HostPathUnset:
|
case v1.HostPathUnset:
|
||||||
// do nothing here because we will verify the path exists in validateVolumeHostDir
|
// do nothing here because we will verify the path exists in validateVolumeHostDir
|
||||||
break
|
break
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue