mount

Documentation

Index

• func GenHashOfSetting(setting jfsConfig.JfsSetting) (string, error)
• func GenPodNameByUniqueId(uniqueId string, withRandom bool) string
• func GetRef(pod *corev1.Pod) int
• type MntInterface
  • func NewPodMount(client *k8sclient.K8sClient, mounter k8sMount.SafeFormatAndMount) MntInterface
  • func NewProcessMount(mounter k8sMount.SafeFormatAndMount) MntInterface
• type PodMount
  • func (p *PodMount) AddRefOfMount(target string, podName string) error
  • func (p *PodMount) CleanCache(id string, volumeId string, cacheDirs []string) error
  • func (p *PodMount) GetMountRef(target, podName string) (int, error)
  • func (p *PodMount) JCreateVolume(jfsSetting *jfsConfig.JfsSetting) error
  • func (p *PodMount) JDeleteVolume(jfsSetting *jfsConfig.JfsSetting) error
  • func (p *PodMount) JMount(jfsSetting *jfsConfig.JfsSetting) error
  • func (p *PodMount) JUmount(target, podName string) error
  • func (p *PodMount) UmountTarget(target, podName string) error
• type ProcessMount
  • func (p *ProcessMount) AddRefOfMount(target string, podName string) error
  • func (p *ProcessMount) CleanCache(id string, volumeId string, cacheDirs []string) error
  • func (p *ProcessMount) GetMountRef(target, podName string) (int, error)
  • func (p *ProcessMount) JCreateVolume(jfsSetting *jfsConfig.JfsSetting) error
  • func (p *ProcessMount) JDeleteVolume(jfsSetting *jfsConfig.JfsSetting) error
  • func (p *ProcessMount) JMount(jfsSetting *jfsConfig.JfsSetting) error
  • func (p *ProcessMount) JUmount(target, podName string) error
  • func (p *ProcessMount) RmrDir(directory string, isCeMount bool) ([]byte, error)
  • func (p *ProcessMount) UmountTarget(target, podName string) error

Functions

func GenHashOfSetting

func GenHashOfSetting(setting jfsConfig.JfsSetting) (string, error)

func GenPodNameByUniqueId

func GenPodNameByUniqueId(uniqueId string, withRandom bool) string

func GetRef

func GetRef(pod *corev1.Pod) int

Types

type MntInterface

type MntInterface interface {
	k8sMount.Interface
	JMount(jfsSetting *jfsConfig.JfsSetting) error
	JCreateVolume(jfsSetting *jfsConfig.JfsSetting) error
	JDeleteVolume(jfsSetting *jfsConfig.JfsSetting) error
	GetMountRef(target, podName string) (int, error) // podName is only used by podMount
	UmountTarget(target, podName string) error       // podName is only used by podMount
	JUmount(target, podName string) error            // podName is only used by podMount
	AddRefOfMount(target string, podName string) error
	CleanCache(id string, volumeId string, cacheDirs []string) error
}

func NewPodMount

func NewPodMount(client *k8sclient.K8sClient, mounter k8sMount.SafeFormatAndMount) MntInterface

func NewProcessMount

func NewProcessMount(mounter k8sMount.SafeFormatAndMount) MntInterface

type PodMount

type PodMount struct {
	k8sMount.SafeFormatAndMount
	K8sClient *k8sclient.K8sClient
}

func (*PodMount) AddRefOfMount

func (p *PodMount) AddRefOfMount(target string, podName string) error

func (*PodMount) CleanCache

func (p *PodMount) CleanCache(id string, volumeId string, cacheDirs []string) error

func (*PodMount) GetMountRef

func (p *PodMount) GetMountRef(target, podName string) (int, error)

func (*PodMount) JCreateVolume

func (p *PodMount) JCreateVolume(jfsSetting *jfsConfig.JfsSetting) error

func (*PodMount) JDeleteVolume

func (p *PodMount) JDeleteVolume(jfsSetting *jfsConfig.JfsSetting) error

func (*PodMount) JMount

func (p *PodMount) JMount(jfsSetting *jfsConfig.JfsSetting) error

func (*PodMount) JUmount

func (p *PodMount) JUmount(target, podName string) error

func (*PodMount) UmountTarget

func (p *PodMount) UmountTarget(target, podName string) error

type ProcessMount

type ProcessMount struct {
	k8sMount.SafeFormatAndMount
}

func (*ProcessMount) AddRefOfMount

func (p *ProcessMount) AddRefOfMount(target string, podName string) error

func (*ProcessMount) CleanCache

func (p *ProcessMount) CleanCache(id string, volumeId string, cacheDirs []string) error

func (*ProcessMount) GetMountRef

func (p *ProcessMount) GetMountRef(target, podName string) (int, error)

func (*ProcessMount) JCreateVolume

func (p *ProcessMount) JCreateVolume(jfsSetting *jfsConfig.JfsSetting) error

func (*ProcessMount) JDeleteVolume

func (p *ProcessMount) JDeleteVolume(jfsSetting *jfsConfig.JfsSetting) error

func (*ProcessMount) JMount

func (p *ProcessMount) JMount(jfsSetting *jfsConfig.JfsSetting) error

func (*ProcessMount) JUmount

func (p *ProcessMount) JUmount(target, podName string) error

JUmount umount targetPath

func (*ProcessMount) RmrDir

func (p *ProcessMount) RmrDir(directory string, isCeMount bool) ([]byte, error)

func (*ProcessMount) UmountTarget

func (p *ProcessMount) UmountTarget(target, podName string) error