Versions in this module Expand all Collapse all v1 v1.0.0 Oct 15, 2021 Changes in this version + var ObjectLockIns = KubeObjectLock + type AnonymousStateMainEnter struct + func (e *AnonymousStateMainEnter) GetName() string + func (e *AnonymousStateMainEnter) MainEnter(obj StateResource) error + type Event struct + Name EventName + Params map[string]interface{} + func CreateEvent(name EventName, params map[string]interface{}) *Event + type EventChecker func(resource StateResource) (*Event, error) + type EventName string + type KubeObjectLock struct + func (dl *KubeObjectLock) GetLock(obj StateResource) *sync.Mutex + type StableStateMainEnter struct + func (ss *StableStateMainEnter) GetName() string + func (ss *StableStateMainEnter) MainEnter(obj StateResource) error + type State string + const StateCreating + const StateInit + const StateInterrupt + const StateNil + const StateRebuild + const StateRunning + type StateMachine struct + Logger logr.Logger + ResourceType string + func CreateStateMachineInstance(resourceType string) *StateMachine + func (sm *StateMachine) CheckSetStateTranslate(nowState State, obj StateResource) (State, error) + func (sm *StateMachine) DoStateMainEnter(obj StateResource) error + func (sm *StateMachine) RegisterIgnoreEvents(ignoreEvents []string) *StateMachine + func (sm *StateMachine) RegisterLogger(logger logr.Logger) *StateMachine + func (sm *StateMachine) RegisterStableState(states ...State) + func (sm *StateMachine) RegisterStateMainEnter(state State, action func(obj StateResource) error) + func (sm *StateMachine) RegisterStateTranslate(beforeState State, eventChecker EventChecker, afterState State) + func (sm *StateMachine) RegisterStateTranslateMainEnter(beforeState State, eventChecker EventChecker, afterState State, ...) + type StateMainEnter interface + GetName func() string + MainEnter func(obj StateResource) error + type StateResource interface + Fetch func() (StateResource, error) + GetName func() string + GetNamespace func() string + GetState func() State + IsCancelled func() bool + UpdateState func(State) (StateResource, error)
Go to main page