workflow

Nov 19, 2023

Changes in this version

type MockNatsService

+ func (_m *MockNatsService) Heartbeat(ctx context.Context, request *model.HeartbeatRequest) error

type MockNatsService_Expecter

+ func (_e *MockNatsService_Expecter) Heartbeat(ctx interface{}, request interface{}) *MockNatsService_Heartbeat_Call

+ type MockNatsService_Heartbeat_Call struct

+ func (_c *MockNatsService_Heartbeat_Call) Return(_a0 error) *MockNatsService_Heartbeat_Call

+ func (_c *MockNatsService_Heartbeat_Call) Run(run func(ctx context.Context, request *model.HeartbeatRequest)) *MockNatsService_Heartbeat_Call

+ func (_c *MockNatsService_Heartbeat_Call) RunAndReturn(run func(context.Context, *model.HeartbeatRequest) error) *MockNatsService_Heartbeat_Call

type NatsService

+ Heartbeat func(ctx context.Context, request *model.HeartbeatRequest) error

Nov 16, 2023

Changes in this version

+ type MockNatsService struct

+ func NewMockNatsService(t interface{ ... }) *MockNatsService

+ func (_m *MockNatsService) CheckProcessTaskDeprecation(ctx context.Context, workflow *model.Workflow, processName string) error

+ func (_m *MockNatsService) CloseUserTask(ctx context.Context, trackingID string) error

+ func (_m *MockNatsService) Conn() common.NatsConn

+ func (_m *MockNatsService) CreateExecution(ctx context.Context, wfInstance *model.Execution) (*model.Execution, error)

+ func (_m *MockNatsService) CreateJob(ctx context.Context, job *model.WorkflowState) (string, error)

+ func (_m *MockNatsService) CreateProcessInstance(ctx context.Context, workflowInstanceID string, parentProcessID string, ...) (*model.ProcessInstance, error)

+ func (_m *MockNatsService) DeleteJob(ctx context.Context, trackingID string) error

+ func (_m *MockNatsService) DestroyProcessInstance(ctx context.Context, state *model.WorkflowState, pi *model.ProcessInstance, ...) error

+ func (_m *MockNatsService) EXPECT() *MockNatsService_Expecter

+ func (_m *MockNatsService) EnsureServiceTaskConsumer(uid string) error

+ func (_m *MockNatsService) GetElement(ctx context.Context, state *model.WorkflowState) (*model.Element, error)

+ func (_m *MockNatsService) GetExecution(ctx context.Context, workflowInstanceID string) (*model.Execution, error)

+ func (_m *MockNatsService) GetGatewayInstance(ctx context.Context, gatewayInstanceID string) (*model.Gateway, error)

+ func (_m *MockNatsService) GetGatewayInstanceID(state *model.WorkflowState) (string, string, error)

+ func (_m *MockNatsService) GetJob(ctx context.Context, id string) (*model.WorkflowState, error)

+ func (_m *MockNatsService) GetLatestVersion(ctx context.Context, workflowName string) (string, error)

+ func (_m *MockNatsService) GetOldState(ctx context.Context, id string) (*model.WorkflowState, error)

+ func (_m *MockNatsService) GetProcessHistory(ctx context.Context, processInstanceId string) ([]*model.ProcessHistoryEntry, error)

+ func (_m *MockNatsService) GetProcessInstance(ctx context.Context, processInstanceID string) (*model.ProcessInstance, error)

+ func (_m *MockNatsService) GetTaskSpecByUID(ctx context.Context, uid string) (*model.TaskSpec, error)

+ func (_m *MockNatsService) GetTaskSpecUID(ctx context.Context, name string) (string, error)

+ func (_m *MockNatsService) GetWorkflow(ctx context.Context, workflowID string) (*model.Workflow, error)

+ func (_m *MockNatsService) GetWorkflowNameFor(ctx context.Context, processName string) (string, error)

+ func (_m *MockNatsService) GetWorkflowVersions(ctx context.Context, workflowName string) (*model.WorkflowVersions, error)

+ func (_m *MockNatsService) ListExecutionProcesses(ctx context.Context, id string) ([]string, error)

+ func (_m *MockNatsService) ListExecutions(ctx context.Context, workflowName string) (chan *model.ListExecutionItem, chan error)

+ func (_m *MockNatsService) ListWorkflows(ctx context.Context) (chan *model.ListWorkflowResponse, chan error)

+ func (_m *MockNatsService) OwnerID(name string) (string, error)

+ func (_m *MockNatsService) OwnerName(id string) (string, error)

+ func (_m *MockNatsService) PublishMessage(ctx context.Context, name string, key string, vars []byte) error

+ func (_m *MockNatsService) PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, ...) error

+ func (_m *MockNatsService) PutTaskSpec(ctx context.Context, spec *model.TaskSpec) (string, error)

+ func (_m *MockNatsService) RecordHistoryActivityComplete(ctx context.Context, state *model.WorkflowState) error

+ func (_m *MockNatsService) RecordHistoryActivityExecute(ctx context.Context, state *model.WorkflowState) error

+ func (_m *MockNatsService) RecordHistoryProcessAbort(ctx context.Context, state *model.WorkflowState) error

+ func (_m *MockNatsService) RecordHistoryProcessComplete(ctx context.Context, state *model.WorkflowState) error

+ func (_m *MockNatsService) RecordHistoryProcessSpawn(ctx context.Context, state *model.WorkflowState, newProcessInstanceID string) error

+ func (_m *MockNatsService) RecordHistoryProcessStart(ctx context.Context, state *model.WorkflowState) error

+ func (_m *MockNatsService) SaveState(ctx context.Context, id string, state *model.WorkflowState) error

+ func (_m *MockNatsService) SetAbort(processor services.AbortFunc)

+ func (_m *MockNatsService) SetCompleteActivity(processor services.CompleteActivityFunc)

+ func (_m *MockNatsService) SetCompleteActivityProcessor(processor services.CompleteActivityProcessorFunc)

+ func (_m *MockNatsService) SetCompleteJobProcessor(processor services.CompleteJobProcessorFunc)

+ func (_m *MockNatsService) SetEventProcessor(processor services.EventProcessorFunc)

+ func (_m *MockNatsService) SetLaunchFunc(processor services.LaunchFunc)

+ func (_m *MockNatsService) SetMessageProcessor(processor services.MessageProcessorFunc)

+ func (_m *MockNatsService) SetTraversalProvider(provider services.TraversalFunc)

+ func (_m *MockNatsService) Shutdown()

+ func (_m *MockNatsService) StartProcessing(ctx context.Context) error

+ func (_m *MockNatsService) StoreWorkflow(ctx context.Context, wf *model.Workflow) (string, error)

+ func (_m *MockNatsService) XDestroyProcessInstance(ctx context.Context, state *model.WorkflowState) error

+ type MockNatsService_CheckProcessTaskDeprecation_Call struct

+ func (_c *MockNatsService_CheckProcessTaskDeprecation_Call) Return(_a0 error) *MockNatsService_CheckProcessTaskDeprecation_Call

+ func (_c *MockNatsService_CheckProcessTaskDeprecation_Call) Run(run func(ctx context.Context, workflow *model.Workflow, processName string)) *MockNatsService_CheckProcessTaskDeprecation_Call

+ func (_c *MockNatsService_CheckProcessTaskDeprecation_Call) RunAndReturn(run func(context.Context, *model.Workflow, string) error) *MockNatsService_CheckProcessTaskDeprecation_Call

+ type MockNatsService_CloseUserTask_Call struct

+ func (_c *MockNatsService_CloseUserTask_Call) Return(_a0 error) *MockNatsService_CloseUserTask_Call

+ func (_c *MockNatsService_CloseUserTask_Call) Run(run func(ctx context.Context, trackingID string)) *MockNatsService_CloseUserTask_Call

+ func (_c *MockNatsService_CloseUserTask_Call) RunAndReturn(run func(context.Context, string) error) *MockNatsService_CloseUserTask_Call

+ type MockNatsService_Conn_Call struct

+ func (_c *MockNatsService_Conn_Call) Return(_a0 common.NatsConn) *MockNatsService_Conn_Call

+ func (_c *MockNatsService_Conn_Call) Run(run func()) *MockNatsService_Conn_Call

+ func (_c *MockNatsService_Conn_Call) RunAndReturn(run func() common.NatsConn) *MockNatsService_Conn_Call

+ type MockNatsService_CreateExecution_Call struct

+ func (_c *MockNatsService_CreateExecution_Call) Return(_a0 *model.Execution, _a1 error) *MockNatsService_CreateExecution_Call

+ func (_c *MockNatsService_CreateExecution_Call) Run(run func(ctx context.Context, wfInstance *model.Execution)) *MockNatsService_CreateExecution_Call

+ func (_c *MockNatsService_CreateExecution_Call) RunAndReturn(run func(context.Context, *model.Execution) (*model.Execution, error)) *MockNatsService_CreateExecution_Call

+ type MockNatsService_CreateJob_Call struct

+ func (_c *MockNatsService_CreateJob_Call) Return(_a0 string, _a1 error) *MockNatsService_CreateJob_Call

+ func (_c *MockNatsService_CreateJob_Call) Run(run func(ctx context.Context, job *model.WorkflowState)) *MockNatsService_CreateJob_Call

+ func (_c *MockNatsService_CreateJob_Call) RunAndReturn(run func(context.Context, *model.WorkflowState) (string, error)) *MockNatsService_CreateJob_Call

+ type MockNatsService_CreateProcessInstance_Call struct

+ func (_c *MockNatsService_CreateProcessInstance_Call) Return(_a0 *model.ProcessInstance, _a1 error) *MockNatsService_CreateProcessInstance_Call

+ func (_c *MockNatsService_CreateProcessInstance_Call) Run(...) *MockNatsService_CreateProcessInstance_Call

+ func (_c *MockNatsService_CreateProcessInstance_Call) RunAndReturn(...) *MockNatsService_CreateProcessInstance_Call

+ type MockNatsService_DeleteJob_Call struct

+ func (_c *MockNatsService_DeleteJob_Call) Return(_a0 error) *MockNatsService_DeleteJob_Call

+ func (_c *MockNatsService_DeleteJob_Call) Run(run func(ctx context.Context, trackingID string)) *MockNatsService_DeleteJob_Call

+ func (_c *MockNatsService_DeleteJob_Call) RunAndReturn(run func(context.Context, string) error) *MockNatsService_DeleteJob_Call

+ type MockNatsService_DestroyProcessInstance_Call struct

+ func (_c *MockNatsService_DestroyProcessInstance_Call) Return(_a0 error) *MockNatsService_DestroyProcessInstance_Call

+ func (_c *MockNatsService_DestroyProcessInstance_Call) Run(...) *MockNatsService_DestroyProcessInstance_Call

+ func (_c *MockNatsService_DestroyProcessInstance_Call) RunAndReturn(...) *MockNatsService_DestroyProcessInstance_Call

+ type MockNatsService_EnsureServiceTaskConsumer_Call struct

+ func (_c *MockNatsService_EnsureServiceTaskConsumer_Call) Return(_a0 error) *MockNatsService_EnsureServiceTaskConsumer_Call

+ func (_c *MockNatsService_EnsureServiceTaskConsumer_Call) Run(run func(uid string)) *MockNatsService_EnsureServiceTaskConsumer_Call

+ func (_c *MockNatsService_EnsureServiceTaskConsumer_Call) RunAndReturn(run func(string) error) *MockNatsService_EnsureServiceTaskConsumer_Call

+ type MockNatsService_Expecter struct

+ func (_e *MockNatsService_Expecter) CheckProcessTaskDeprecation(ctx interface{}, workflow interface{}, processName interface{}) *MockNatsService_CheckProcessTaskDeprecation_Call

+ func (_e *MockNatsService_Expecter) CloseUserTask(ctx interface{}, trackingID interface{}) *MockNatsService_CloseUserTask_Call

+ func (_e *MockNatsService_Expecter) Conn() *MockNatsService_Conn_Call

+ func (_e *MockNatsService_Expecter) CreateExecution(ctx interface{}, wfInstance interface{}) *MockNatsService_CreateExecution_Call

+ func (_e *MockNatsService_Expecter) CreateJob(ctx interface{}, job interface{}) *MockNatsService_CreateJob_Call

+ func (_e *MockNatsService_Expecter) CreateProcessInstance(ctx interface{}, workflowInstanceID interface{}, parentProcessID interface{}, ...) *MockNatsService_CreateProcessInstance_Call

+ func (_e *MockNatsService_Expecter) DeleteJob(ctx interface{}, trackingID interface{}) *MockNatsService_DeleteJob_Call

+ func (_e *MockNatsService_Expecter) DestroyProcessInstance(ctx interface{}, state interface{}, pi interface{}, wi interface{}) *MockNatsService_DestroyProcessInstance_Call

+ func (_e *MockNatsService_Expecter) EnsureServiceTaskConsumer(uid interface{}) *MockNatsService_EnsureServiceTaskConsumer_Call

+ func (_e *MockNatsService_Expecter) GetElement(ctx interface{}, state interface{}) *MockNatsService_GetElement_Call

+ func (_e *MockNatsService_Expecter) GetExecution(ctx interface{}, workflowInstanceID interface{}) *MockNatsService_GetExecution_Call

+ func (_e *MockNatsService_Expecter) GetGatewayInstance(ctx interface{}, gatewayInstanceID interface{}) *MockNatsService_GetGatewayInstance_Call

+ func (_e *MockNatsService_Expecter) GetGatewayInstanceID(state interface{}) *MockNatsService_GetGatewayInstanceID_Call

+ func (_e *MockNatsService_Expecter) GetJob(ctx interface{}, id interface{}) *MockNatsService_GetJob_Call

+ func (_e *MockNatsService_Expecter) GetLatestVersion(ctx interface{}, workflowName interface{}) *MockNatsService_GetLatestVersion_Call

+ func (_e *MockNatsService_Expecter) GetOldState(ctx interface{}, id interface{}) *MockNatsService_GetOldState_Call

+ func (_e *MockNatsService_Expecter) GetProcessHistory(ctx interface{}, processInstanceId interface{}) *MockNatsService_GetProcessHistory_Call

+ func (_e *MockNatsService_Expecter) GetProcessInstance(ctx interface{}, processInstanceID interface{}) *MockNatsService_GetProcessInstance_Call

+ func (_e *MockNatsService_Expecter) GetTaskSpecByUID(ctx interface{}, uid interface{}) *MockNatsService_GetTaskSpecByUID_Call

+ func (_e *MockNatsService_Expecter) GetTaskSpecUID(ctx interface{}, name interface{}) *MockNatsService_GetTaskSpecUID_Call

+ func (_e *MockNatsService_Expecter) GetWorkflow(ctx interface{}, workflowID interface{}) *MockNatsService_GetWorkflow_Call

+ func (_e *MockNatsService_Expecter) GetWorkflowNameFor(ctx interface{}, processName interface{}) *MockNatsService_GetWorkflowNameFor_Call

+ func (_e *MockNatsService_Expecter) GetWorkflowVersions(ctx interface{}, workflowName interface{}) *MockNatsService_GetWorkflowVersions_Call

+ func (_e *MockNatsService_Expecter) ListExecutionProcesses(ctx interface{}, id interface{}) *MockNatsService_ListExecutionProcesses_Call

+ func (_e *MockNatsService_Expecter) ListExecutions(ctx interface{}, workflowName interface{}) *MockNatsService_ListExecutions_Call

+ func (_e *MockNatsService_Expecter) ListWorkflows(ctx interface{}) *MockNatsService_ListWorkflows_Call

+ func (_e *MockNatsService_Expecter) OwnerID(name interface{}) *MockNatsService_OwnerID_Call

+ func (_e *MockNatsService_Expecter) OwnerName(id interface{}) *MockNatsService_OwnerName_Call

+ func (_e *MockNatsService_Expecter) PublishMessage(ctx interface{}, name interface{}, key interface{}, vars interface{}) *MockNatsService_PublishMessage_Call

+ func (_e *MockNatsService_Expecter) PublishWorkflowState(ctx interface{}, stateName interface{}, state interface{}, ops ...interface{}) *MockNatsService_PublishWorkflowState_Call

+ func (_e *MockNatsService_Expecter) PutTaskSpec(ctx interface{}, spec interface{}) *MockNatsService_PutTaskSpec_Call

+ func (_e *MockNatsService_Expecter) RecordHistoryActivityComplete(ctx interface{}, state interface{}) *MockNatsService_RecordHistoryActivityComplete_Call

+ func (_e *MockNatsService_Expecter) RecordHistoryActivityExecute(ctx interface{}, state interface{}) *MockNatsService_RecordHistoryActivityExecute_Call

+ func (_e *MockNatsService_Expecter) RecordHistoryProcessAbort(ctx interface{}, state interface{}) *MockNatsService_RecordHistoryProcessAbort_Call

+ func (_e *MockNatsService_Expecter) RecordHistoryProcessComplete(ctx interface{}, state interface{}) *MockNatsService_RecordHistoryProcessComplete_Call

+ func (_e *MockNatsService_Expecter) RecordHistoryProcessSpawn(ctx interface{}, state interface{}, newProcessInstanceID interface{}) *MockNatsService_RecordHistoryProcessSpawn_Call

+ func (_e *MockNatsService_Expecter) RecordHistoryProcessStart(ctx interface{}, state interface{}) *MockNatsService_RecordHistoryProcessStart_Call

+ func (_e *MockNatsService_Expecter) SaveState(ctx interface{}, id interface{}, state interface{}) *MockNatsService_SaveState_Call

+ func (_e *MockNatsService_Expecter) SetAbort(processor interface{}) *MockNatsService_SetAbort_Call

+ func (_e *MockNatsService_Expecter) SetCompleteActivity(processor interface{}) *MockNatsService_SetCompleteActivity_Call

+ func (_e *MockNatsService_Expecter) SetCompleteActivityProcessor(processor interface{}) *MockNatsService_SetCompleteActivityProcessor_Call

+ func (_e *MockNatsService_Expecter) SetCompleteJobProcessor(processor interface{}) *MockNatsService_SetCompleteJobProcessor_Call

+ func (_e *MockNatsService_Expecter) SetEventProcessor(processor interface{}) *MockNatsService_SetEventProcessor_Call

+ func (_e *MockNatsService_Expecter) SetLaunchFunc(processor interface{}) *MockNatsService_SetLaunchFunc_Call

+ func (_e *MockNatsService_Expecter) SetMessageProcessor(processor interface{}) *MockNatsService_SetMessageProcessor_Call

+ func (_e *MockNatsService_Expecter) SetTraversalProvider(provider interface{}) *MockNatsService_SetTraversalProvider_Call

+ func (_e *MockNatsService_Expecter) Shutdown() *MockNatsService_Shutdown_Call

