localdiskvolume

Documentation

Index

• Constants
• type DiskVolumeHandler
  • func NewLocalDiskVolumeHandler(cli client.Client, recorder record.EventRecorder) *DiskVolumeHandler
  • func (v *DiskVolumeHandler) AddFinalizers(finalizer []string)
  • func (v *DiskVolumeHandler) AppendMountPoint(targetPath string, volCap *csi.VolumeCapability)
  • func (v *DiskVolumeHandler) CanSafelyMount() (bool, error)
  • func (v *DiskVolumeHandler) CheckFinalizers() error
  • func (v *DiskVolumeHandler) DeleteLocalDiskVolume() error
  • func (v *DiskVolumeHandler) ExistMountPoint(targetPath string) bool
  • func (v *DiskVolumeHandler) For(volume *v1alpha1.LocalDiskVolume)
  • func (v *DiskVolumeHandler) GetBoundDisk() string
  • func (v *DiskVolumeHandler) GetCanWipe() bool
  • func (v *DiskVolumeHandler) GetDevPath() string
  • func (v *DiskVolumeHandler) GetLocalDiskVolume(key client.ObjectKey) (volume *v1alpha1.LocalDiskVolume, err error)
  • func (v *DiskVolumeHandler) GetMountPoints() []v1alpha1.MountPoint
  • func (v *DiskVolumeHandler) GetVolumePath() string
  • func (v *DiskVolumeHandler) IsDevMountPoint(mountPoint string) bool
  • func (v *DiskVolumeHandler) MountFileSystem(devPath, mountPoint, fsType string, options ...string) error
  • func (v *DiskVolumeHandler) MountRawBlock(devPath, mountPoint string) error
  • func (v *DiskVolumeHandler) ReconcileCreated() (reconcile.Result, error)
  • func (v *DiskVolumeHandler) ReconcileDeleted() (reconcile.Result, error)
  • func (v *DiskVolumeHandler) ReconcileMount() (reconcile.Result, error)
  • func (v *DiskVolumeHandler) ReconcileToBeDeleted() (reconcile.Result, error)
  • func (v *DiskVolumeHandler) ReconcileUnmount() (reconcile.Result, error)
  • func (v *DiskVolumeHandler) RecordEvent(eventtype, reason, messageFmt string, args ...interface{})
  • func (v *DiskVolumeHandler) RefreshVolume() error
  • func (v *DiskVolumeHandler) RemoveFinalizers() error
  • func (v *DiskVolumeHandler) RemoveMountPoint(targetPath string)
  • func (v *DiskVolumeHandler) SetCanWipe(canWipe bool)
  • func (v *DiskVolumeHandler) SetupVolumeStatus(status v1alpha1.State)
  • func (v *DiskVolumeHandler) UnMount(mountPoint string) error
  • func (v *DiskVolumeHandler) UpdateDevPathAccordingVolume()
  • func (v *DiskVolumeHandler) UpdateLocalDiskVolume() error
  • func (v *DiskVolumeHandler) UpdateMountPointPhase(targetPath string, phase v1alpha1.State)
  • func (v *DiskVolumeHandler) VolumeState() v1alpha1.State
  • func (v *DiskVolumeHandler) WaitVolume(ctx context.Context, state v1alpha1.State) error
  • func (v *DiskVolumeHandler) WaitVolumeReady(ctx context.Context) error
  • func (v *DiskVolumeHandler) WaitVolumeUnmounted(ctx context.Context, mountPoint string) error
  • func (v *DiskVolumeHandler) WipeDisk() error

Constants

const (
	// LocalDiskFinalizer for the LocalDiskVolume CR
	LocalDiskFinalizer string = "localdisk.hwameistor.io/finalizer"
)

Types

type DiskVolumeHandler

type DiskVolumeHandler struct {
	client.Client
	record.EventRecorder
	Ldv *v1alpha1.LocalDiskVolume
	// contains filtered or unexported fields
}

DiskVolumeHandler

func NewLocalDiskVolumeHandler

func NewLocalDiskVolumeHandler(cli client.Client, recorder record.EventRecorder) *DiskVolumeHandler

NewLocalDiskHandler

func (*DiskVolumeHandler) AddFinalizers

func (v *DiskVolumeHandler) AddFinalizers(finalizer []string)

func (*DiskVolumeHandler) AppendMountPoint

func (v *DiskVolumeHandler) AppendMountPoint(targetPath string, volCap *csi.VolumeCapability)

func (*DiskVolumeHandler) CanSafelyMount

func (v *DiskVolumeHandler) CanSafelyMount() (bool, error)

CanSafelyMount returns true if the volume is safe to be mounted, false otherwise. case 1: if there are multiple disks having the same identifier, return false to prevent mount the wrong disk

func (*DiskVolumeHandler) CheckFinalizers

func (v *DiskVolumeHandler) CheckFinalizers() error

func (*DiskVolumeHandler) DeleteLocalDiskVolume

