workflow

package
v1.1.1035 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 22, 2024 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Engine 

type Engine struct {
	// contains filtered or unexported fields
}

Engine contains the workflow processing functions

func New added in v1.0.477 

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

New returns an instance of the core workflow engine.

func (*Engine) CancelProcessInstance added in v1.0.645 

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

CancelProcessInstance cancels a workflow instance with a reason.

func (*Engine) CompleteManualTask added in v0.1.86 

func (c *Engine) CompleteManualTask(ctx context.Context, job *model.WorkflowState, newvars []byte) error

CompleteManualTask completes a manual workflow task

func (*Engine) CompleteSendMessageTask added in v1.0.235 

func (c *Engine) CompleteSendMessageTask(ctx context.Context, job *model.WorkflowState, newvars []byte) error

CompleteSendMessageTask completes a send message task

func (*Engine) CompleteServiceTask added in v0.1.86 

func (c *Engine) CompleteServiceTask(ctx context.Context, job *model.WorkflowState, newvars []byte) error

CompleteServiceTask completes a workflow service task

func (*Engine) CompleteUserTask added in v0.1.86 

func (c *Engine) CompleteUserTask(ctx context.Context, job *model.WorkflowState, newvars []byte) error

CompleteUserTask completes and closes a user task with variables

func (*Engine) Launch 

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

Launch starts a new instance of a workflow and returns an execution Id.

func (*Engine) LoadWorkflow 

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

LoadWorkflow loads a model.Process describing a workflow into the engine ready for execution.

func (*Engine) Shutdown 

func (c *Engine) Shutdown()

Shutdown gracefully stops the engine.

func (*Engine) Start 

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

Start sets up the activity and job processors and starts the engine processing workflows.

type MockNatsService added in v1.1.725 

type MockNatsService struct {
	mock.Mock
}

MockNatsService is an autogenerated mock type for the NatsService type

func NewMockNatsService added in v1.1.725 

func NewMockNatsService(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockNatsService

NewMockNatsService creates a new instance of MockNatsService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockNatsService) CheckProcessTaskDeprecation added in v1.1.725 

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

CheckProcessTaskDeprecation provides a mock function with given fields: ctx, workflow, processName

func (*MockNatsService) CloseUserTask added in v1.1.725 

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

CloseUserTask provides a mock function with given fields: ctx, trackingID

func (*MockNatsService) Conn added in v1.1.725 

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

Conn provides a mock function with given fields:

func (*MockNatsService) CreateExecution added in v1.1.725 

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

CreateExecution provides a mock function with given fields: ctx, wfInstance

func (*MockNatsService) CreateJob added in v1.1.725 

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

CreateJob provides a mock function with given fields: ctx, job

func (*MockNatsService) CreateProcessInstance added in v1.1.725 

func (_m *MockNatsService) CreateProcessInstance(ctx context.Context, workflowInstanceID string, parentProcessID string, parentElementID string, processName string, workflowName string, workflowId string) (*model.ProcessInstance, error)

CreateProcessInstance provides a mock function with given fields: ctx, workflowInstanceID, parentProcessID, parentElementID, processName, workflowName, workflowId

func (*MockNatsService) DeleteJob added in v1.1.725 

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

DeleteJob provides a mock function with given fields: ctx, trackingID

func (*MockNatsService) DestroyProcessInstance added in v1.1.725 

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

DestroyProcessInstance provides a mock function with given fields: ctx, state, pi, wi

func (*MockNatsService) EXPECT added in v1.1.725 

func (_m *MockNatsService) EXPECT() *MockNatsService_Expecter

func (*MockNatsService) EnsureServiceTaskConsumer added in v1.1.725 

func (_m *MockNatsService) EnsureServiceTaskConsumer(ctx context.Context, uid string) error

EnsureServiceTaskConsumer provides a mock function with given fields: ctx, uid

func (*MockNatsService) GetElement added in v1.1.725 

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

GetElement provides a mock function with given fields: ctx, state

func (*MockNatsService) GetExecution added in v1.1.725 

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

GetExecution provides a mock function with given fields: ctx, workflowInstanceID

func (*MockNatsService) GetGatewayInstance added in v1.1.725 

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

GetGatewayInstance provides a mock function with given fields: ctx, gatewayInstanceID

func (*MockNatsService) GetGatewayInstanceID added in v1.1.725 

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

GetGatewayInstanceID provides a mock function with given fields: state

func (*MockNatsService) GetJob added in v1.1.725 

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

GetJob provides a mock function with given fields: ctx, id

func (*MockNatsService) GetLatestVersion added in v1.1.725 

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

GetLatestVersion provides a mock function with given fields: ctx, workflowName

func (*MockNatsService) GetOldState added in v1.1.725 

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

GetOldState provides a mock function with given fields: ctx, id

func (*MockNatsService) GetProcessHistory added in v1.1.725 

func (_m *MockNatsService) GetProcessHistory(ctx context.Context, processInstanceId string, wch chan<- *model.ProcessHistoryEntry, errs chan<- error)

GetProcessHistory provides a mock function with given fields: ctx, processInstanceId, wch, errs

func (*MockNatsService) GetProcessInstance added in v1.1.725 

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

GetProcessInstance provides a mock function with given fields: ctx, processInstanceID

func (*MockNatsService) GetTaskSpecByUID added in v1.1.725 

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

GetTaskSpecByUID provides a mock function with given fields: ctx, uid

func (*MockNatsService) GetTaskSpecUID added in v1.1.725 

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

GetTaskSpecUID provides a mock function with given fields: ctx, name

func (*MockNatsService) GetWorkflow added in v1.1.725 

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

GetWorkflow provides a mock function with given fields: ctx, workflowID

func (*MockNatsService) GetWorkflowNameFor added in v1.1.725 

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

GetWorkflowNameFor provides a mock function with given fields: ctx, processName

func (*MockNatsService) GetWorkflowVersions added in v1.1.725 

func (_m *MockNatsService) GetWorkflowVersions(_a0 context.Context, _a1 string, _a2 chan<- *model.WorkflowVersion, _a3 chan<- error)

GetWorkflowVersions provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*MockNatsService) Heartbeat added in v1.1.731 

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

Heartbeat provides a mock function with given fields: ctx, request