+ func (_e *MockNatsService_Expecter) StartProcessing(ctx interface{}) *MockNatsService_StartProcessing_Call

+ func (_e *MockNatsService_Expecter) StoreWorkflow(ctx interface{}, wf interface{}) *MockNatsService_StoreWorkflow_Call

+ func (_e *MockNatsService_Expecter) XDestroyProcessInstance(ctx interface{}, state interface{}) *MockNatsService_XDestroyProcessInstance_Call

+ type MockNatsService_GetElement_Call struct

+ func (_c *MockNatsService_GetElement_Call) Return(_a0 *model.Element, _a1 error) *MockNatsService_GetElement_Call

+ func (_c *MockNatsService_GetElement_Call) Run(run func(ctx context.Context, state *model.WorkflowState)) *MockNatsService_GetElement_Call

+ func (_c *MockNatsService_GetElement_Call) RunAndReturn(run func(context.Context, *model.WorkflowState) (*model.Element, error)) *MockNatsService_GetElement_Call

+ type MockNatsService_GetExecution_Call struct

+ func (_c *MockNatsService_GetExecution_Call) Return(_a0 *model.Execution, _a1 error) *MockNatsService_GetExecution_Call

+ func (_c *MockNatsService_GetExecution_Call) Run(run func(ctx context.Context, workflowInstanceID string)) *MockNatsService_GetExecution_Call

+ func (_c *MockNatsService_GetExecution_Call) RunAndReturn(run func(context.Context, string) (*model.Execution, error)) *MockNatsService_GetExecution_Call

+ type MockNatsService_GetGatewayInstanceID_Call struct

+ func (_c *MockNatsService_GetGatewayInstanceID_Call) Return(_a0 string, _a1 string, _a2 error) *MockNatsService_GetGatewayInstanceID_Call

+ func (_c *MockNatsService_GetGatewayInstanceID_Call) Run(run func(state *model.WorkflowState)) *MockNatsService_GetGatewayInstanceID_Call

+ func (_c *MockNatsService_GetGatewayInstanceID_Call) RunAndReturn(run func(*model.WorkflowState) (string, string, error)) *MockNatsService_GetGatewayInstanceID_Call

+ type MockNatsService_GetGatewayInstance_Call struct

+ func (_c *MockNatsService_GetGatewayInstance_Call) Return(_a0 *model.Gateway, _a1 error) *MockNatsService_GetGatewayInstance_Call

+ func (_c *MockNatsService_GetGatewayInstance_Call) Run(run func(ctx context.Context, gatewayInstanceID string)) *MockNatsService_GetGatewayInstance_Call

+ func (_c *MockNatsService_GetGatewayInstance_Call) RunAndReturn(run func(context.Context, string) (*model.Gateway, error)) *MockNatsService_GetGatewayInstance_Call

+ type MockNatsService_GetJob_Call struct

+ func (_c *MockNatsService_GetJob_Call) Return(_a0 *model.WorkflowState, _a1 error) *MockNatsService_GetJob_Call

+ func (_c *MockNatsService_GetJob_Call) Run(run func(ctx context.Context, id string)) *MockNatsService_GetJob_Call

+ func (_c *MockNatsService_GetJob_Call) RunAndReturn(run func(context.Context, string) (*model.WorkflowState, error)) *MockNatsService_GetJob_Call

+ type MockNatsService_GetLatestVersion_Call struct

+ func (_c *MockNatsService_GetLatestVersion_Call) Return(_a0 string, _a1 error) *MockNatsService_GetLatestVersion_Call

+ func (_c *MockNatsService_GetLatestVersion_Call) Run(run func(ctx context.Context, workflowName string)) *MockNatsService_GetLatestVersion_Call

+ func (_c *MockNatsService_GetLatestVersion_Call) RunAndReturn(run func(context.Context, string) (string, error)) *MockNatsService_GetLatestVersion_Call

+ type MockNatsService_GetOldState_Call struct

+ func (_c *MockNatsService_GetOldState_Call) Return(_a0 *model.WorkflowState, _a1 error) *MockNatsService_GetOldState_Call

+ func (_c *MockNatsService_GetOldState_Call) Run(run func(ctx context.Context, id string)) *MockNatsService_GetOldState_Call

+ func (_c *MockNatsService_GetOldState_Call) RunAndReturn(run func(context.Context, string) (*model.WorkflowState, error)) *MockNatsService_GetOldState_Call

+ type MockNatsService_GetProcessHistory_Call struct

+ func (_c *MockNatsService_GetProcessHistory_Call) Return(_a0 []*model.ProcessHistoryEntry, _a1 error) *MockNatsService_GetProcessHistory_Call

+ func (_c *MockNatsService_GetProcessHistory_Call) Run(run func(ctx context.Context, processInstanceId string)) *MockNatsService_GetProcessHistory_Call

+ func (_c *MockNatsService_GetProcessHistory_Call) RunAndReturn(run func(context.Context, string) ([]*model.ProcessHistoryEntry, error)) *MockNatsService_GetProcessHistory_Call

+ type MockNatsService_GetProcessInstance_Call struct

+ func (_c *MockNatsService_GetProcessInstance_Call) Return(_a0 *model.ProcessInstance, _a1 error) *MockNatsService_GetProcessInstance_Call

+ func (_c *MockNatsService_GetProcessInstance_Call) Run(run func(ctx context.Context, processInstanceID string)) *MockNatsService_GetProcessInstance_Call

+ func (_c *MockNatsService_GetProcessInstance_Call) RunAndReturn(run func(context.Context, string) (*model.ProcessInstance, error)) *MockNatsService_GetProcessInstance_Call

+ type MockNatsService_GetTaskSpecByUID_Call struct

+ func (_c *MockNatsService_GetTaskSpecByUID_Call) Return(_a0 *model.TaskSpec, _a1 error) *MockNatsService_GetTaskSpecByUID_Call

+ func (_c *MockNatsService_GetTaskSpecByUID_Call) Run(run func(ctx context.Context, uid string)) *MockNatsService_GetTaskSpecByUID_Call

+ func (_c *MockNatsService_GetTaskSpecByUID_Call) RunAndReturn(run func(context.Context, string) (*model.TaskSpec, error)) *MockNatsService_GetTaskSpecByUID_Call

+ type MockNatsService_GetTaskSpecUID_Call struct

+ func (_c *MockNatsService_GetTaskSpecUID_Call) Return(_a0 string, _a1 error) *MockNatsService_GetTaskSpecUID_Call

