cleanup

Documentation

Index

• func CancelPendingClones(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) error
• func CleanUpOMAPDetails(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) error
• func DeleteSubVolumeSnapshots(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) error
• func RadosNamespaceCleanup(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) error
• func StartHostPathCleanup(namespaceDir, dataDirHostPath, monSecret string)
• func SubVolumeGroupCleanup(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) error
• type DiskSanitizer
  • func NewDiskSanitizer(context *clusterd.Context, clusterInfo *client.ClusterInfo, ...) *DiskSanitizer
  • func (s *DiskSanitizer) SanitizeLVMDisk(osdLVMList []oposd.OSDInfo)
  • func (s *DiskSanitizer) SanitizeRawDisk(osdRawList []oposd.OSDInfo)
  • func (s *DiskSanitizer) StartSanitizeDisks()

Functions

func CancelPendingClones

func CancelPendingClones(context *clusterd.Context, clusterInfo *client.ClusterInfo, snapshots cephclient.SubVolumeSnapshots, fsName, subvol, svg string) error

func CleanUpOMAPDetails

func CleanUpOMAPDetails(context *clusterd.Context, clusterInfo *client.ClusterInfo, objName, poolName, namespace string) error

func DeleteSubVolumeSnapshots

func DeleteSubVolumeSnapshots(context *clusterd.Context, clusterInfo *client.ClusterInfo, snapshots cephclient.SubVolumeSnapshots, fsName, subvol, svg string) error

func RadosNamespaceCleanup

func RadosNamespaceCleanup(context *clusterd.Context, clusterInfo *client.ClusterInfo, poolName, radosNamespace string) error

func StartHostPathCleanup

func StartHostPathCleanup(namespaceDir, dataDirHostPath, monSecret string)

StartHostPathCleanup is the main entrypoint function to clean up dataDirHostPath and monitor store

func SubVolumeGroupCleanup

func SubVolumeGroupCleanup(context *clusterd.Context, clusterInfo *client.ClusterInfo, fsName, svg, poolName, csiNamespace string) error

Types

type DiskSanitizer

type DiskSanitizer struct {
	// contains filtered or unexported fields
}

DiskSanitizer is simple struct to old the context to execute the commands

func NewDiskSanitizer

func NewDiskSanitizer(context *clusterd.Context, clusterInfo *client.ClusterInfo, sanitizeDisksSpec *cephv1.SanitizeDisksSpec) *DiskSanitizer

NewDiskSanitizer is function that returns a full filled DiskSanitizer object

func (*DiskSanitizer) SanitizeLVMDisk

func (s *DiskSanitizer) SanitizeLVMDisk(osdLVMList []oposd.OSDInfo)

func (*DiskSanitizer) SanitizeRawDisk

func (s *DiskSanitizer) SanitizeRawDisk(osdRawList []oposd.OSDInfo)

func (*DiskSanitizer) StartSanitizeDisks

func (s *DiskSanitizer) StartSanitizeDisks()

StartSanitizeDisks main entrypoint of the cleanup package