func (*MockNatsService) ListExecutionProcesses added in v1.1.725 

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

ListExecutionProcesses provides a mock function with given fields: ctx, id

func (*MockNatsService) ListExecutions added in v1.1.725 

func (_m *MockNatsService) ListExecutions(ctx context.Context, id string, res chan<- *model.ListExecutionItem, errs chan<- error)

ListExecutions provides a mock function with given fields: ctx, id, res, errs

func (*MockNatsService) ListWorkflows added in v1.1.725 

func (_m *MockNatsService) ListWorkflows(ctx context.Context, res chan<- *model.ListWorkflowResponse, errs chan<- error)

ListWorkflows provides a mock function with given fields: ctx, res, errs

func (*MockNatsService) OwnerID added in v1.1.725 

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

OwnerID provides a mock function with given fields: ctx, name

func (*MockNatsService) OwnerName added in v1.1.725 

func (_m *MockNatsService) OwnerName(ctx context.Context, id string) (string, error)

OwnerName provides a mock function with given fields: ctx, id

func (*MockNatsService) PublishMessage added in v1.1.725 

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

PublishMessage provides a mock function with given fields: ctx, name, key, vars

func (*MockNatsService) PublishWorkflowState added in v1.1.725 

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

PublishWorkflowState provides a mock function with given fields: ctx, stateName, state, ops

func (*MockNatsService) PutTaskSpec added in v1.1.725 

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

PutTaskSpec provides a mock function with given fields: ctx, spec

func (*MockNatsService) RecordHistoryActivityComplete added in v1.1.725 

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

RecordHistoryActivityComplete provides a mock function with given fields: ctx, state

func (*MockNatsService) RecordHistoryActivityExecute added in v1.1.725 

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

RecordHistoryActivityExecute provides a mock function with given fields: ctx, state

func (*MockNatsService) RecordHistoryProcessAbort added in v1.1.725 

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

RecordHistoryProcessAbort provides a mock function with given fields: ctx, state

func (*MockNatsService) RecordHistoryProcessComplete added in v1.1.725 

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

RecordHistoryProcessComplete provides a mock function with given fields: ctx, state

func (*MockNatsService) RecordHistoryProcessSpawn added in v1.1.725 

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

RecordHistoryProcessSpawn provides a mock function with given fields: ctx, state, newProcessInstanceID

func (*MockNatsService) RecordHistoryProcessStart added in v1.1.725 

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

RecordHistoryProcessStart provides a mock function with given fields: ctx, state

func (*MockNatsService) SaveState added in v1.1.725 

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

SaveState provides a mock function with given fields: ctx, id, state

func (*MockNatsService) SetAbort added in v1.1.725 

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

SetAbort provides a mock function with given fields: processor

func (*MockNatsService) SetCompleteActivity added in v1.1.725 

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

SetCompleteActivity provides a mock function with given fields: processor

func (*MockNatsService) SetCompleteActivityProcessor added in v1.1.725 

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

SetCompleteActivityProcessor provides a mock function with given fields: processor

func (*MockNatsService) SetCompleteJobProcessor added in v1.1.725 

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

SetCompleteJobProcessor provides a mock function with given fields: processor

func (*MockNatsService) SetEventProcessor added in v1.1.725 

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

SetEventProcessor provides a mock function with given fields: processor

func (*MockNatsService) SetLaunchFunc added in v1.1.725 

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

SetLaunchFunc provides a mock function with given fields: processor

func (*MockNatsService) SetMessageProcessor added in v1.1.725 

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

SetMessageProcessor provides a mock function with given fields: processor

func (*MockNatsService) SetTraversalProvider added in v1.1.725 

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

SetTraversalProvider provides a mock function with given fields: provider

func (*MockNatsService) Shutdown added in v1.1.725 

func (_m *MockNatsService) Shutdown()

Shutdown provides a mock function with given fields:

func (*MockNatsService) StartProcessing added in v1.1.725 

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

StartProcessing provides a mock function with given fields: ctx

func (*MockNatsService) StoreWorkflow added in v1.1.725 

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

StoreWorkflow provides a mock function with given fields: ctx, wf

func (*MockNatsService) XDestroyProcessInstance added in v1.1.725 

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

XDestroyProcessInstance provides a mock function with given fields: ctx, state

type MockNatsService_CheckProcessTaskDeprecation_Call added in v1.1.725 

type MockNatsService_CheckProcessTaskDeprecation_Call struct {
	*mock.Call
}

MockNatsService_CheckProcessTaskDeprecation_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckProcessTaskDeprecation'

func (*MockNatsService_CheckProcessTaskDeprecation_Call) Return added in v1.1.725 

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

func (*MockNatsService_CheckProcessTaskDeprecation_Call) Run added in v1.1.725 

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