+ func (_c *MockNatsService_GetTaskSpecUID_Call) Run(run func(ctx context.Context, name string)) *MockNatsService_GetTaskSpecUID_Call

+ func (_c *MockNatsService_GetTaskSpecUID_Call) RunAndReturn(run func(context.Context, string) (string, error)) *MockNatsService_GetTaskSpecUID_Call

+ type MockNatsService_GetWorkflowNameFor_Call struct

+ func (_c *MockNatsService_GetWorkflowNameFor_Call) Return(_a0 string, _a1 error) *MockNatsService_GetWorkflowNameFor_Call

+ func (_c *MockNatsService_GetWorkflowNameFor_Call) Run(run func(ctx context.Context, processName string)) *MockNatsService_GetWorkflowNameFor_Call

+ func (_c *MockNatsService_GetWorkflowNameFor_Call) RunAndReturn(run func(context.Context, string) (string, error)) *MockNatsService_GetWorkflowNameFor_Call

+ type MockNatsService_GetWorkflowVersions_Call struct

+ func (_c *MockNatsService_GetWorkflowVersions_Call) Return(_a0 *model.WorkflowVersions, _a1 error) *MockNatsService_GetWorkflowVersions_Call

+ func (_c *MockNatsService_GetWorkflowVersions_Call) Run(run func(ctx context.Context, workflowName string)) *MockNatsService_GetWorkflowVersions_Call

+ func (_c *MockNatsService_GetWorkflowVersions_Call) RunAndReturn(run func(context.Context, string) (*model.WorkflowVersions, error)) *MockNatsService_GetWorkflowVersions_Call

+ type MockNatsService_GetWorkflow_Call struct

+ func (_c *MockNatsService_GetWorkflow_Call) Return(_a0 *model.Workflow, _a1 error) *MockNatsService_GetWorkflow_Call

+ func (_c *MockNatsService_GetWorkflow_Call) Run(run func(ctx context.Context, workflowID string)) *MockNatsService_GetWorkflow_Call

+ func (_c *MockNatsService_GetWorkflow_Call) RunAndReturn(run func(context.Context, string) (*model.Workflow, error)) *MockNatsService_GetWorkflow_Call

+ type MockNatsService_ListExecutionProcesses_Call struct

+ func (_c *MockNatsService_ListExecutionProcesses_Call) Return(_a0 []string, _a1 error) *MockNatsService_ListExecutionProcesses_Call

+ func (_c *MockNatsService_ListExecutionProcesses_Call) Run(run func(ctx context.Context, id string)) *MockNatsService_ListExecutionProcesses_Call

+ func (_c *MockNatsService_ListExecutionProcesses_Call) RunAndReturn(run func(context.Context, string) ([]string, error)) *MockNatsService_ListExecutionProcesses_Call

+ type MockNatsService_ListExecutions_Call struct

+ func (_c *MockNatsService_ListExecutions_Call) Return(_a0 chan *model.ListExecutionItem, _a1 chan error) *MockNatsService_ListExecutions_Call

+ func (_c *MockNatsService_ListExecutions_Call) Run(run func(ctx context.Context, workflowName string)) *MockNatsService_ListExecutions_Call

+ func (_c *MockNatsService_ListExecutions_Call) RunAndReturn(run func(context.Context, string) (chan *model.ListExecutionItem, chan error)) *MockNatsService_ListExecutions_Call

+ type MockNatsService_ListWorkflows_Call struct

+ func (_c *MockNatsService_ListWorkflows_Call) Return(_a0 chan *model.ListWorkflowResponse, _a1 chan error) *MockNatsService_ListWorkflows_Call

+ func (_c *MockNatsService_ListWorkflows_Call) Run(run func(ctx context.Context)) *MockNatsService_ListWorkflows_Call

+ func (_c *MockNatsService_ListWorkflows_Call) RunAndReturn(run func(context.Context) (chan *model.ListWorkflowResponse, chan error)) *MockNatsService_ListWorkflows_Call

+ type MockNatsService_OwnerID_Call struct

+ func (_c *MockNatsService_OwnerID_Call) Return(_a0 string, _a1 error) *MockNatsService_OwnerID_Call

+ func (_c *MockNatsService_OwnerID_Call) Run(run func(name string)) *MockNatsService_OwnerID_Call

+ func (_c *MockNatsService_OwnerID_Call) RunAndReturn(run func(string) (string, error)) *MockNatsService_OwnerID_Call

+ type MockNatsService_OwnerName_Call struct

+ func (_c *MockNatsService_OwnerName_Call) Return(_a0 string, _a1 error) *MockNatsService_OwnerName_Call

+ func (_c *MockNatsService_OwnerName_Call) Run(run func(id string)) *MockNatsService_OwnerName_Call

+ func (_c *MockNatsService_OwnerName_Call) RunAndReturn(run func(string) (string, error)) *MockNatsService_OwnerName_Call

+ type MockNatsService_PublishMessage_Call struct

+ func (_c *MockNatsService_PublishMessage_Call) Return(_a0 error) *MockNatsService_PublishMessage_Call

+ func (_c *MockNatsService_PublishMessage_Call) Run(run func(ctx context.Context, name string, key string, vars []byte)) *MockNatsService_PublishMessage_Call

+ func (_c *MockNatsService_PublishMessage_Call) RunAndReturn(run func(context.Context, string, string, []byte) error) *MockNatsService_PublishMessage_Call

+ type MockNatsService_PublishWorkflowState_Call struct

+ func (_c *MockNatsService_PublishWorkflowState_Call) Return(_a0 error) *MockNatsService_PublishWorkflowState_Call

+ func (_c *MockNatsService_PublishWorkflowState_Call) Run(...) *MockNatsService_PublishWorkflowState_Call

+ func (_c *MockNatsService_PublishWorkflowState_Call) RunAndReturn(...) *MockNatsService_PublishWorkflowState_Call

+ type MockNatsService_PutTaskSpec_Call struct

+ func (_c *MockNatsService_PutTaskSpec_Call) Return(_a0 string, _a1 error) *MockNatsService_PutTaskSpec_Call

+ func (_c *MockNatsService_PutTaskSpec_Call) Run(run func(ctx context.Context, spec *model.TaskSpec)) *MockNatsService_PutTaskSpec_Call