func (v *DiskVolumeHandler) DeleteLocalDiskVolume() error

func (*DiskVolumeHandler) ExistMountPoint

func (v *DiskVolumeHandler) ExistMountPoint(targetPath string) bool

func (*DiskVolumeHandler) For

func (v *DiskVolumeHandler) For(volume *v1alpha1.LocalDiskVolume)

func (*DiskVolumeHandler) GetBoundDisk

func (v *DiskVolumeHandler) GetBoundDisk() string

func (*DiskVolumeHandler) GetCanWipe

func (v *DiskVolumeHandler) GetCanWipe() bool

func (*DiskVolumeHandler) GetDevPath

func (v *DiskVolumeHandler) GetDevPath() string

func (*DiskVolumeHandler) GetLocalDiskVolume

func (v *DiskVolumeHandler) GetLocalDiskVolume(key client.ObjectKey) (volume *v1alpha1.LocalDiskVolume, err error)

func (*DiskVolumeHandler) GetMountPoints

func (v *DiskVolumeHandler) GetMountPoints() []v1alpha1.MountPoint

func (*DiskVolumeHandler) GetVolumePath

func (v *DiskVolumeHandler) GetVolumePath() string

func (*DiskVolumeHandler) IsDevMountPoint

func (v *DiskVolumeHandler) IsDevMountPoint(mountPoint string) bool

IsDevMountPoint judge if this mountpoint is mounted by the dev

func (*DiskVolumeHandler) MountFileSystem

func (v *DiskVolumeHandler) MountFileSystem(devPath, mountPoint, fsType string, options ...string) error

func (*DiskVolumeHandler) MountRawBlock

func (v *DiskVolumeHandler) MountRawBlock(devPath, mountPoint string) error

func (*DiskVolumeHandler) ReconcileCreated

func (v *DiskVolumeHandler) ReconcileCreated() (reconcile.Result, error)

func (*DiskVolumeHandler) ReconcileDeleted

func (v *DiskVolumeHandler) ReconcileDeleted() (reconcile.Result, error)

func (*DiskVolumeHandler) ReconcileMount

func (v *DiskVolumeHandler) ReconcileMount() (reconcile.Result, error)

func (*DiskVolumeHandler) ReconcileToBeDeleted

func (v *DiskVolumeHandler) ReconcileToBeDeleted() (reconcile.Result, error)

func (*DiskVolumeHandler) ReconcileUnmount

func (v *DiskVolumeHandler) ReconcileUnmount() (reconcile.Result, error)

func (*DiskVolumeHandler) RecordEvent

func (v *DiskVolumeHandler) RecordEvent(eventtype, reason, messageFmt string, args ...interface{})

func (*DiskVolumeHandler) RefreshVolume

func (v *DiskVolumeHandler) RefreshVolume() error

func (*DiskVolumeHandler) RemoveFinalizers

func (v *DiskVolumeHandler) RemoveFinalizers() error

func (*DiskVolumeHandler) RemoveMountPoint

func (v *DiskVolumeHandler) RemoveMountPoint(targetPath string)

func (*DiskVolumeHandler) SetCanWipe

func (v *DiskVolumeHandler) SetCanWipe(canWipe bool)

func (*DiskVolumeHandler) SetupVolumeStatus

func (v *DiskVolumeHandler) SetupVolumeStatus(status v1alpha1.State)

func (*DiskVolumeHandler) UnMount

func (v *DiskVolumeHandler) UnMount(mountPoint string) error

func (*DiskVolumeHandler) UpdateDevPathAccordingVolume

func (v *DiskVolumeHandler) UpdateDevPathAccordingVolume()

UpdateDevPathAccordingVolume devPath can change after machine restart, so update it here according to the volume

func (*DiskVolumeHandler) UpdateLocalDiskVolume

func (v *DiskVolumeHandler) UpdateLocalDiskVolume() error

func (*DiskVolumeHandler) UpdateMountPointPhase

func (v *DiskVolumeHandler) UpdateMountPointPhase(targetPath string, phase v1alpha1.State)

func (*DiskVolumeHandler) VolumeState

func (v *DiskVolumeHandler) VolumeState() v1alpha1.State

func (*DiskVolumeHandler) WaitVolume

func (v *DiskVolumeHandler) WaitVolume(ctx context.Context, state v1alpha1.State) error

func (*DiskVolumeHandler) WaitVolumeReady

func (v *DiskVolumeHandler) WaitVolumeReady(ctx context.Context) error

WaitVolumeReady wait LocalDiskVolume Ready

func (*DiskVolumeHandler) WaitVolumeUnmounted

func (v *DiskVolumeHandler) WaitVolumeUnmounted(ctx context.Context, mountPoint string) error

WaitVolumeUnmounted wait a special mountpoint is unmounted

func (*DiskVolumeHandler) WipeDisk

func (v *DiskVolumeHandler) WipeDisk() error

WipeDisk use wipefs to wipe disk