workflow_shared

package
v0.0.0-...-693d502 Latest Latest
Warning

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

Go to latest
Published: May 9, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetMigrateInfo

func GetMigrateInfo(cluster *v1.MPDCluster) (insId string, targetNode string)

func Register

func Register()

Types

type CleanAllTempMeta

type CleanAllTempMeta struct {
	wf.SharedStorageClusterStepBase
}

func (*CleanAllTempMeta) DoStep

func (step *CleanAllTempMeta) DoStep(ctx context.Context, logger logr.Logger) error

type CleanModifyClassTempMeta

type CleanModifyClassTempMeta struct {
	wf.SharedStorageClusterStepBase
}

func (*CleanModifyClassTempMeta) DoStep

func (step *CleanModifyClassTempMeta) DoStep(ctx context.Context, logger logr.Logger) error

type CleanOldTempMeta

type CleanOldTempMeta struct {
	wf.SharedStorageClusterStepBase
}

func (*CleanOldTempMeta) DoStep

func (step *CleanOldTempMeta) DoStep(ctx context.Context, logger logr.Logger) error

type CleanTempRoMeta

type CleanTempRoMeta struct {
	wf.SharedStorageClusterStepBase
}

func (*CleanTempRoMeta) DoStep

func (step *CleanTempRoMeta) DoStep(ctx context.Context, logger logr.Logger) error

type CleanUpgradeTempMeta

type CleanUpgradeTempMeta struct {
	wf.SharedStorageClusterStepBase
}

func (*CleanUpgradeTempMeta) DoStep

func (step *CleanUpgradeTempMeta) DoStep(ctx context.Context, logger logr.Logger) error

type ConvertTempRoToRo

type ConvertTempRoToRo struct {
	wf.SharedStorageClusterStepBase
}

func (*ConvertTempRoToRo) DoStep

func (step *ConvertTempRoToRo) DoStep(ctx context.Context, logger logr.Logger) error

type CreateClusterManager

type CreateClusterManager struct {
	wf.SharedStorageClusterStepBase
}

func (*CreateClusterManager) DoStep

func (step *CreateClusterManager) DoStep(ctx context.Context, logger logr.Logger) error

type CreateNetwork

type CreateNetwork struct {
	wf.SharedStorageClusterStepBase
}

func (*CreateNetwork) DoStep

func (step *CreateNetwork) DoStep(ctx context.Context, logger logr.Logger) error

type CreateRoPods

type CreateRoPods struct {
	wf.SharedStorageClusterStepBase
}

func (*CreateRoPods) DoStep

func (step *CreateRoPods) DoStep(ctx context.Context, logger logr.Logger) error

type CreateRwPod

type CreateRwPod struct {
	wf.SharedStorageClusterStepBase
}

func (*CreateRwPod) DoStep

func (step *CreateRwPod) DoStep(ctx context.Context, logger logr.Logger) error

type CreateTempRoForRw

type CreateTempRoForRw struct {
	wf.SharedStorageClusterStepBase
}

func (*CreateTempRoForRw) DoStep

func (step *CreateTempRoForRw) DoStep(ctx context.Context, logger logr.Logger) error

type DeleteOldRw

type DeleteOldRw struct {
	wf.SharedStorageClusterStepBase
}

func (*DeleteOldRw) DoStep

func (step *DeleteOldRw) DoStep(ctx context.Context, logger logr.Logger) error

type DisableHA

type DisableHA struct {
	wf.SharedStorageClusterStepBase
}

func (*DisableHA) DoStep

func (step *DisableHA) DoStep(ctx context.Context, logger logr.Logger) error

type EnableHA

type EnableHA struct {
	wf.SharedStorageClusterStepBase
}

func (*EnableHA) DoStep

func (step *EnableHA) DoStep(ctx context.Context, logger logr.Logger) error

type EnsureCmRwAffinity

type EnsureCmRwAffinity struct {
	wf.SharedStorageClusterStepBase
}

func (*EnsureCmRwAffinity) DoStep

func (step *EnsureCmRwAffinity) DoStep(ctx context.Context, logger logr.Logger) error

type EnsureNewRoUpToDate

type EnsureNewRoUpToDate struct {
	wf.SharedStorageClusterStepBase
}

func (*EnsureNewRoUpToDate) DoStep

func (step *EnsureNewRoUpToDate) DoStep(ctx context.Context, logger logr.Logger) error

type EnsureRoMigrate

type EnsureRoMigrate struct {
	wf.SharedStorageClusterStepBase
}

func (*EnsureRoMigrate) DoStep

func (step *EnsureRoMigrate) DoStep(ctx context.Context, logger logr.Logger) error

type ExtendStorageFs

type ExtendStorageFs struct {
	wf.SharedStorageClusterStepBase
}

func (*ExtendStorageFs) DoStep

func (s *ExtendStorageFs) DoStep(ctx context.Context, logger logr.Logger) error

type FlushParams

type FlushParams struct {
	wf.SharedStorageClusterStepBase
}

func (*FlushParams) DoStep

func (step *FlushParams) DoStep(ctx context.Context, logger logr.Logger) error

type FlushParamsIfNecessary

type FlushParamsIfNecessary struct {
	wf.SharedStorageClusterStepBase
}

func (*FlushParamsIfNecessary) DoStep

func (step *FlushParamsIfNecessary) DoStep(ctx context.Context, logger logr.Logger) error

type GenerateAddRoTempId

type GenerateAddRoTempId struct {
	wf.SharedStorageClusterStepBase
}