+ func (_c *MockNatsService_PutTaskSpec_Call) RunAndReturn(run func(context.Context, *model.TaskSpec) (string, error)) *MockNatsService_PutTaskSpec_Call

+ type MockNatsService_RecordHistoryActivityComplete_Call struct

+ func (_c *MockNatsService_RecordHistoryActivityComplete_Call) Return(_a0 error) *MockNatsService_RecordHistoryActivityComplete_Call

+ func (_c *MockNatsService_RecordHistoryActivityComplete_Call) Run(run func(ctx context.Context, state *model.WorkflowState)) *MockNatsService_RecordHistoryActivityComplete_Call

+ func (_c *MockNatsService_RecordHistoryActivityComplete_Call) RunAndReturn(run func(context.Context, *model.WorkflowState) error) *MockNatsService_RecordHistoryActivityComplete_Call

+ type MockNatsService_RecordHistoryActivityExecute_Call struct

+ func (_c *MockNatsService_RecordHistoryActivityExecute_Call) Return(_a0 error) *MockNatsService_RecordHistoryActivityExecute_Call

+ func (_c *MockNatsService_RecordHistoryActivityExecute_Call) Run(run func(ctx context.Context, state *model.WorkflowState)) *MockNatsService_RecordHistoryActivityExecute_Call

+ func (_c *MockNatsService_RecordHistoryActivityExecute_Call) RunAndReturn(run func(context.Context, *model.WorkflowState) error) *MockNatsService_RecordHistoryActivityExecute_Call

+ type MockNatsService_RecordHistoryProcessAbort_Call struct

+ func (_c *MockNatsService_RecordHistoryProcessAbort_Call) Return(_a0 error) *MockNatsService_RecordHistoryProcessAbort_Call

+ func (_c *MockNatsService_RecordHistoryProcessAbort_Call) Run(run func(ctx context.Context, state *model.WorkflowState)) *MockNatsService_RecordHistoryProcessAbort_Call

+ func (_c *MockNatsService_RecordHistoryProcessAbort_Call) RunAndReturn(run func(context.Context, *model.WorkflowState) error) *MockNatsService_RecordHistoryProcessAbort_Call

+ type MockNatsService_RecordHistoryProcessComplete_Call struct

+ func (_c *MockNatsService_RecordHistoryProcessComplete_Call) Return(_a0 error) *MockNatsService_RecordHistoryProcessComplete_Call

+ func (_c *MockNatsService_RecordHistoryProcessComplete_Call) Run(run func(ctx context.Context, state *model.WorkflowState)) *MockNatsService_RecordHistoryProcessComplete_Call

+ func (_c *MockNatsService_RecordHistoryProcessComplete_Call) RunAndReturn(run func(context.Context, *model.WorkflowState) error) *MockNatsService_RecordHistoryProcessComplete_Call

+ type MockNatsService_RecordHistoryProcessSpawn_Call struct

+ func (_c *MockNatsService_RecordHistoryProcessSpawn_Call) Return(_a0 error) *MockNatsService_RecordHistoryProcessSpawn_Call

+ func (_c *MockNatsService_RecordHistoryProcessSpawn_Call) Run(...) *MockNatsService_RecordHistoryProcessSpawn_Call

+ func (_c *MockNatsService_RecordHistoryProcessSpawn_Call) RunAndReturn(run func(context.Context, *model.WorkflowState, string) error) *MockNatsService_RecordHistoryProcessSpawn_Call

+ type MockNatsService_RecordHistoryProcessStart_Call struct

+ func (_c *MockNatsService_RecordHistoryProcessStart_Call) Return(_a0 error) *MockNatsService_RecordHistoryProcessStart_Call

+ func (_c *MockNatsService_RecordHistoryProcessStart_Call) Run(run func(ctx context.Context, state *model.WorkflowState)) *MockNatsService_RecordHistoryProcessStart_Call

+ func (_c *MockNatsService_RecordHistoryProcessStart_Call) RunAndReturn(run func(context.Context, *model.WorkflowState) error) *MockNatsService_RecordHistoryProcessStart_Call

+ type MockNatsService_SaveState_Call struct

+ func (_c *MockNatsService_SaveState_Call) Return(_a0 error) *MockNatsService_SaveState_Call

+ func (_c *MockNatsService_SaveState_Call) Run(run func(ctx context.Context, id string, state *model.WorkflowState)) *MockNatsService_SaveState_Call

+ func (_c *MockNatsService_SaveState_Call) RunAndReturn(run func(context.Context, string, *model.WorkflowState) error) *MockNatsService_SaveState_Call

+ type MockNatsService_SetAbort_Call struct

+ func (_c *MockNatsService_SetAbort_Call) Return() *MockNatsService_SetAbort_Call

+ func (_c *MockNatsService_SetAbort_Call) Run(run func(processor services.AbortFunc)) *MockNatsService_SetAbort_Call

+ func (_c *MockNatsService_SetAbort_Call) RunAndReturn(run func(services.AbortFunc)) *MockNatsService_SetAbort_Call

+ type MockNatsService_SetCompleteActivityProcessor_Call struct

+ func (_c *MockNatsService_SetCompleteActivityProcessor_Call) Return() *MockNatsService_SetCompleteActivityProcessor_Call

+ func (_c *MockNatsService_SetCompleteActivityProcessor_Call) Run(run func(processor services.CompleteActivityProcessorFunc)) *MockNatsService_SetCompleteActivityProcessor_Call

+ func (_c *MockNatsService_SetCompleteActivityProcessor_Call) RunAndReturn(run func(services.CompleteActivityProcessorFunc)) *MockNatsService_SetCompleteActivityProcessor_Call

+ type MockNatsService_SetCompleteActivity_Call struct

+ func (_c *MockNatsService_SetCompleteActivity_Call) Return() *MockNatsService_SetCompleteActivity_Call

+ func (_c *MockNatsService_SetCompleteActivity_Call) Run(run func(processor services.CompleteActivityFunc)) *MockNatsService_SetCompleteActivity_Call

+ func (_c *MockNatsService_SetCompleteActivity_Call) RunAndReturn(run func(services.CompleteActivityFunc)) *MockNatsService_SetCompleteActivity_Call

+ type MockNatsService_SetCompleteJobProcessor_Call struct

+ func (_c *MockNatsService_SetCompleteJobProcessor_Call) Return() *MockNatsService_SetCompleteJobProcessor_Call

