mount

Documentation

Index

• Constants
• func GeneratePodNameByVolumeID(volumeID string) string
• func GetOptions(mountInfo Info, readOnly bool) []string
• func PFSMount(volumeID string, mountInfo Info) error
• func PodUnmount(volumeID string, mountInfo Info) error
• type Info
  • func ProcessMountInfo(fsInfoBase64, fsCacheBase64, targetPath string, readOnly bool) (Info, error)
  • func (mountInfo *Info) CacheWorkerCmd() string
  • func (mountInfo *Info) MountCmd() (string, []string)

Constants

const (
	VolumesKeyMount     = "pfs-mount"
	VolumesKeyDataCache = "data-cache"
	VolumesKeyMetaCache = "meta-cache"

	FusePodMountPoint = schema.FusePodMntDir + "/storage"
	FusePodCachePath  = "/home/paddleflow/pfs-cache"
	DataCacheDir      = "/data-cache"
	MetaCacheDir      = "/meta-cache"
	CacheWorkerBin    = "/home/paddleflow/cache-worker"

	ContainerNameCacheWorker = "cache-worker"
	ContainerNamePfsMount    = "pfs-mount"
)

const (
	ReadOnly = "ro"
)

Functions

func GeneratePodNameByVolumeID

func GeneratePodNameByVolumeID(volumeID string) string

func GetOptions

func GetOptions(mountInfo Info, readOnly bool) []string

func PFSMount

func PFSMount(volumeID string, mountInfo Info) error

func PodUnmount

func PodUnmount(volumeID string, mountInfo Info) error

Types

type Info

type Info struct {
	CacheConfig model.FSCacheConfig
	FS          model.FileSystem
	FSBase64Str string
	TargetPath  string
	Options     []string
	K8sClient   utils.Client
}

func ProcessMountInfo

func ProcessMountInfo(fsInfoBase64, fsCacheBase64, targetPath string, readOnly bool) (Info, error)

func (*Info) CacheWorkerCmd

func (mountInfo *Info) CacheWorkerCmd() string

func (*Info) MountCmd

func (mountInfo *Info) MountCmd() (string, []string)