localdiskvolume

Documentation

Index

• Constants
• func Add(mgr manager.Manager) error
• 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) CheckFinalizers() error
  • func (v *DiskVolumeHandler) DeleteLocalDiskVolume() error
  • func (v *DiskVolumeHandler) ExistMountPoint(targetPath string) bool
  • func (v *DiskVolumeHandler) For(volume *ldm.LocalDiskVolume)
  • func (v *DiskVolumeHandler) GetBoundDisk() string
  • func (v *DiskVolumeHandler) GetDevPath() string
  • func (v *DiskVolumeHandler) GetLocalDiskVolume(key client.ObjectKey) (volume *ldm.LocalDiskVolume, err error)
  • func (v *DiskVolumeHandler) GetMountPoints() []ldm.MountPoint
  • func (v *DiskVolumeHandler) MountFileSystem(devPath, mountPoint, fsType string, options ...string) error
  • func (v *DiskVolumeHandler) MountRawBlock(devPath, mountPoint string) error
  • func (v *DiskVolumeHandler) MoveMountPoint(targetPath string)
  • func (v *DiskVolumeHandler) RecordEvent(eventtype, reason, messageFmt string, args ...interface{})
  • func (v *DiskVolumeHandler) RefreshVolume() error
  • func (v *DiskVolumeHandler) RemoveFinalizers() error
  • func (v *DiskVolumeHandler) SetupVolumeStatus(status ldm.State)
  • func (v *DiskVolumeHandler) UnMount(mountPoint string) error
  • func (v *DiskVolumeHandler) UpdateLocalDiskVolume() error
  • func (v *DiskVolumeHandler) UpdateMountPointPhase(targetPath string, phase ldm.State)
  • func (v *DiskVolumeHandler) VolumeState() ldm.State
  • func (v *DiskVolumeHandler) WaitVolume(ctx context.Context, state ldm.State) error
  • func (v *DiskVolumeHandler) WaitVolumeReady(ctx context.Context) error
  • func (v *DiskVolumeHandler) WaitVolumeUnmounted(ctx context.Context, mountPoint string) error
• type ReconcileLocalDiskVolume
  • func (r *ReconcileLocalDiskVolume) Reconcile(request reconcile.Request) (reconcile.Result, error)

Constants

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

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new LocalDiskVolume Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

Types

type DiskVolumeHandler

type DiskVolumeHandler struct {
	client.Client
	record.EventRecorder
	// 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) 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 *ldm.LocalDiskVolume)

func (*DiskVolumeHandler) GetBoundDisk

func (v *DiskVolumeHandler) GetBoundDisk() string

func (*DiskVolumeHandler) GetDevPath

func (v *DiskVolumeHandler) GetDevPath() string

func (*DiskVolumeHandler) GetLocalDiskVolume

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

func (*DiskVolumeHandler) GetMountPoints

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

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) MoveMountPoint

func (v *DiskVolumeHandler) MoveMountPoint(targetPath string)

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) SetupVolumeStatus

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

func (*DiskVolumeHandler) UnMount

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

func (*DiskVolumeHandler) UpdateLocalDiskVolume

func (v *DiskVolumeHandler) UpdateLocalDiskVolume() error

func (*DiskVolumeHandler) UpdateMountPointPhase

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

func (*DiskVolumeHandler) VolumeState

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

func (*DiskVolumeHandler) WaitVolume

func (v *DiskVolumeHandler) WaitVolume(ctx context.Context, state ldm.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

type ReconcileLocalDiskVolume

type ReconcileLocalDiskVolume struct {
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

ReconcileLocalDiskVolume reconciles a LocalDiskVolume object

func (*ReconcileLocalDiskVolume) Reconcile

func (r *ReconcileLocalDiskVolume) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile