dbclusterwf

Documentation

Index

• func CheckInstall(obj statemachine.StateResource) (*statemachine.Event, error)
• func GetDbClusterWfManager() *wfengine.WfManager
• type CreateStep1
  • func (step *CreateStep1) DoStep(ctx context.Context, logger logr.Logger) error
• type CreateStep2
  • func (step *CreateStep2) DoStep(ctx context.Context, logger logr.Logger) error
• type DbClusterStepBase
  • 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
  • func (s *DbResource) Fetch() (statemachine.StateResource, error)
  • func (s *DbResource) GetDbCluster() *corev1.ConfigMap
  • func (s *DbResource) GetScheme() *runtime.Scheme
  • func (s *DbResource) GetState() statemachine.State
  • func (s *DbResource) IsCancelled() bool
  • func (s *DbResource) Update() error
  • func (s *DbResource) UpdateState(state statemachine.State) (statemachine.StateResource, error)

Functions

func CheckInstall

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

func GetDbClusterWfManager

func GetDbClusterWfManager() *wfengine.WfManager

Types

type CreateStep1

type CreateStep1 struct {
	DbClusterStepBase
}

func (*CreateStep1) DoStep

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

type CreateStep2

type CreateStep2 struct {
	DbClusterStepBase
}

func (*CreateStep2) DoStep

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

type DbClusterStepBase

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

func (*DbClusterStepBase) DoStep

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

func (*DbClusterStepBase) Init

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

func (*DbClusterStepBase) Output

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

type DbResource

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

func (*DbResource) Fetch

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

Fetch 重新获取资源

func (*DbResource) GetDbCluster

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

func (*DbResource) GetScheme

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

GetScheme ...

func (*DbResource) GetState

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

GetState 获取资源当前状态

func (*DbResource) IsCancelled

func (s *DbResource) IsCancelled() bool

func (*DbResource) Update

func (s *DbResource) Update() error

更新资源信息

func (*DbResource) UpdateState

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

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