Versions in this module Expand all Collapse all v1 v1.0.0 Oct 15, 2021 Changes in this version + func CheckInstall(obj statemachine.StateResource) (*statemachine.Event, error) + func GetDbClusterWfManager() *wfengine.WfManager + type CreateStep1 struct + func (step *CreateStep1) DoStep(ctx context.Context, logger logr.Logger) error + type CreateStep2 struct + func (step *CreateStep2) DoStep(ctx context.Context, logger logr.Logger) error + type DbClusterStepBase struct + 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 + Logger logr.Logger + 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)