steps

Documentation

Index

• type ClusterStepManager
  • func (s *ClusterStepManager) CheckAndSetFinalizer() kube.BindFunc
  • func (s *ClusterStepManager) HandleDelete() kube.BindFunc
  • func (s *ClusterStepManager) InitObservedInstance() kube.BindFunc
  • func (s *ClusterStepManager) ScaleDown() kube.BindFunc
  • func (s *ClusterStepManager) ScaleUp() kube.BindFunc
  • func (s *ClusterStepManager) SetGlobalConfig() kube.BindFunc
  • func (s *ClusterStepManager) StepBinder(name string, f Step) kube.BindFunc
  • func (s *ClusterStepManager) StepIfBinder(conditionName string, condFunc Condition, binders ...kube.BindFunc) kube.BindFunc
• type ClusterStepper
• type Condition
• type ConditionFunc
• type InstanceStepManager
  • func (s *InstanceStepManager) CheckAndSetFinalizer() kube.BindFunc
  • func (s *InstanceStepManager) HandleDelete() kube.BindFunc
  • func (s *InstanceStepManager) InitObservedInstance() kube.BindFunc
  • func (s *InstanceStepManager) PatchKDBInstance() kube.BindFunc
  • func (s *InstanceStepManager) PatchKDBInstanceStatus() kube.BindFunc
  • func (s *InstanceStepManager) ScaleDownInstance() kube.BindFunc
  • func (s *InstanceStepManager) ScaleUpInstance() kube.BindFunc
  • func (s *InstanceStepManager) SetGlobalConfig() kube.BindFunc
  • func (s *InstanceStepManager) SetInstanceConfig() kube.BindFunc
  • func (s *InstanceStepManager) SetMonitor() kube.BindFunc
  • func (s *InstanceStepManager) SetRbac() kube.BindFunc
  • func (s *InstanceStepManager) SetService() kube.BindFunc
  • func (s *InstanceStepManager) StepBinder(name string, f StepFunc) kube.BindFunc
  • func (s *InstanceStepManager) StepIfBinder(conditionName string, condFunc ConditionFunc, binders ...kube.BindFunc) kube.BindFunc
• type InstanceStepper
• type Step
• type StepFunc

Types

type ClusterStepManager

type ClusterStepManager struct {
}

func (*ClusterStepManager) CheckAndSetFinalizer

func (s *ClusterStepManager) CheckAndSetFinalizer() kube.BindFunc

CheckAndSetFinalizer check if the Finalizer exists, if not, add it

func (*ClusterStepManager) HandleDelete

func (s *ClusterStepManager) HandleDelete() kube.BindFunc

HandleDelete sets a finalizer on cluster and performs the finalization of cluster when it is being deleted. It returns (nil, nil) when cluster is not being deleted. The caller is responsible for returning other values to controller-runtime.

func (*ClusterStepManager) InitObservedInstance

func (s *ClusterStepManager) InitObservedInstance() kube.BindFunc

func (*ClusterStepManager) ScaleDown

func (s *ClusterStepManager) ScaleDown() kube.BindFunc

func (*ClusterStepManager) ScaleUp

func (s *ClusterStepManager) ScaleUp() kube.BindFunc

func (*ClusterStepManager) SetGlobalConfig

func (s *ClusterStepManager) SetGlobalConfig() kube.BindFunc

SetGlobalConfig including configuration information such as Root certificate, username and password

func (*ClusterStepManager) StepBinder

func (s *ClusterStepManager) StepBinder(name string, f Step) kube.BindFunc

StepBinder bind one step to a task function

func (*ClusterStepManager) StepIfBinder

func (s *ClusterStepManager) StepIfBinder(conditionName string, condFunc Condition, binders ...kube.BindFunc) kube.BindFunc

StepIfBinder bind one condition step to a task function

type ClusterStepper

type ClusterStepper interface {
	StepBinder(name string, f StepFunc) kube.BindFunc
	StepIfBinder(conditionName string, condFunc ConditionFunc, binders ...kube.BindFunc) kube.BindFunc
	CheckAndSetFinalizer() kube.BindFunc
	HandleDelete() kube.BindFunc
	SetGlobalConfig() kube.BindFunc
	SetInstanceConfig() kube.BindFunc
	ScaleUp() kube.BindFunc
	ScaleDown() kube.BindFunc
}

type Condition

type Condition func(rc *context.ClusterContext, log logr.Logger) (bool, error)

type ConditionFunc

type ConditionFunc func(rc *context.InstanceContext, log logr.Logger) (bool, error)

type InstanceStepManager

type InstanceStepManager struct {
}

func (*InstanceStepManager) CheckAndSetFinalizer

func (s *InstanceStepManager) CheckAndSetFinalizer() kube.BindFunc

CheckAndSetFinalizer check if the Finalizer exists, if not, add it

func (*InstanceStepManager) HandleDelete

func (s *InstanceStepManager) HandleDelete() kube.BindFunc

HandleDelete sets a finalizer on cluster and performs the finalization of cluster when it is being deleted. It returns (nil, nil) when cluster is not being deleted. The caller is responsible for returning other values to controller-runtime.

func (*InstanceStepManager) InitObservedInstance

func (s *InstanceStepManager) InitObservedInstance() kube.BindFunc

func (*InstanceStepManager) PatchKDBInstance

func (s *InstanceStepManager) PatchKDBInstance() kube.BindFunc

PatchKDBInstance patch instance

func (*InstanceStepManager) PatchKDBInstanceStatus

func (s *InstanceStepManager) PatchKDBInstanceStatus() kube.BindFunc

PatchKDBInstanceStatus patch instance status

func (*InstanceStepManager) ScaleDownInstance

func (s *InstanceStepManager) ScaleDownInstance() kube.BindFunc

func (*InstanceStepManager) ScaleUpInstance

func (s *InstanceStepManager) ScaleUpInstance() kube.BindFunc

func (*InstanceStepManager) SetGlobalConfig

func (s *InstanceStepManager) SetGlobalConfig() kube.BindFunc

SetGlobalConfig including configuration information such as Root certificate, username and password

func (*InstanceStepManager) SetInstanceConfig

func (s *InstanceStepManager) SetInstanceConfig() kube.BindFunc

func (*InstanceStepManager) SetMonitor

func (s *InstanceStepManager) SetMonitor() kube.BindFunc

func (*InstanceStepManager) SetRbac

func (s *InstanceStepManager) SetRbac() kube.BindFunc

func (*InstanceStepManager) SetService

func (s *InstanceStepManager) SetService() kube.BindFunc

func (*InstanceStepManager) StepBinder

func (s *InstanceStepManager) StepBinder(name string, f StepFunc) kube.BindFunc

StepBinder bind one step to a task function

func (*InstanceStepManager) StepIfBinder

func (s *InstanceStepManager) StepIfBinder(conditionName string, condFunc ConditionFunc, binders ...kube.BindFunc) kube.BindFunc

StepIfBinder bind one condition step to a task function

type InstanceStepper

type InstanceStepper interface {
	StepBinder(name string, f StepFunc) kube.BindFunc
	StepIfBinder(conditionName string, condFunc ConditionFunc, binders ...kube.BindFunc) kube.BindFunc
	PatchKDBInstanceStatus() kube.BindFunc
	PatchKDBInstance() kube.BindFunc
	CheckAndSetFinalizer() kube.BindFunc
	HandleDelete() kube.BindFunc
	SetGlobalConfig() kube.BindFunc
	SetInstanceConfig() kube.BindFunc
	SetRbac() kube.BindFunc
	InitObservedInstance() kube.BindFunc
	SetService() kube.BindFunc
	ScaleUpInstance() kube.BindFunc
	ScaleDownInstance() kube.BindFunc
	SetMonitor() kube.BindFunc
}

type Step

type Step func(rc *context.ClusterContext, flow kube.Flow) (reconcile.Result, error)

type StepFunc

type StepFunc func(rc *context.InstanceContext, flow kube.Flow) (reconcile.Result, error)