Versions in this module Expand all Collapse all v1 v1.0.0 Oct 15, 2021 Changes in this version + type MockRecover struct + func NewMockRecover(ctrl *gomock.Controller) *MockRecover + func (m *MockRecover) CancelResourceRecover(resource statemachine.StateResource, conf map[define.WFConfKey]string) error + func (m *MockRecover) EXPECT() *MockRecoverMockRecorder + func (m *MockRecover) GetResourceRecoverInfo(resource statemachine.StateResource, conf map[define.WFConfKey]string) (bool, statemachine.State) + func (m *MockRecover) SaveResourceInterruptInfo(resource statemachine.StateResource, conf map[define.WFConfKey]string, ...) error + type MockRecoverMockRecorder struct + func (mr *MockRecoverMockRecorder) CancelResourceRecover(resource, conf interface{}) *gomock.Call + func (mr *MockRecoverMockRecorder) GetResourceRecoverInfo(resource, conf interface{}) *gomock.Call + func (mr *MockRecoverMockRecorder) SaveResourceInterruptInfo(resource, conf, reason, message, prevState interface{}) *gomock.Call + type MockStateMainEnter struct + func NewMockStateMainEnter(ctrl *gomock.Controller) *MockStateMainEnter + func (m *MockStateMainEnter) EXPECT() *MockStateMainEnterMockRecorder + func (m *MockStateMainEnter) GetName() string + func (m *MockStateMainEnter) MainEnter(obj statemachine.StateResource) error + type MockStateMainEnterMockRecorder struct + func (mr *MockStateMainEnterMockRecorder) GetName() *gomock.Call + func (mr *MockStateMainEnterMockRecorder) MainEnter(obj interface{}) *gomock.Call + type MockStateResource struct + func NewMockStateResource(ctrl *gomock.Controller) *MockStateResource + func (m *MockStateResource) EXPECT() *MockStateResourceMockRecorder + func (m *MockStateResource) Fetch() (statemachine.StateResource, error) + func (m *MockStateResource) GetName() string + func (m *MockStateResource) GetNamespace() string + func (m *MockStateResource) GetState() statemachine.State + func (m *MockStateResource) IsCancelled() bool + func (m *MockStateResource) UpdateState(arg0 statemachine.State) (statemachine.StateResource, error) + type MockStateResourceMockRecorder struct + func (mr *MockStateResourceMockRecorder) Fetch() *gomock.Call + func (mr *MockStateResourceMockRecorder) GetName() *gomock.Call + func (mr *MockStateResourceMockRecorder) GetNamespace() *gomock.Call + func (mr *MockStateResourceMockRecorder) GetState() *gomock.Call + func (mr *MockStateResourceMockRecorder) IsCancelled() *gomock.Call + func (mr *MockStateResourceMockRecorder) UpdateState(arg0 interface{}) *gomock.Call + type MockStepAction struct + func NewMockStepAction(ctrl *gomock.Controller) *MockStepAction + func (m *MockStepAction) DoStep(arg0 context.Context, arg1 logr.Logger) error + func (m *MockStepAction) EXPECT() *MockStepActionMockRecorder + func (m *MockStepAction) Init(arg0 map[string]interface{}, arg1 logr.Logger) error + func (m *MockStepAction) Output(arg0 logr.Logger) map[string]interface{} + type MockStepActionMockRecorder struct + func (mr *MockStepActionMockRecorder) DoStep(arg0, arg1 interface{}) *gomock.Call + func (mr *MockStepActionMockRecorder) Init(arg0, arg1 interface{}) *gomock.Call + func (mr *MockStepActionMockRecorder) Output(arg0 interface{}) *gomock.Call + type MockWfHook struct + func NewMockWfHook(ctrl *gomock.Controller) *MockWfHook + func (m *MockWfHook) EXPECT() *MockWfHookMockRecorder + func (m *MockWfHook) OnStepCompleted(step *wfengine.StepRuntime) error + func (m *MockWfHook) OnStepInit(step *wfengine.StepRuntime) error + func (m *MockWfHook) OnStepWaiting(step *wfengine.StepRuntime) error + func (m *MockWfHook) OnWfCompleted() error + func (m *MockWfHook) OnWfInit() error + func (m *MockWfHook) OnWfInterrupt(arg0 *define.InterruptError) error + type MockWfHookMockRecorder struct + func (mr *MockWfHookMockRecorder) OnStepCompleted(step interface{}) *gomock.Call + func (mr *MockWfHookMockRecorder) OnStepInit(step interface{}) *gomock.Call + func (mr *MockWfHookMockRecorder) OnStepWaiting(step interface{}) *gomock.Call + func (mr *MockWfHookMockRecorder) OnWfCompleted() *gomock.Call + func (mr *MockWfHookMockRecorder) OnWfInit() *gomock.Call + func (mr *MockWfHookMockRecorder) OnWfInterrupt(arg0 interface{}) *gomock.Call + type MockWfMetaLoader struct + func NewMockWfMetaLoader(ctrl *gomock.Controller) *MockWfMetaLoader + func (m *MockWfMetaLoader) EXPECT() *MockWfMetaLoaderMockRecorder + func (m *MockWfMetaLoader) GetAllFlowMeta(workFlowMetaDir string) (map[string]*wfengine.FlowMeta, map[string]*wfengine.StepGroupMeta, error) + type MockWfMetaLoaderMockRecorder struct + func (mr *MockWfMetaLoaderMockRecorder) GetAllFlowMeta(workFlowMetaDir interface{}) *gomock.Call + type MockWfRuntimeMementoStorage struct + func NewMockWfRuntimeMementoStorage(ctrl *gomock.Controller) *MockWfRuntimeMementoStorage + func (m *MockWfRuntimeMementoStorage) EXPECT() *MockWfRuntimeMementoStorageMockRecorder + func (m *MockWfRuntimeMementoStorage) LoadMementoMap(careTakerName string) (map[string]string, error) + func (m *MockWfRuntimeMementoStorage) Save(mementoKey, mementoContent string) error + type MockWfRuntimeMementoStorageMockRecorder struct + func (mr *MockWfRuntimeMementoStorageMockRecorder) LoadMementoMap(careTakerName interface{}) *gomock.Call + func (mr *MockWfRuntimeMementoStorageMockRecorder) Save(mementoKey, mementoContent interface{}) *gomock.Call
Go to main page