dbclusterwf

package

v1.0.0 Latest Latest Go to latest Published: Oct 15, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func CheckInstall(obj statemachine.StateResource) (*statemachine.Event, error)

func GetDbClusterWfManager() *wfengine.WfManager

type CreateStep1 struct {
	DbClusterStepBase
}

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

type CreateStep2 struct {
	DbClusterStepBase
}

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

type DbClusterStepBase struct {
	wfengine.StepAction
	Resource *corev1.ConfigMap
}

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

func (s *DbClusterStepBase) Init(ctx map[string]interface{}, logger logr.Logger) error

func (s *DbClusterStepBase) Output(logger logr.Logger) map[string]interface{}

type DbResource struct {
	implement.KubeResource
	Logger logr.Logger
}

func (s *DbResource) Fetch() (statemachine.StateResource, error)

Fetch 重新获取资源

func (s *DbResource) GetDbCluster() *corev1.ConfigMap

func (s *DbResource) GetScheme() *runtime.Scheme

GetScheme ...

func (s *DbResource) GetState() statemachine.State

GetState 获取资源当前状态

func (s *DbResource) IsCancelled() bool

func (s *DbResource) Update() error

更新资源信息

func (s *DbResource) UpdateState(state statemachine.State) (statemachine.StateResource, error)

UpdateState 更新资源当前状态(string)