func (*MockNatsService_CheckProcessTaskDeprecation_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_CloseUserTask_Call added in v1.1.725 

type MockNatsService_CloseUserTask_Call struct {
	*mock.Call
}

MockNatsService_CloseUserTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CloseUserTask'

func (*MockNatsService_CloseUserTask_Call) Return added in v1.1.725 

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

func (*MockNatsService_CloseUserTask_Call) Run added in v1.1.725 

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

func (*MockNatsService_CloseUserTask_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_Conn_Call added in v1.1.725 

type MockNatsService_Conn_Call struct {
	*mock.Call
}

MockNatsService_Conn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Conn'

func (*MockNatsService_Conn_Call) Return added in v1.1.725 

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

func (*MockNatsService_Conn_Call) Run added in v1.1.725 

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

func (*MockNatsService_Conn_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_CreateExecution_Call added in v1.1.725 

type MockNatsService_CreateExecution_Call struct {
	*mock.Call
}

MockNatsService_CreateExecution_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateExecution'

func (*MockNatsService_CreateExecution_Call) Return added in v1.1.725 

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

func (*MockNatsService_CreateExecution_Call) Run added in v1.1.725 

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

func (*MockNatsService_CreateExecution_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_CreateJob_Call added in v1.1.725 

type MockNatsService_CreateJob_Call struct {
	*mock.Call
}

MockNatsService_CreateJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJob'

func (*MockNatsService_CreateJob_Call) Return added in v1.1.725 

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

func (*MockNatsService_CreateJob_Call) Run added in v1.1.725 

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

func (*MockNatsService_CreateJob_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_CreateProcessInstance_Call added in v1.1.725 

type MockNatsService_CreateProcessInstance_Call struct {
	*mock.Call
}

MockNatsService_CreateProcessInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateProcessInstance'

func (*MockNatsService_CreateProcessInstance_Call) Return added in v1.1.725 

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

func (*MockNatsService_CreateProcessInstance_Call) Run added in v1.1.725 

func (_c *MockNatsService_CreateProcessInstance_Call) Run(run func(ctx context.Context, workflowInstanceID string, parentProcessID string, parentElementID string, processName string, workflowName string, workflowId string)) *MockNatsService_CreateProcessInstance_Call

func (*MockNatsService_CreateProcessInstance_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_DeleteJob_Call added in v1.1.725 

type MockNatsService_DeleteJob_Call struct {
	*mock.Call
}

MockNatsService_DeleteJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJob'

func (*MockNatsService_DeleteJob_Call) Return added in v1.1.725 

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

func (*MockNatsService_DeleteJob_Call) Run added in v1.1.725 

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

func (*MockNatsService_DeleteJob_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_DestroyProcessInstance_Call added in v1.1.725 

type MockNatsService_DestroyProcessInstance_Call struct {
	*mock.Call
}

MockNatsService_DestroyProcessInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DestroyProcessInstance'

func (*MockNatsService_DestroyProcessInstance_Call) Return added in v1.1.725 

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

func (*MockNatsService_DestroyProcessInstance_Call) Run added in v1.1.725 

func (_c *MockNatsService_DestroyProcessInstance_Call) Run(run func(ctx context.Context, state *model.WorkflowState, pi *model.ProcessInstance, wi *model.Execution)) *MockNatsService_DestroyProcessInstance_Call

func (*MockNatsService_DestroyProcessInstance_Call) RunAndReturn added in v1.1.725 

func (_c *MockNatsService_DestroyProcessInstance_Call) RunAndReturn(run func(context.Context, *model.WorkflowState, *model.ProcessInstance, *model.Execution) error) *MockNatsService_DestroyProcessInstance_Call

type MockNatsService_EnsureServiceTaskConsumer_Call added in v1.1.725 

type MockNatsService_EnsureServiceTaskConsumer_Call struct {
	*mock.Call
}

MockNatsService_EnsureServiceTaskConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnsureServiceTaskConsumer'

func (*MockNatsService_EnsureServiceTaskConsumer_Call) Return added in v1.1.725 

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

func (*MockNatsService_EnsureServiceTaskConsumer_Call) Run added in v1.1.725 

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

func (*MockNatsService_EnsureServiceTaskConsumer_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_Expecter added in v1.1.725 

type MockNatsService_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockNatsService_Expecter) CheckProcessTaskDeprecation added in v1.1.725 

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

CheckProcessTaskDeprecation is a helper method to define mock.On call

  • ctx context.Context
  • workflow *model.Workflow
  • processName string

func (*MockNatsService_Expecter) CloseUserTask added in v1.1.725 

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

CloseUserTask is a helper method to define mock.On call

  • ctx context.Context
  • trackingID string

func (*MockNatsService_Expecter) Conn added in v1.1.725 

func (_e *MockNatsService_Expecter) Conn() *MockNatsService_Conn_Call

Conn is a helper method to define mock.On call

func (*MockNatsService_Expecter) CreateExecution added in v1.1.725 

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

CreateExecution is a helper method to define mock.On call

  • ctx context.Context
  • wfInstance *model.Execution

func (*MockNatsService_Expecter) CreateJob added in v1.1.725 

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

CreateJob is a helper method to define mock.On call

  • ctx context.Context
  • job *model.WorkflowState

func (*MockNatsService_Expecter) CreateProcessInstance added in v1.1.725 

func (_e *MockNatsService_Expecter) CreateProcessInstance(ctx interface{}, workflowInstanceID interface{}, parentProcessID interface{}, parentElementID interface{}, processName interface{}, workflowName interface{}, workflowId interface{}) *MockNatsService_CreateProcessInstance_Call

CreateProcessInstance is a helper method to define mock.On call

  • ctx context.Context
  • workflowInstanceID string
  • parentProcessID string
  • parentElementID string
  • processName string
  • workflowName string
  • workflowId string

func (*MockNatsService_Expecter) DeleteJob added in v1.1.725 

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

DeleteJob is a helper method to define mock.On call

  • ctx context.Context
  • trackingID string

func (*MockNatsService_Expecter) DestroyProcessInstance added in v1.1.725 

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

DestroyProcessInstance is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState
  • pi *model.ProcessInstance
  • wi *model.Execution

func (*MockNatsService_Expecter) EnsureServiceTaskConsumer added in v1.1.725 

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

EnsureServiceTaskConsumer is a helper method to define mock.On call

  • ctx context.Context
  • uid string

func (*MockNatsService_Expecter) GetElement added in v1.1.725 

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

GetElement is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockNatsService_Expecter) GetExecution added in v1.1.725 

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

GetExecution is a helper method to define mock.On call

  • ctx context.Context
  • workflowInstanceID string

func (*MockNatsService_Expecter) GetGatewayInstance added in v1.1.725 

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

GetGatewayInstance is a helper method to define mock.On call

  • ctx context.Context
  • gatewayInstanceID string

func (*MockNatsService_Expecter) GetGatewayInstanceID added in v1.1.725 

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

GetGatewayInstanceID is a helper method to define mock.On call

  • state *model.WorkflowState

func (*MockNatsService_Expecter) GetJob added in v1.1.725 

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

GetJob is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*MockNatsService_Expecter) GetLatestVersion added in v1.1.725 

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

GetLatestVersion is a helper method to define mock.On call

  • ctx context.Context
  • workflowName string

func (*MockNatsService_Expecter) GetOldState added in v1.1.725 

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

GetOldState is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*MockNatsService_Expecter) GetProcessHistory added in v1.1.725 

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

GetProcessHistory is a helper method to define mock.On call

  • ctx context.Context
  • processInstanceId string
  • wch chan<- *model.ProcessHistoryEntry
  • errs chan<- error

func (*MockNatsService_Expecter) GetProcessInstance added in v1.1.725 

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

GetProcessInstance is a helper method to define mock.On call

  • ctx context.Context
  • processInstanceID string

func (*MockNatsService_Expecter) GetTaskSpecByUID added in v1.1.725 

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

GetTaskSpecByUID is a helper method to define mock.On call

  • ctx context.Context
  • uid string

func (*MockNatsService_Expecter) GetTaskSpecUID added in v1.1.725 

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

GetTaskSpecUID is a helper method to define mock.On call

  • ctx context.Context
  • name string

func (*MockNatsService_Expecter) GetWorkflow added in v1.1.725 

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

GetWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string

func (*MockNatsService_Expecter) GetWorkflowNameFor added in v1.1.725 

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

GetWorkflowNameFor is a helper method to define mock.On call

  • ctx context.Context
  • processName string

func (*MockNatsService_Expecter) GetWorkflowVersions added in v1.1.725 

func (_e *MockNatsService_Expecter) GetWorkflowVersions(_a0 interface{}, _a1 interface{}, _a2 interface{}, _a3 interface{}) *MockNatsService_GetWorkflowVersions_Call

GetWorkflowVersions is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 string
  • _a2 chan<- *model.WorkflowVersion
  • _a3 chan<- error

func (*MockNatsService_Expecter) Heartbeat added in v1.1.731 

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

Heartbeat is a helper method to define mock.On call

  • ctx context.Context
  • request *model.HeartbeatRequest

func (*MockNatsService_Expecter) ListExecutionProcesses added in v1.1.725 

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

ListExecutionProcesses is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*MockNatsService_Expecter) ListExecutions added in v1.1.725 

func (_e *MockNatsService_Expecter) ListExecutions(ctx interface{}, id interface{}, res interface{}, errs interface{}) *MockNatsService_ListExecutions_Call

ListExecutions is a helper method to define mock.On call

  • ctx context.Context
  • id string
  • res chan<- *model.ListExecutionItem
  • errs chan<- error

func (*MockNatsService_Expecter) ListWorkflows added in v1.1.725 

func (_e *MockNatsService_Expecter) ListWorkflows(ctx interface{}, res interface{}, errs interface{}) *MockNatsService_ListWorkflows_Call

ListWorkflows is a helper method to define mock.On call

  • ctx context.Context
  • res chan<- *model.ListWorkflowResponse
  • errs chan<- error

func (*MockNatsService_Expecter) OwnerID added in v1.1.725 

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

OwnerID is a helper method to define mock.On call

  • ctx context.Context
  • name string

func (*MockNatsService_Expecter) OwnerName added in v1.1.725 

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

OwnerName is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*MockNatsService_Expecter) PublishMessage added in v1.1.725 

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

PublishMessage is a helper method to define mock.On call

  • ctx context.Context
  • name string
  • key string
  • vars []byte

func (*MockNatsService_Expecter) PublishWorkflowState added in v1.1.725 

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

PublishWorkflowState is a helper method to define mock.On call

  • ctx context.Context
  • stateName string
  • state *model.WorkflowState
  • ops ...storage.PublishOpt

func (*MockNatsService_Expecter) PutTaskSpec added in v1.1.725 

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

PutTaskSpec is a helper method to define mock.On call

  • ctx context.Context
  • spec *model.TaskSpec

func (*MockNatsService_Expecter) RecordHistoryActivityComplete added in v1.1.725 

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

RecordHistoryActivityComplete is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockNatsService_Expecter) RecordHistoryActivityExecute added in v1.1.725 

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

RecordHistoryActivityExecute is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockNatsService_Expecter) RecordHistoryProcessAbort added in v1.1.725 

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