+ func (_c *MockNatsService_SetCompleteJobProcessor_Call) Run(run func(processor services.CompleteJobProcessorFunc)) *MockNatsService_SetCompleteJobProcessor_Call

+ func (_c *MockNatsService_SetCompleteJobProcessor_Call) RunAndReturn(run func(services.CompleteJobProcessorFunc)) *MockNatsService_SetCompleteJobProcessor_Call

+ type MockNatsService_SetEventProcessor_Call struct

+ func (_c *MockNatsService_SetEventProcessor_Call) Return() *MockNatsService_SetEventProcessor_Call

+ func (_c *MockNatsService_SetEventProcessor_Call) Run(run func(processor services.EventProcessorFunc)) *MockNatsService_SetEventProcessor_Call

+ func (_c *MockNatsService_SetEventProcessor_Call) RunAndReturn(run func(services.EventProcessorFunc)) *MockNatsService_SetEventProcessor_Call

+ type MockNatsService_SetLaunchFunc_Call struct

+ func (_c *MockNatsService_SetLaunchFunc_Call) Return() *MockNatsService_SetLaunchFunc_Call

+ func (_c *MockNatsService_SetLaunchFunc_Call) Run(run func(processor services.LaunchFunc)) *MockNatsService_SetLaunchFunc_Call

+ func (_c *MockNatsService_SetLaunchFunc_Call) RunAndReturn(run func(services.LaunchFunc)) *MockNatsService_SetLaunchFunc_Call

+ type MockNatsService_SetMessageProcessor_Call struct

+ func (_c *MockNatsService_SetMessageProcessor_Call) Return() *MockNatsService_SetMessageProcessor_Call

+ func (_c *MockNatsService_SetMessageProcessor_Call) Run(run func(processor services.MessageProcessorFunc)) *MockNatsService_SetMessageProcessor_Call

+ func (_c *MockNatsService_SetMessageProcessor_Call) RunAndReturn(run func(services.MessageProcessorFunc)) *MockNatsService_SetMessageProcessor_Call

+ type MockNatsService_SetTraversalProvider_Call struct

+ func (_c *MockNatsService_SetTraversalProvider_Call) Return() *MockNatsService_SetTraversalProvider_Call

+ func (_c *MockNatsService_SetTraversalProvider_Call) Run(run func(provider services.TraversalFunc)) *MockNatsService_SetTraversalProvider_Call

+ func (_c *MockNatsService_SetTraversalProvider_Call) RunAndReturn(run func(services.TraversalFunc)) *MockNatsService_SetTraversalProvider_Call

+ type MockNatsService_Shutdown_Call struct

+ func (_c *MockNatsService_Shutdown_Call) Return() *MockNatsService_Shutdown_Call

+ func (_c *MockNatsService_Shutdown_Call) Run(run func()) *MockNatsService_Shutdown_Call

+ func (_c *MockNatsService_Shutdown_Call) RunAndReturn(run func()) *MockNatsService_Shutdown_Call

+ type MockNatsService_StartProcessing_Call struct

+ func (_c *MockNatsService_StartProcessing_Call) Return(_a0 error) *MockNatsService_StartProcessing_Call

+ func (_c *MockNatsService_StartProcessing_Call) Run(run func(ctx context.Context)) *MockNatsService_StartProcessing_Call

+ func (_c *MockNatsService_StartProcessing_Call) RunAndReturn(run func(context.Context) error) *MockNatsService_StartProcessing_Call

+ type MockNatsService_StoreWorkflow_Call struct

+ func (_c *MockNatsService_StoreWorkflow_Call) Return(_a0 string, _a1 error) *MockNatsService_StoreWorkflow_Call

+ func (_c *MockNatsService_StoreWorkflow_Call) Run(run func(ctx context.Context, wf *model.Workflow)) *MockNatsService_StoreWorkflow_Call

+ func (_c *MockNatsService_StoreWorkflow_Call) RunAndReturn(run func(context.Context, *model.Workflow) (string, error)) *MockNatsService_StoreWorkflow_Call

+ type MockNatsService_XDestroyProcessInstance_Call struct

+ func (_c *MockNatsService_XDestroyProcessInstance_Call) Return(_a0 error) *MockNatsService_XDestroyProcessInstance_Call

+ func (_c *MockNatsService_XDestroyProcessInstance_Call) Run(run func(ctx context.Context, state *model.WorkflowState)) *MockNatsService_XDestroyProcessInstance_Call

+ func (_c *MockNatsService_XDestroyProcessInstance_Call) RunAndReturn(run func(context.Context, *model.WorkflowState) error) *MockNatsService_XDestroyProcessInstance_Call

Oct 14, 2023

Changes in this version

type NatsService

+ CheckProcessTaskDeprecation func(ctx context.Context, workflow *model.Workflow, processName string) error

+ EnsureServiceTaskConsumer func(uid string) error

Oct 3, 2023

Changes in this version

type Engine

+ func (c *Engine) CancelProcessInstance(ctx context.Context, state *model.WorkflowState) error

type NatsService

+ CreateExecution func(ctx context.Context, wfInstance *model.Execution) (*model.Execution, error)

+ GetExecution func(ctx context.Context, workflowInstanceID string) (*model.Execution, error)

+ GetWorkflowNameFor func(ctx context.Context, processName string) (string, error)

+ ListExecutionProcesses func(ctx context.Context, id string) ([]string, error)

+ ListExecutions func(ctx context.Context, workflowName string) (chan *model.ListExecutionResult, chan error)

+ XDestroyProcessInstance func(ctx context.Context, state *model.WorkflowState) error

Sep 13, 2023

Changes in this version

type NatsService

+ GetTaskSpecByUID func(ctx context.Context, uid string) (*model.TaskSpec, error)

+ GetTaskSpecUID func(ctx context.Context, name string) (string, error)

+ PutTaskSpec func(ctx context.Context, spec *model.TaskSpec) (string, error)

+ SaveState func(ctx context.Context, id string, state *model.WorkflowState) error

Mar 24, 2023

Changes in this version

type Engine

+ func New(ns NatsService) (*Engine, error)

type NatsService

+ GetProcessHistory func(ctx context.Context, processInstanceId string) ([]*model.ProcessHistoryEntry, error)

+ RecordHistoryActivityComplete func(ctx context.Context, state *model.WorkflowState) error

+ RecordHistoryActivityExecute func(ctx context.Context, state *model.WorkflowState) error

