Documentation ¶
Index ¶
- func GenHashOfSetting(log klog.Logger, setting jfsConfig.JfsSetting) string
- func GenPodNameByUniqueId(uniqueId string, withRandom bool) string
- func GetRef(pod *corev1.Pod) int
- type 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, jfsSetting *jfsConfig.JfsSetting) (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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenHashOfSetting ¶ added in v0.16.0
func GenHashOfSetting(log klog.Logger, setting jfsConfig.JfsSetting) string
func GenPodNameByUniqueId ¶ added in v0.16.0
Types ¶
type MntInterface ¶ added in v0.12.0
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 // contains filtered or unexported fields }
func (*PodMount) AddRefOfMount ¶
func (*PodMount) CleanCache ¶ added in v0.14.1
func (*PodMount) GetJfsVolUUID ¶ added in v0.19.0
func (p *PodMount) GetJfsVolUUID(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) (string, error)
GetJfsVolUUID get UUID from result of `juicefs status <volumeName>`
func (*PodMount) GetMountRef ¶ added in v0.14.1
func (*PodMount) JCreateVolume ¶ added in v0.13.0
func (*PodMount) JDeleteVolume ¶ added in v0.13.0
type ProcessMount ¶
type ProcessMount struct { k8sMount.SafeFormatAndMount // contains filtered or unexported fields }
func (*ProcessMount) AddRefOfMount ¶
func (*ProcessMount) CleanCache ¶ added in v0.14.1
func (*ProcessMount) GetMountRef ¶ added in v0.14.1
func (*ProcessMount) JCreateVolume ¶ added in v0.13.0
func (p *ProcessMount) JCreateVolume(ctx context.Context, jfsSetting *jfsConfig.JfsSetting) error
func (*ProcessMount) JDeleteVolume ¶ added in v0.13.0
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) UmountTarget ¶ added in v0.14.1
func (p *ProcessMount) UmountTarget(ctx context.Context, target, podName string) error
Click to show internal directories.
Click to hide internal directories.