RecordHistoryProcessAbort is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockNatsService_Expecter) RecordHistoryProcessComplete added in v1.1.725 

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

RecordHistoryProcessComplete is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockNatsService_Expecter) RecordHistoryProcessSpawn added in v1.1.725 

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

RecordHistoryProcessSpawn is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState
  • newProcessInstanceID string

func (*MockNatsService_Expecter) RecordHistoryProcessStart added in v1.1.725 

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

RecordHistoryProcessStart is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockNatsService_Expecter) SaveState added in v1.1.725 

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

SaveState is a helper method to define mock.On call

  • ctx context.Context
  • id string
  • state *model.WorkflowState

func (*MockNatsService_Expecter) SetAbort added in v1.1.725 

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

SetAbort is a helper method to define mock.On call

  • processor services.AbortFunc

func (*MockNatsService_Expecter) SetCompleteActivity added in v1.1.725 

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

SetCompleteActivity is a helper method to define mock.On call

  • processor services.CompleteActivityFunc

func (*MockNatsService_Expecter) SetCompleteActivityProcessor added in v1.1.725 

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

SetCompleteActivityProcessor is a helper method to define mock.On call

  • processor services.CompleteActivityProcessorFunc

func (*MockNatsService_Expecter) SetCompleteJobProcessor added in v1.1.725 

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

SetCompleteJobProcessor is a helper method to define mock.On call

  • processor services.CompleteJobProcessorFunc

func (*MockNatsService_Expecter) SetEventProcessor added in v1.1.725 

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

SetEventProcessor is a helper method to define mock.On call

  • processor services.EventProcessorFunc

func (*MockNatsService_Expecter) SetLaunchFunc added in v1.1.725 

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

SetLaunchFunc is a helper method to define mock.On call

  • processor services.LaunchFunc

func (*MockNatsService_Expecter) SetMessageProcessor added in v1.1.725 

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

SetMessageProcessor is a helper method to define mock.On call

  • processor services.MessageProcessorFunc

func (*MockNatsService_Expecter) SetTraversalProvider added in v1.1.725 

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

SetTraversalProvider is a helper method to define mock.On call

  • provider services.TraversalFunc

func (*MockNatsService_Expecter) Shutdown added in v1.1.725 

func (_e *MockNatsService_Expecter) Shutdown() *MockNatsService_Shutdown_Call

Shutdown is a helper method to define mock.On call

func (*MockNatsService_Expecter) StartProcessing added in v1.1.725 

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

StartProcessing is a helper method to define mock.On call

  • ctx context.Context

func (*MockNatsService_Expecter) StoreWorkflow added in v1.1.725 

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

StoreWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • wf *model.Workflow

