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(ctx context.Context, target string, podName string) error
  • func (p *PodMount) CleanCache(ctx context.Context, image string, id string, volumeId string, ...) error
  • func (p *PodMount) GetJfsVolUUID(ctx context.Context, name string) (string, error)
  • func (p *PodMount) GetMountRef(ctx context.Context, target, podName string) (int, error)
  • func (p *PodMount) JCreateVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error
  • func (p *PodMount) JDeleteVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error
  • func (p *PodMount) JMount(ctx context.Context, appInfo *jfsConfig.AppInfo, ...) error
  • func (p *PodMount) JUmount(ctx context.Context, target, podName string) error
  • func (p *PodMount) UmountTarget(ctx context.Context, target, podName string) error
• type ProcessMount
  • func (p *ProcessMount) AddRefOfMount(ctx context.Context, target string, podName string) error
  • func (p *ProcessMount) CleanCache(ctx context.Context, _ string, id string, _ string, cacheDirs []string) error
  • func (p *ProcessMount) GetMountRef(ctx context.Context, target, podName string) (int, error)
  • func (p *ProcessMount) JCreateVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error
  • func (p *ProcessMount) JDeleteVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error
  • func (p *ProcessMount) JMount(ctx context.Context, _ *jfsConfig.AppInfo, jfsSetting *jfsConfig.JfsSetting) error
  • func (p *ProcessMount) JUmount(ctx context.Context, target, podName string) error
  • func (p *ProcessMount) RmrDir(ctx context.Context, directory string, isCeMount bool) ([]byte, error)
  • func (p *ProcessMount) UmountTarget(ctx context.Context, 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(ctx context.Context, appInfo *jfsConfig.AppInfo, jfsSetting *jfsConfig.JfsSetting) error
	JCreateVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error
	JDeleteVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error
	GetMountRef(ctx context.Context, target, podName string) (int, error) // podName is only used by podMount
	UmountTarget(ctx context.Context, target, podName string) error       // podName is only used by podMount
	JUmount(ctx context.Context, target, podName string) error            // podName is only used by podMount
	AddRefOfMount(ctx context.Context, target string, podName string) error
	CleanCache(ctx context.Context, image string, 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(ctx context.Context, target string, podName string) error

func (*PodMount) CleanCache

func (p *PodMount) CleanCache(ctx context.Context, image string, id string, volumeId string, cacheDirs []string) error

func (*PodMount) GetJfsVolUUID

func (p *PodMount) GetJfsVolUUID(ctx context.Context, name string) (string, error)

GetJfsVolUUID get UUID from result of `juicefs status <volumeName>`

func (*PodMount) GetMountRef

func (p *PodMount) GetMountRef(ctx context.Context, target, podName string) (int, error)

func (*PodMount) JCreateVolume

func (p *PodMount) JCreateVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error

func (*PodMount) JDeleteVolume

func (p *PodMount) JDeleteVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error

func (*PodMount) JMount

func (p *PodMount) JMount(ctx context.Context, appInfo *jfsConfig.AppInfo, jfsSetting *jfsConfig.JfsSetting) error

func (*PodMount) JUmount

func (p *PodMount) JUmount(ctx context.Context, target, podName string) error

func (*PodMount) UmountTarget

func (p *PodMount) UmountTarget(ctx context.Context, target, podName string) error

type ProcessMount

type ProcessMount struct {
	k8sMount.SafeFormatAndMount
}

func (*ProcessMount) AddRefOfMount

func (p *ProcessMount) AddRefOfMount(ctx context.Context, target string, podName string) error

func (*ProcessMount) CleanCache

func (p *ProcessMount) CleanCache(ctx context.Context, _ string, id string, _ string, cacheDirs []string) error

func (*ProcessMount) GetMountRef

func (p *ProcessMount) GetMountRef(ctx context.Context, target, podName string) (int, error)

func (*ProcessMount) JCreateVolume

func (p *ProcessMount) JCreateVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error

func (*ProcessMount) JDeleteVolume

func (p *ProcessMount) JDeleteVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error

func (*ProcessMount) JMount

func (p *ProcessMount) JMount(ctx context.Context, _ *jfsConfig.AppInfo, jfsSetting *jfsConfig.JfsSetting) error

func (*ProcessMount) JUmount

func (p *ProcessMount) JUmount(ctx context.Context, target, podName string) error

JUmount umount targetPath

func (*ProcessMount) RmrDir

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

func (*ProcessMount) UmountTarget

func (p *ProcessMount) UmountTarget(ctx context.Context, target, podName string) error