Versions in this module Expand all Collapse all v1 v1.0.0 Oct 15, 2021 Changes in this version + const EventsReasonFormat + const WorkFlowJobConfigMapTag + func CreateDefaultWfMetaLoader(resourceType string) (wfengine.WfMetaLoader, error) + func CreateDefaultWorkflowHook(wfRuntime *wfengine.WfRuntime) (wfengine.WfHook, error) + func GetDefaultMementoStorageFactory(resourceType string, enableEvent bool) wfengine.CreateMementoStorageFunc + type DefaultHistoryRecorder struct + func CreateDefaultHistoryRecorder(resourceType string, logger logr.Logger, logDir string) *DefaultHistoryRecorder + func (r *DefaultHistoryRecorder) WriteWorkflowStepLog(flow *wfengine.WfRuntime, step *wfengine.StepRuntime, stepType StepType) + type DefaultMementoStorage struct + func (s *DefaultMementoStorage) LoadMementoMap(careTakerName string) (map[string]string, error) + func (s *DefaultMementoStorage) Save(mementoKey, mementoContent string) error + type DefaultRecover struct + func CreateDefaultRecover() *DefaultRecover + func (*DefaultRecover) CancelResourceRecover(resource statemachine.StateResource, conf map[define.WFConfKey]string) error + func (*DefaultRecover) GetResourceRecoverInfo(resource statemachine.StateResource, conf map[define.WFConfKey]string) (recover bool, preStatus statemachine.State) + func (*DefaultRecover) SaveResourceInterruptInfo(resource statemachine.StateResource, conf map[define.WFConfKey]string, ...) error + type DefaultWfMetaLoader struct + func (l *DefaultWfMetaLoader) GetAllFlowMeta(workFlowMetaDir string) (map[string]*wfengine.FlowMeta, map[string]*wfengine.StepGroupMeta, error) + type DefaultWorkflowHook struct + func (wfh DefaultWorkflowHook) OnStepCompleted(step *wfengine.StepRuntime) error + func (wfh DefaultWorkflowHook) OnStepInit(step *wfengine.StepRuntime) error + func (wfh DefaultWorkflowHook) OnStepWaiting(step *wfengine.StepRuntime) error + func (wfh DefaultWorkflowHook) OnWfCompleted() error + func (wfh DefaultWorkflowHook) OnWfInit() error + func (wfh DefaultWorkflowHook) OnWfInterrupt(err *define.InterruptError) error + type StepType string + const StepCompleted + const StepError + const StepInited + const StepWaiting + const WorkFlowCompleted + const WorkFlowInterrupt + const WorkFlowStart + type WorkflowStep struct + EndTime string + Error string + ExtraCtx map[string]string + FlowName string + Namespace string + ResourceName string + Retry int + StartTime string + Step int + StepCount int + StepID string + StepName string + Type StepType + WorkflowID string