func (*MockNatsService_Expecter) XDestroyProcessInstance added in v1.1.725 

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

XDestroyProcessInstance is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

type MockNatsService_GetElement_Call added in v1.1.725 

type MockNatsService_GetElement_Call struct {
	*mock.Call
}

MockNatsService_GetElement_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetElement'

func (*MockNatsService_GetElement_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetElement_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetElement_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetExecution_Call added in v1.1.725 

type MockNatsService_GetExecution_Call struct {
	*mock.Call
}

MockNatsService_GetExecution_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetExecution'

func (*MockNatsService_GetExecution_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetExecution_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetExecution_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetGatewayInstanceID_Call added in v1.1.725 

type MockNatsService_GetGatewayInstanceID_Call struct {
	*mock.Call
}

MockNatsService_GetGatewayInstanceID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetGatewayInstanceID'

func (*MockNatsService_GetGatewayInstanceID_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetGatewayInstanceID_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetGatewayInstanceID_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetGatewayInstance_Call added in v1.1.725 

type MockNatsService_GetGatewayInstance_Call struct {
	*mock.Call
}

MockNatsService_GetGatewayInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetGatewayInstance'

func (*MockNatsService_GetGatewayInstance_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetGatewayInstance_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetGatewayInstance_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetJob_Call added in v1.1.725 

type MockNatsService_GetJob_Call struct {
	*mock.Call
}

MockNatsService_GetJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJob'

func (*MockNatsService_GetJob_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetJob_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetJob_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetLatestVersion_Call added in v1.1.725 

type MockNatsService_GetLatestVersion_Call struct {
	*mock.Call
}

MockNatsService_GetLatestVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestVersion'

func (*MockNatsService_GetLatestVersion_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetLatestVersion_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetLatestVersion_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetOldState_Call added in v1.1.725 

type MockNatsService_GetOldState_Call struct {
	*mock.Call
}

MockNatsService_GetOldState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOldState'

func (*MockNatsService_GetOldState_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetOldState_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetOldState_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetProcessHistory_Call added in v1.1.725 

type MockNatsService_GetProcessHistory_Call struct {
	*mock.Call
}

MockNatsService_GetProcessHistory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetProcessHistory'

func (*MockNatsService_GetProcessHistory_Call) Return added in v1.1.725 

func (_c *MockNatsService_GetProcessHistory_Call) Return() *MockNatsService_GetProcessHistory_Call

func (*MockNatsService_GetProcessHistory_Call) Run added in v1.1.725 

func (_c *MockNatsService_GetProcessHistory_Call) Run(run func(ctx context.Context, processInstanceId string, wch chan<- *model.ProcessHistoryEntry, errs chan<- error)) *MockNatsService_GetProcessHistory_Call

func (*MockNatsService_GetProcessHistory_Call) RunAndReturn added in v1.1.725 

func (_c *MockNatsService_GetProcessHistory_Call) RunAndReturn(run func(context.Context, string, chan<- *model.ProcessHistoryEntry, chan<- error)) *MockNatsService_GetProcessHistory_Call

type MockNatsService_GetProcessInstance_Call added in v1.1.725 

type MockNatsService_GetProcessInstance_Call struct {
	*mock.Call
}

MockNatsService_GetProcessInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetProcessInstance'

func (*MockNatsService_GetProcessInstance_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetProcessInstance_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetProcessInstance_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetTaskSpecByUID_Call added in v1.1.725 

type MockNatsService_GetTaskSpecByUID_Call struct {
	*mock.Call
}

MockNatsService_GetTaskSpecByUID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskSpecByUID'

func (*MockNatsService_GetTaskSpecByUID_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetTaskSpecByUID_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetTaskSpecByUID_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetTaskSpecUID_Call added in v1.1.725 

type MockNatsService_GetTaskSpecUID_Call struct {
	*mock.Call
}

MockNatsService_GetTaskSpecUID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskSpecUID'

func (*MockNatsService_GetTaskSpecUID_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetTaskSpecUID_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetTaskSpecUID_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetWorkflowNameFor_Call added in v1.1.725 

type MockNatsService_GetWorkflowNameFor_Call struct {
	*mock.Call
}

MockNatsService_GetWorkflowNameFor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflowNameFor'

func (*MockNatsService_GetWorkflowNameFor_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetWorkflowNameFor_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetWorkflowNameFor_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_GetWorkflowVersions_Call added in v1.1.725 

type MockNatsService_GetWorkflowVersions_Call struct {
	*mock.Call
}

MockNatsService_GetWorkflowVersions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflowVersions'

func (*MockNatsService_GetWorkflowVersions_Call) Return added in v1.1.725 

func (_c *MockNatsService_GetWorkflowVersions_Call) Return() *MockNatsService_GetWorkflowVersions_Call

func (*MockNatsService_GetWorkflowVersions_Call) Run added in v1.1.725 

func (_c *MockNatsService_GetWorkflowVersions_Call) Run(run func(_a0 context.Context, _a1 string, _a2 chan<- *model.WorkflowVersion, _a3 chan<- error)) *MockNatsService_GetWorkflowVersions_Call

func (*MockNatsService_GetWorkflowVersions_Call) RunAndReturn added in v1.1.725 

func (_c *MockNatsService_GetWorkflowVersions_Call) RunAndReturn(run func(context.Context, string, chan<- *model.WorkflowVersion, chan<- error)) *MockNatsService_GetWorkflowVersions_Call

type MockNatsService_GetWorkflow_Call added in v1.1.725 

type MockNatsService_GetWorkflow_Call struct {
	*mock.Call
}

MockNatsService_GetWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetWorkflow'

func (*MockNatsService_GetWorkflow_Call) Return added in v1.1.725 

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

func (*MockNatsService_GetWorkflow_Call) Run added in v1.1.725 

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

func (*MockNatsService_GetWorkflow_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_Heartbeat_Call added in v1.1.731 

type MockNatsService_Heartbeat_Call struct {
	*mock.Call
}

MockNatsService_Heartbeat_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Heartbeat'

func (*MockNatsService_Heartbeat_Call) Return added in v1.1.731 

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

func (*MockNatsService_Heartbeat_Call) Run added in v1.1.731 

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

func (*MockNatsService_Heartbeat_Call) RunAndReturn added in v1.1.731 

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

type MockNatsService_ListExecutionProcesses_Call added in v1.1.725 

type MockNatsService_ListExecutionProcesses_Call struct {
	*mock.Call
}

MockNatsService_ListExecutionProcesses_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListExecutionProcesses'

func (*MockNatsService_ListExecutionProcesses_Call) Return added in v1.1.725 

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

func (*MockNatsService_ListExecutionProcesses_Call) Run added in v1.1.725 

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

func (*MockNatsService_ListExecutionProcesses_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_ListExecutions_Call added in v1.1.725 

type MockNatsService_ListExecutions_Call struct {
	*mock.Call
}

MockNatsService_ListExecutions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListExecutions'

func (*MockNatsService_ListExecutions_Call) Return added in v1.1.725 

func (_c *MockNatsService_ListExecutions_Call) Return() *MockNatsService_ListExecutions_Call

func (*MockNatsService_ListExecutions_Call) Run added in v1.1.725 

func (_c *MockNatsService_ListExecutions_Call) Run(run func(ctx context.Context, id string, res chan<- *model.ListExecutionItem, errs chan<- error)) *MockNatsService_ListExecutions_Call

func (*MockNatsService_ListExecutions_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_ListWorkflows_Call added in v1.1.725 

type MockNatsService_ListWorkflows_Call struct {
	*mock.Call
}

MockNatsService_ListWorkflows_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListWorkflows'

func (*MockNatsService_ListWorkflows_Call) Return added in v1.1.725 

func (_c *MockNatsService_ListWorkflows_Call) Return() *MockNatsService_ListWorkflows_Call

func (*MockNatsService_ListWorkflows_Call) Run added in v1.1.725 

func (_c *MockNatsService_ListWorkflows_Call) Run(run func(ctx context.Context, res chan<- *model.ListWorkflowResponse, errs chan<- error)) *MockNatsService_ListWorkflows_Call

func (*MockNatsService_ListWorkflows_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_OwnerID_Call added in v1.1.725 

type MockNatsService_OwnerID_Call struct {
	*mock.Call
}

MockNatsService_OwnerID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OwnerID'

func (*MockNatsService_OwnerID_Call) Return added in v1.1.725 

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

func (*MockNatsService_OwnerID_Call) Run added in v1.1.725 

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

func (*MockNatsService_OwnerID_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_OwnerName_Call added in v1.1.725 

type MockNatsService_OwnerName_Call struct {
	*mock.Call
}

MockNatsService_OwnerName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OwnerName'

func (*MockNatsService_OwnerName_Call) Return added in v1.1.725 

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

func (*MockNatsService_OwnerName_Call) Run added in v1.1.725 

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

func (*MockNatsService_OwnerName_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_PublishMessage_Call added in v1.1.725 

type MockNatsService_PublishMessage_Call struct {
	*mock.Call
}

MockNatsService_PublishMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishMessage'

func (*MockNatsService_PublishMessage_Call) Return added in v1.1.725 

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

func (*MockNatsService_PublishMessage_Call) Run added in v1.1.725 

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

func (*MockNatsService_PublishMessage_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_PublishWorkflowState_Call added in v1.1.725 

type MockNatsService_PublishWorkflowState_Call struct {
	*mock.Call
}

MockNatsService_PublishWorkflowState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishWorkflowState'

func (*MockNatsService_PublishWorkflowState_Call) Return added in v1.1.725 

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

func (*MockNatsService_PublishWorkflowState_Call) Run added in v1.1.725 

func (_c *MockNatsService_PublishWorkflowState_Call) Run(run func(ctx context.Context, stateName string, state *model.WorkflowState, ops ...storage.PublishOpt)) *MockNatsService_PublishWorkflowState_Call

func (*MockNatsService_PublishWorkflowState_Call) RunAndReturn added in v1.1.725 

func (_c *MockNatsService_PublishWorkflowState_Call) RunAndReturn(run func(context.Context, string, *model.WorkflowState, ...storage.PublishOpt) error) *MockNatsService_PublishWorkflowState_Call

type MockNatsService_PutTaskSpec_Call added in v1.1.725 

type MockNatsService_PutTaskSpec_Call struct {
	*mock.Call
}

MockNatsService_PutTaskSpec_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutTaskSpec'

func (*MockNatsService_PutTaskSpec_Call) Return added in v1.1.725 

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

func (*MockNatsService_PutTaskSpec_Call) Run added in v1.1.725 

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

func (*MockNatsService_PutTaskSpec_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_RecordHistoryActivityComplete_Call added in v1.1.725 

type MockNatsService_RecordHistoryActivityComplete_Call struct {
	*mock.Call
}

MockNatsService_RecordHistoryActivityComplete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordHistoryActivityComplete'

func (*MockNatsService_RecordHistoryActivityComplete_Call) Return added in v1.1.725 

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

func (*MockNatsService_RecordHistoryActivityComplete_Call) Run added in v1.1.725 

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

func (*MockNatsService_RecordHistoryActivityComplete_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_RecordHistoryActivityExecute_Call added in v1.1.725 

type MockNatsService_RecordHistoryActivityExecute_Call struct {
	*mock.Call
}

MockNatsService_RecordHistoryActivityExecute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordHistoryActivityExecute'

func (*MockNatsService_RecordHistoryActivityExecute_Call) Return added in v1.1.725 

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

func (*MockNatsService_RecordHistoryActivityExecute_Call) Run added in v1.1.725 

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

func (*MockNatsService_RecordHistoryActivityExecute_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_RecordHistoryProcessAbort_Call added in v1.1.725 

type MockNatsService_RecordHistoryProcessAbort_Call struct {
	*mock.Call
}

MockNatsService_RecordHistoryProcessAbort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordHistoryProcessAbort'

func (*MockNatsService_RecordHistoryProcessAbort_Call) Return added in v1.1.725 

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

func (*MockNatsService_RecordHistoryProcessAbort_Call) Run added in v1.1.725 

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

func (*MockNatsService_RecordHistoryProcessAbort_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_RecordHistoryProcessComplete_Call added in v1.1.725 

type MockNatsService_RecordHistoryProcessComplete_Call struct {
	*mock.Call
}

MockNatsService_RecordHistoryProcessComplete_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordHistoryProcessComplete'

func (*MockNatsService_RecordHistoryProcessComplete_Call) Return added in v1.1.725 

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

func (*MockNatsService_RecordHistoryProcessComplete_Call) Run added in v1.1.725 

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

func (*MockNatsService_RecordHistoryProcessComplete_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_RecordHistoryProcessSpawn_Call added in v1.1.725 

type MockNatsService_RecordHistoryProcessSpawn_Call struct {
	*mock.Call
}

MockNatsService_RecordHistoryProcessSpawn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordHistoryProcessSpawn'

func (*MockNatsService_RecordHistoryProcessSpawn_Call) Return added in v1.1.725 

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

func (*MockNatsService_RecordHistoryProcessSpawn_Call) Run added in v1.1.725 

func (_c *MockNatsService_RecordHistoryProcessSpawn_Call) Run(run func(ctx context.Context, state *model.WorkflowState, newProcessInstanceID string)) *MockNatsService_RecordHistoryProcessSpawn_Call

func (*MockNatsService_RecordHistoryProcessSpawn_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_RecordHistoryProcessStart_Call added in v1.1.725 

type MockNatsService_RecordHistoryProcessStart_Call struct {
	*mock.Call
}

MockNatsService_RecordHistoryProcessStart_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordHistoryProcessStart'

func (*MockNatsService_RecordHistoryProcessStart_Call) Return added in v1.1.725 

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

func (*MockNatsService_RecordHistoryProcessStart_Call) Run added in v1.1.725 

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

func (*MockNatsService_RecordHistoryProcessStart_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SaveState_Call added in v1.1.725 

type MockNatsService_SaveState_Call struct {
	*mock.Call
}

MockNatsService_SaveState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SaveState'

func (*MockNatsService_SaveState_Call) Return added in v1.1.725 

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

func (*MockNatsService_SaveState_Call) Run added in v1.1.725 

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

func (*MockNatsService_SaveState_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SetAbort_Call added in v1.1.725 

type MockNatsService_SetAbort_Call struct {
	*mock.Call
}

MockNatsService_SetAbort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetAbort'

func (*MockNatsService_SetAbort_Call) Return added in v1.1.725 

func (_c *MockNatsService_SetAbort_Call) Return() *MockNatsService_SetAbort_Call

func (*MockNatsService_SetAbort_Call) Run added in v1.1.725 

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

func (*MockNatsService_SetAbort_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SetCompleteActivityProcessor_Call added in v1.1.725 

type MockNatsService_SetCompleteActivityProcessor_Call struct {
	*mock.Call
}

MockNatsService_SetCompleteActivityProcessor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetCompleteActivityProcessor'

func (*MockNatsService_SetCompleteActivityProcessor_Call) Return added in v1.1.725 

func (_c *MockNatsService_SetCompleteActivityProcessor_Call) Return() *MockNatsService_SetCompleteActivityProcessor_Call

func (*MockNatsService_SetCompleteActivityProcessor_Call) Run added in v1.1.725 

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

func (*MockNatsService_SetCompleteActivityProcessor_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SetCompleteActivity_Call added in v1.1.725 

type MockNatsService_SetCompleteActivity_Call struct {
	*mock.Call
}

MockNatsService_SetCompleteActivity_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetCompleteActivity'

func (*MockNatsService_SetCompleteActivity_Call) Return added in v1.1.725 

func (_c *MockNatsService_SetCompleteActivity_Call) Return() *MockNatsService_SetCompleteActivity_Call

func (*MockNatsService_SetCompleteActivity_Call) Run added in v1.1.725 

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

func (*MockNatsService_SetCompleteActivity_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SetCompleteJobProcessor_Call added in v1.1.725 

type MockNatsService_SetCompleteJobProcessor_Call struct {
	*mock.Call
}

MockNatsService_SetCompleteJobProcessor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetCompleteJobProcessor'

func (*MockNatsService_SetCompleteJobProcessor_Call) Return added in v1.1.725 

func (_c *MockNatsService_SetCompleteJobProcessor_Call) Return() *MockNatsService_SetCompleteJobProcessor_Call

func (*MockNatsService_SetCompleteJobProcessor_Call) Run added in v1.1.725 

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

func (*MockNatsService_SetCompleteJobProcessor_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SetEventProcessor_Call added in v1.1.725 

type MockNatsService_SetEventProcessor_Call struct {
	*mock.Call
}

MockNatsService_SetEventProcessor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetEventProcessor'

func (*MockNatsService_SetEventProcessor_Call) Return added in v1.1.725 

func (_c *MockNatsService_SetEventProcessor_Call) Return() *MockNatsService_SetEventProcessor_Call

func (*MockNatsService_SetEventProcessor_Call) Run added in v1.1.725 

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

func (*MockNatsService_SetEventProcessor_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SetLaunchFunc_Call added in v1.1.725 

type MockNatsService_SetLaunchFunc_Call struct {
	*mock.Call
}

MockNatsService_SetLaunchFunc_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetLaunchFunc'

func (*MockNatsService_SetLaunchFunc_Call) Return added in v1.1.725 

func (_c *MockNatsService_SetLaunchFunc_Call) Return() *MockNatsService_SetLaunchFunc_Call

func (*MockNatsService_SetLaunchFunc_Call) Run added in v1.1.725 

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

func (*MockNatsService_SetLaunchFunc_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SetMessageProcessor_Call added in v1.1.725 

type MockNatsService_SetMessageProcessor_Call struct {
	*mock.Call
}

MockNatsService_SetMessageProcessor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetMessageProcessor'

func (*MockNatsService_SetMessageProcessor_Call) Return added in v1.1.725 

func (_c *MockNatsService_SetMessageProcessor_Call) Return() *MockNatsService_SetMessageProcessor_Call

func (*MockNatsService_SetMessageProcessor_Call) Run added in v1.1.725 

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

func (*MockNatsService_SetMessageProcessor_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_SetTraversalProvider_Call added in v1.1.725 

type MockNatsService_SetTraversalProvider_Call struct {
	*mock.Call
}

MockNatsService_SetTraversalProvider_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetTraversalProvider'

func (*MockNatsService_SetTraversalProvider_Call) Return added in v1.1.725 

func (_c *MockNatsService_SetTraversalProvider_Call) Return() *MockNatsService_SetTraversalProvider_Call

func (*MockNatsService_SetTraversalProvider_Call) Run added in v1.1.725 

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

func (*MockNatsService_SetTraversalProvider_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_Shutdown_Call added in v1.1.725 

type MockNatsService_Shutdown_Call struct {
	*mock.Call
}

MockNatsService_Shutdown_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Shutdown'

func (*MockNatsService_Shutdown_Call) Return added in v1.1.725 

func (_c *MockNatsService_Shutdown_Call) Return() *MockNatsService_Shutdown_Call

func (*MockNatsService_Shutdown_Call) Run added in v1.1.725 

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

func (*MockNatsService_Shutdown_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_StartProcessing_Call added in v1.1.725 

type MockNatsService_StartProcessing_Call struct {
	*mock.Call
}

MockNatsService_StartProcessing_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartProcessing'

func (*MockNatsService_StartProcessing_Call) Return added in v1.1.725 

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

func (*MockNatsService_StartProcessing_Call) Run added in v1.1.725 

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

func (*MockNatsService_StartProcessing_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_StoreWorkflow_Call added in v1.1.725 

type MockNatsService_StoreWorkflow_Call struct {
	*mock.Call
}

MockNatsService_StoreWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StoreWorkflow'

func (*MockNatsService_StoreWorkflow_Call) Return added in v1.1.725 

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

func (*MockNatsService_StoreWorkflow_Call) Run added in v1.1.725 

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

func (*MockNatsService_StoreWorkflow_Call) RunAndReturn added in v1.1.725 

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

type MockNatsService_XDestroyProcessInstance_Call added in v1.1.725 

type MockNatsService_XDestroyProcessInstance_Call struct {
	*mock.Call
}

MockNatsService_XDestroyProcessInstance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'XDestroyProcessInstance'

func (*MockNatsService_XDestroyProcessInstance_Call) Return added in v1.1.725 

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

func (*MockNatsService_XDestroyProcessInstance_Call) Run added in v1.1.725 

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

func (*MockNatsService_XDestroyProcessInstance_Call) RunAndReturn added in v1.1.725 

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

type NatsService 

type NatsService interface {
	CheckProcessTaskDeprecation(ctx context.Context, workflow *model.Workflow, processName string) error
	CloseUserTask(ctx context.Context, trackingID string) error
	Conn() common.NatsConn
	CreateExecution(ctx context.Context, wfInstance *model.Execution) (*model.Execution, error)
	CreateJob(ctx context.Context, job *model.WorkflowState) (string, error)
	CreateProcessInstance(ctx context.Context, workflowInstanceID string, parentProcessID string, parentElementID string, processName string, workflowName string, workflowId string) (*model.ProcessInstance, error)
	DeleteJob(ctx context.Context, trackingID string) error
	DestroyProcessInstance(ctx context.Context, state *model.WorkflowState, pi *model.ProcessInstance, wi *model.Execution) error
	EnsureServiceTaskConsumer(ctx context.Context, uid string) error
	GetElement(ctx context.Context, state *model.WorkflowState) (*model.Element, error)
	GetExecution(ctx context.Context, workflowInstanceID string) (*model.Execution, error)
	GetGatewayInstance(ctx context.Context, gatewayInstanceID string) (*model.Gateway, error)
	GetGatewayInstanceID(state *model.WorkflowState) (string, string, error)
	GetJob(ctx context.Context, id string) (*model.WorkflowState, error)
	GetLatestVersion(ctx context.Context, workflowName string) (string, error)
	GetOldState(ctx context.Context, id string) (*model.WorkflowState, error)
	GetProcessHistory(ctx context.Context, processInstanceId string, wch chan<- *model.ProcessHistoryEntry, errs chan<- error)
	GetProcessInstance(ctx context.Context, processInstanceID string) (*model.ProcessInstance, error)
	GetTaskSpecByUID(ctx context.Context, uid string) (*model.TaskSpec, error)
	GetTaskSpecUID(ctx context.Context, name string) (string, error)
	GetWorkflow(ctx context.Context, workflowID string) (*model.Workflow, error)
	GetWorkflowNameFor(ctx context.Context, processName string) (string, error)
	GetWorkflowVersions(context.Context, string, chan<- *model.WorkflowVersion, chan<- error)
	Heartbeat(ctx context.Context, request *model.HeartbeatRequest) error
	ListExecutionProcesses(ctx context.Context, id string) ([]string, error)
	ListExecutions(ctx context.Context, id string, res chan<- *model.ListExecutionItem, errs chan<- error)
	ListWorkflows(ctx context.Context, res chan<- *model.ListWorkflowResponse, errs chan<- error)
	OwnerID(ctx context.Context, name string) (string, error)
	OwnerName(ctx context.Context, id string) (string, error)
	PublishMessage(ctx context.Context, name string, key string, vars []byte) error
	PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, ops ...storage.PublishOpt) error
	PutTaskSpec(ctx context.Context, spec *model.TaskSpec) (string, error)
	RecordHistoryActivityComplete(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryActivityExecute(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryProcessAbort(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryProcessComplete(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryProcessSpawn(ctx context.Context, state *model.WorkflowState, newProcessInstanceID string) error
	RecordHistoryProcessStart(ctx context.Context, state *model.WorkflowState) error
	SaveState(ctx context.Context, id string, state *model.WorkflowState) error
	SetAbort(processor services.AbortFunc)
	SetCompleteActivity(processor services.CompleteActivityFunc)
	SetCompleteActivityProcessor(processor services.CompleteActivityProcessorFunc)
	SetCompleteJobProcessor(processor services.CompleteJobProcessorFunc)
	SetEventProcessor(processor services.EventProcessorFunc)
	SetLaunchFunc(processor services.LaunchFunc)
	SetMessageProcessor(processor services.MessageProcessorFunc)
	SetTraversalProvider(provider services.TraversalFunc)
	Shutdown()
	StartProcessing(ctx context.Context) error
	StoreWorkflow(ctx context.Context, wf *model.Workflow) (string, error)
	XDestroyProcessInstance(ctx context.Context, state *model.WorkflowState) error
}

NatsService is the shar type responsible for interacting with NATS.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.