+ RecordHistoryProcessAbort func(ctx context.Context, state *model.WorkflowState) error

+ RecordHistoryProcessComplete func(ctx context.Context, state *model.WorkflowState) error

+ RecordHistoryProcessSpawn func(ctx context.Context, state *model.WorkflowState, newProcessInstanceID string) error

+ RecordHistoryProcessStart func(ctx context.Context, state *model.WorkflowState) error

Mar 2, 2023

Changes in this version

type NatsService

+ GetGatewayInstance func(ctx context.Context, gatewayInstanceID string) (*model.Gateway, error)

+ GetGatewayInstanceID func(state *model.WorkflowState) (string, string, error)

Feb 3, 2023

Changes in this version

type NatsService

+ CreateProcessInstance func(ctx context.Context, workflowInstanceID string, parentProcessID string, ...) (*model.ProcessInstance, error)

+ DestroyProcessInstance func(ctx context.Context, state *model.WorkflowState, pi *model.ProcessInstance, ...) error

+ GetProcessInstance func(ctx context.Context, processInstanceID string) (*model.ProcessInstance, error)

+ ListWorkflowInstanceProcesses func(ctx context.Context, id string) ([]string, error)

+ SatisfyProcess func(ctx context.Context, workflowInstance *model.WorkflowInstance, ...) error

+ XDestroyWorkflowInstance func(ctx context.Context, state *model.WorkflowState, ...) error

Dec 20, 2022

Changes in this version

type NatsService

+ GetWorkflowVersions func(ctx context.Context, workflowName string) (*model.WorkflowVersions, error)

Nov 8, 2022

Changes in this version

type NatsService

+ OwnerID func(name string) (string, error)

Oct 31, 2022

Changes in this version

type NatsService

+ SetAbort func(processor services.AbortFunc)

Oct 18, 2022

Changes in this version

type Engine

+ func (c *Engine) PublishError(ctx context.Context, state *model.WorkflowState, err error)

Oct 12, 2022

Changes in this version

type Engine

+ func (c *Engine) CompleteSendMessageTask(ctx context.Context, trackingID string, newvars []byte) error

type NatsService

+ SetCompleteActivity func(processor services.CompleteActivityFunc)

Oct 3, 2022

Changes in this version

type NatsService

+ SetMessageProcessor func(processor services.MessageProcessorFunc)

Oct 3, 2022

Changes in this version

type NatsService

+ DeleteJob func(ctx context.Context, trackingID string) error

+ GetOldState func(id string) (*model.WorkflowState, error)

+ SetCompleteActivityProcessor func(processor services.CompleteActivityProcessorFunc)

+ SetLaunchFunc func(processor services.LaunchFunc)

Sep 20, 2022

Changes in this version

type NatsService

+ DeleteVariableState func(ctx context.Context, key string) error

+ LoadVariableState func(ctx context.Context, key string) ([]byte, error)

+ SaveVariableState func(ctx context.Context, key string, vars []byte) error

Sep 20, 2022

Changes in this version

type Engine

+ func (c *Engine) CompleteSendMessage(ctx context.Context, trackingID string, newvars []byte) error

Sep 16, 2022

Changes in this version

type NatsService

+ SetTraversalProvider func(provider services.TraversalFunc)

Sep 13, 2022

Changes in this version

type NatsService

+ GetElement func(ctx context.Context, state *model.WorkflowState) (*model.Element, error)

Sep 6, 2022

Changes in this version

type NatsService

+ GetMessageSenderRoutingKey func(workflowName string, messageName string) (string, error)

+ GetServiceTaskRoutingKey func(taskName string) (string, error)

Jul 20, 2022

Changes in this version

type Engine

+ func (c *Engine) CompleteManualTask(ctx context.Context, trackingID string, newvars []byte) error

+ func (c *Engine) CompleteServiceTask(ctx context.Context, trackingID string, newvars []byte) error

+ func (c *Engine) CompleteUserTask(ctx context.Context, trackingID string, newvars []byte) error

type NatsService

+ CloseUserTask func(trackingID string) error

+ OwnerId func(name string) (string, error)

+ OwnerName func(id string) (string, error)

Jun 24, 2022

Changes in this version

+ type Engine struct

+ func NewEngine(log *zap.Logger, ns NatsService) (*Engine, error)

+ func (c *Engine) CancelWorkflowInstance(ctx context.Context, id string) error

+ func (c *Engine) Launch(ctx context.Context, workflowName string, vars []byte) (string, error)

+ func (c *Engine) LoadWorkflow(ctx context.Context, model *model.Workflow) (string, error)

+ func (c *Engine) Shutdown()

+ func (c *Engine) Start(ctx context.Context) error

+ type NatsService interface

+ AwaitMsg func(ctx context.Context, state *model.WorkflowState) error

+ Conn func() common.NatsConn

+ CreateJob func(ctx context.Context, job *model.WorkflowState) (string, error)

+ CreateWorkflowInstance func(ctx context.Context, wfInstance *model.WorkflowInstance) (*model.WorkflowInstance, error)

+ DestroyWorkflowInstance func(ctx context.Context, workflowInstanceId string) error

+ GetJob func(ctx context.Context, id string) (*model.WorkflowState, error)

+ GetLatestVersion func(ctx context.Context, workflowName string) (string, error)

+ GetWorkflow func(ctx context.Context, workflowId string) (*model.Workflow, error)

+ GetWorkflowInstance func(ctx context.Context, workflowInstanceId string) (*model.WorkflowInstance, error)

+ GetWorkflowInstanceStatus func(ctx context.Context, id string) (*model.WorkflowInstanceStatus, error)

+ ListWorkflowInstance func(ctx context.Context, workflowName string) (chan *model.ListWorkflowInstanceResult, chan error)

+ ListWorkflows func(ctx context.Context) (chan *model.ListWorkflowResult, chan error)

+ PublishMessage func(ctx context.Context, workflowInstanceID string, name string, key string) error

+ PublishWorkflowState func(ctx context.Context, stateName string, state *model.WorkflowState) error

+ SetCompleteJobProcessor func(processor services.CompleteJobProcessorFunc)

+ SetEventProcessor func(processor services.EventProcessorFunc)

+ SetMessageCompleteProcessor func(processor services.MessageCompleteProcessorFunc)

+ Shutdown func()

+ StartProcessing func(ctx context.Context) error

+ StoreWorkflow func(ctx context.Context, wf *model.Workflow) (string, error)