mount

package
v0.25.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 4, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

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

func GenPodNameByUniqueId(uniqueId string, withRandom bool) string

func GetRef added in v0.14.1

func GetRef(pod *corev1.Pod) int

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 (p *PodMount) AddRefOfMount(ctx context.Context, target string, podName string) error

func (*PodMount) CleanCache added in v0.14.1

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

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 (p *PodMount) GetMountRef(ctx context.Context, target, podName string) (int, error)

func (*PodMount) JCreateVolume added in v0.13.0

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

func (*PodMount) JDeleteVolume added in v0.13.0

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 added in v0.14.1

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

type ProcessMount

type ProcessMount struct {
	k8sMount.SafeFormatAndMount
	// contains filtered or unexported fields
}

func (*ProcessMount) AddRefOfMount

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

func (*ProcessMount) CleanCache added in v0.14.1

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

func (*ProcessMount) GetMountRef added in v0.14.1

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

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) RmrDir added in v0.13.2

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

func (*ProcessMount) UmountTarget added in v0.14.1

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

Directories

Path Synopsis
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL