Documentation ¶
Index ¶
- Variables
- func GetLocalStorageClusterStateMachine() *statemachine.StateMachine
- func GetLocalStorageClusterWfManager() *wfengine.WfManager
- func GetSharedStorageClusterStateMachine() *statemachine.StateMachine
- func GetSharedStorageClusterWfManager() *wfengine.WfManager
- type LocalStorageClusterStepBase
- type MpdClusterResource
- func (s *MpdClusterResource) Fetch() (statemachine.StateResource, error)
- func (s *MpdClusterResource) GetMpdCluster() *v1.MPDCluster
- func (s *MpdClusterResource) GetScheme() *runtime.Scheme
- func (s *MpdClusterResource) GetState() statemachine.State
- func (s *MpdClusterResource) IsCancelled() bool
- func (s *MpdClusterResource) Update() error
- func (s *MpdClusterResource) UpdateState(state statemachine.State) (statemachine.StateResource, error)
- type SharedStorageClusterStepBase
Constants ¶
This section is empty.
Variables ¶
View Source
var ResourceType = "shared"
Functions ¶
func GetLocalStorageClusterStateMachine ¶
func GetLocalStorageClusterStateMachine() *statemachine.StateMachine
func GetSharedStorageClusterStateMachine ¶
func GetSharedStorageClusterStateMachine() *statemachine.StateMachine
Types ¶
type LocalStorageClusterStepBase ¶
type LocalStorageClusterStepBase struct { wfengine.StepAction Resource *v1.MPDCluster Service *service.LocalStorageClusterService Model *domain.LocalStorageCluster }
type MpdClusterResource ¶
type MpdClusterResource struct { implement.KubeResource Logger logr.Logger }
func (*MpdClusterResource) Fetch ¶
func (s *MpdClusterResource) Fetch() (statemachine.StateResource, error)
Fetch 重新获取资源
func (*MpdClusterResource) GetMpdCluster ¶
func (s *MpdClusterResource) GetMpdCluster() *v1.MPDCluster
func (*MpdClusterResource) GetScheme ¶
func (s *MpdClusterResource) GetScheme() *runtime.Scheme
GetScheme ...
func (*MpdClusterResource) GetState ¶
func (s *MpdClusterResource) GetState() statemachine.State
GetState 获取资源当前状态
func (*MpdClusterResource) IsCancelled ¶
func (s *MpdClusterResource) IsCancelled() bool
func (*MpdClusterResource) UpdateState ¶
func (s *MpdClusterResource) UpdateState(state statemachine.State) (statemachine.StateResource, error)
UpdateState 更新资源当前状态(string)
Click to show internal directories.
Click to hide internal directories.