func (*GenerateAddRoTempId) DoStep

func (step *GenerateAddRoTempId) DoStep(ctx context.Context, logger logr.Logger) error

type GenerateMigrateTempId

type GenerateMigrateTempId struct {
	wf.SharedStorageClusterStepBase
}

func (*GenerateMigrateTempId) DoStep

func (step *GenerateMigrateTempId) DoStep(ctx context.Context, logger logr.Logger) error

type GenerateRebuildRoTempId

type GenerateRebuildRoTempId struct {
	wf.SharedStorageClusterStepBase
}

func (*GenerateRebuildRoTempId) DoStep

func (step *GenerateRebuildRoTempId) DoStep(ctx context.Context, logger logr.Logger) error

type GenerateTempRoIds

type GenerateTempRoIds struct {
	wf.SharedStorageClusterStepBase
}

func (*GenerateTempRoIds) DoStep

func (step *GenerateTempRoIds) DoStep(ctx context.Context, logger logr.Logger) error

type InitMeta

type InitMeta struct {
	wf.SharedStorageClusterStepBase
}

func (*InitMeta) DoStep

func (step *InitMeta) DoStep(ctx context.Context, logger logr.Logger) error

type InitTempRoMeta

type InitTempRoMeta struct {
	wf.SharedStorageClusterStepBase
}

func (*InitTempRoMeta) DoStep

func (step *InitTempRoMeta) DoStep(ctx context.Context, logger logr.Logger) error

type InitUpgradeImages

type InitUpgradeImages struct {
	wf.SharedStorageClusterStepBase
}

func (*InitUpgradeImages) DoStep

func (step *InitUpgradeImages) DoStep(ctx context.Context, logger logr.Logger) error

type PrepareStorage

type PrepareStorage struct {
	wf.SharedStorageClusterStepBase
}

func (*PrepareStorage) DoStep

func (step *PrepareStorage) DoStep(ctx context.Context, logger logr.Logger) error

type RemoveAllInsPod

type RemoveAllInsPod struct {
	wf.SharedStorageClusterStepBase
}

func (*RemoveAllInsPod) DoStep

func (step *RemoveAllInsPod) DoStep(ctx context.Context, logger logr.Logger) error

type RemoveClusterManager

type RemoveClusterManager struct {
	wf.SharedStorageClusterStepBase
}

func (*RemoveClusterManager) DoStep

func (step *RemoveClusterManager) DoStep(ctx context.Context, logger logr.Logger) error

type RemoveRo

type RemoveRo struct {
	wf.SharedStorageClusterStepBase
}

func (*RemoveRo) DoStep

func (step *RemoveRo) DoStep(ctx context.Context, logger logr.Logger) error

type RestartCluster

type RestartCluster struct {
	wf.SharedStorageClusterStepBase
}

func (*RestartCluster) DoStep

func (step *RestartCluster) DoStep(ctx context.Context, logger logr.Logger) error

type RestartClusterIfNeed

type RestartClusterIfNeed struct {
	wf.SharedStorageClusterStepBase
}

func (*RestartClusterIfNeed) DoStep

func (step *RestartClusterIfNeed) DoStep(ctx context.Context, logger logr.Logger) error

type RestartIns

type RestartIns struct {
	wf.SharedStorageClusterStepBase
}

func (*RestartIns) DoStep

func (step *RestartIns) DoStep(ctx context.Context, logger logr.Logger) error

type SaveParamsLastUpdateTime

type SaveParamsLastUpdateTime struct {
	wf.SharedStorageClusterStepBase
}

func (*SaveParamsLastUpdateTime) DoStep

func (step *SaveParamsLastUpdateTime) DoStep(ctx context.Context, logger logr.Logger) error

type SetRebuildTag

type SetRebuildTag struct {
	wf.SharedStorageClusterStepBase
}

func (*SetRebuildTag) DoStep

func (step *SetRebuildTag) DoStep(ctx context.Context, logger logr.Logger) error

type StopOldRo

type StopOldRo struct {
	wf.SharedStorageClusterStepBase
}

func (*StopOldRo) DoStep

func (step *StopOldRo) DoStep(ctx context.Context, logger logr.Logger) error

type SwitchNewRoToRw

type SwitchNewRoToRw struct {
	wf.SharedStorageClusterStepBase
}

func (*SwitchNewRoToRw) DoStep

func (step *SwitchNewRoToRw) DoStep(ctx context.Context, logger logr.Logger) error

type SwitchRw

type SwitchRw struct {
	wf.SharedStorageClusterStepBase
}

func (*SwitchRw) DoStep

func (step *SwitchRw) DoStep(ctx context.Context, logger logr.Logger) error

type UpdateModifyClassMeta

type UpdateModifyClassMeta struct {
	wf.SharedStorageClusterStepBase
}

func (*UpdateModifyClassMeta) DoStep

func (step *UpdateModifyClassMeta) DoStep(ctx context.Context, logger logr.Logger) error

type UpdateRunningStatus

type UpdateRunningStatus struct {
	wf.SharedStorageClusterStepBase
}

func (*UpdateRunningStatus) DoStep

func (step *UpdateRunningStatus) DoStep(ctx context.Context, logger logr.Logger) error

type UpgradeCmVersion

type UpgradeCmVersion struct {
	wf.SharedStorageClusterStepBase
}

func (*UpgradeCmVersion) DoStep

func (step *UpgradeCmVersion) DoStep(ctx context.Context, logger logr.Logger) error

Jump to

Keyboard shortcuts

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