manager

package

v0.1.0 Latest Latest Go to latest Published: Jun 28, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/hwameistor/reliable-helper-system

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func New(mgr mgrpkg.Manager) (apis.ReplaceDiskManager, error)
func NewLVMExecutor() *lvmExecutor
type ReplaceDiskHandler
- func NewReplaceDiskHandler(client client.Client, recorder record.EventRecorder) *ReplaceDiskHandler

Constants ¶

View Source

const (
	APIVersion             = "v1alpha1"
	ReplaceDiskKind        = "ReplaceDisk"
	ReplaceDiskAPIVersion  = "hwameistor.io" + "/" + APIVersion
	MigrateType_DataRepair = "DataRepair"
	MigrateType_BackUp     = "BackUp"
)

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(mgr mgrpkg.Manager) (apis.ReplaceDiskManager, error)

New replacedisk manager

func NewLVMExecutor ¶

func NewLVMExecutor() *lvmExecutor

Types ¶

type ReplaceDiskHandler ¶

type ReplaceDiskHandler struct {
	client.Client
	record.EventRecorder
	ReplaceDisk apisv1alpha1.ReplaceDisk
}

ReplaceDiskHandler

func NewReplaceDiskHandler ¶

func NewReplaceDiskHandler(client client.Client, recorder record.EventRecorder) *ReplaceDiskHandler

NewReplaceDiskHandler

func (*ReplaceDiskHandler) CheckReplaceDiskTaskDestroyed ¶

func (rdHandler *ReplaceDiskHandler) CheckReplaceDiskTaskDestroyed(rd apisv1alpha1.ReplaceDisk) bool

SetReplaceDisk

func (*ReplaceDiskHandler) GetReplaceDisk ¶

func (rdHandler *ReplaceDiskHandler) GetReplaceDisk(key client.ObjectKey) (*apisv1alpha1.ReplaceDisk, error)

GetReplaceDisk

func (*ReplaceDiskHandler) ListReplaceDisk ¶

func (rdHandler *ReplaceDiskHandler) ListReplaceDisk() (*apisv1alpha1.ReplaceDiskList, error)

ListReplaceDisk

func (*ReplaceDiskHandler) Refresh ¶

func (rdHandler *ReplaceDiskHandler) Refresh() (*ReplaceDiskHandler, error)

Refresh

func (*ReplaceDiskHandler) ReplaceDiskStage ¶

func (rdHandler *ReplaceDiskHandler) ReplaceDiskStage() apisv1alpha1.ReplaceDiskStage

ReplaceDiskStage

func (*ReplaceDiskHandler) ReplaceDiskStatus ¶

func (rdHandler *ReplaceDiskHandler) ReplaceDiskStatus() apisv1alpha1.ReplaceDiskStatus

ReplaceDiskStatus

func (*ReplaceDiskHandler) SetErrMsg ¶

func (rdHandler *ReplaceDiskHandler) SetErrMsg(errMsg string) error

SetErrMsg

func (*ReplaceDiskHandler) SetMigrateBackUpFailededVolumeNames ¶

func (rdHandler *ReplaceDiskHandler) SetMigrateBackUpFailededVolumeNames(volumeNames []string) *ReplaceDiskHandler

SetMigrateBackUpFailededVolumeNames

func (*ReplaceDiskHandler) SetMigrateBackUpSucceededVolumeNames ¶

func (rdHandler *ReplaceDiskHandler) SetMigrateBackUpSucceededVolumeNames(volumeNames []string) *ReplaceDiskHandler

SetMigrateBackUpSucceededVolumeNames

func (*ReplaceDiskHandler) SetMigrateFailededVolumeNames ¶

func (rdHandler *ReplaceDiskHandler) SetMigrateFailededVolumeNames(volumeNames []string) *ReplaceDiskHandler

SetMigrateFailededVolumeNames

func (*ReplaceDiskHandler) SetMigrateSucceededVolumeNames ¶

func (rdHandler *ReplaceDiskHandler) SetMigrateSucceededVolumeNames(volumeNames []string) *ReplaceDiskHandler

SetMigrateSucceededVolumeNames

func (*ReplaceDiskHandler) SetMigrateVolumeNames ¶

func (rdHandler *ReplaceDiskHandler) SetMigrateVolumeNames(volumeNames []string) *ReplaceDiskHandler

SetReplaceDisk

func (*ReplaceDiskHandler) SetReplaceDisk ¶

func (rdHandler *ReplaceDiskHandler) SetReplaceDisk(rd apisv1alpha1.ReplaceDisk) *ReplaceDiskHandler

SetReplaceDisk

func (*ReplaceDiskHandler) SetReplaceDiskStage ¶

func (rdHandler *ReplaceDiskHandler) SetReplaceDiskStage(stage apisv1alpha1.ReplaceDiskStage) *ReplaceDiskHandler

SetReplaceDiskStage

func (*ReplaceDiskHandler) SetWarnMsg ¶ added in v0.0.4

func (rdHandler *ReplaceDiskHandler) SetWarnMsg(warnMsg string) error

SetWarnMsg

func (*ReplaceDiskHandler) UpdateReplaceDiskCR ¶

func (rdHandler *ReplaceDiskHandler) UpdateReplaceDiskCR() error

UpdateReplaceDiskCR

func (*ReplaceDiskHandler) UpdateReplaceDiskStatus ¶

func (rdHandler *ReplaceDiskHandler) UpdateReplaceDiskStatus(status apisv1alpha1.ReplaceDiskStatus) error

UpdateReplaceDiskStatus

Source Files ¶

View all Source files

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