workflow

package
v1.1.1507 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2024 License: MIT Imports: 50 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AbortTypeActivity    = iota // AbortTypeActivity signifies an activity is being aborted
	AbortTypeServiceTask = iota // AbortTypeServiceTask signifies a service task is being aborted
)

Variables

This section is empty.

Functions

func NoOpServiceTaskConsumerFn 

func NoOpServiceTaskConsumerFn(_ context.Context, _ string) error

NoOpServiceTaskConsumerFn no op service task consumer fn

func NoOpWorkFlowProcessMappingFn 

func NoOpWorkFlowProcessMappingFn(_ context.Context, _ *model.Workflow, _ *model.Process) (uint64, error)

NoOpWorkFlowProcessMappingFn no op workflow to process mapping fn

func WithEmbargo 

func WithEmbargo(embargo int) *publishEmbargoOption

WithEmbargo allows the specification of an embargo time on a workflow state message

func WithHeaders 

func WithHeaders(headers map[string]string) *publishHeadersOption

WithHeaders allows the addition of extra headers to a workflow state message

Types

type AbortType 

type AbortType int

AbortType represents the type of termination being handled by the abort function

type Engine 

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

Engine contains the workflow processing functions

func New 

func New(natsService *natz.NatsService, operations *Operations, options *option.ServerOptions) (*Engine, error)

New returns an instance of the core workflow engine.

func (*Engine) Compensate 

func (s *Engine) Compensate(ctx context.Context, state *model.WorkflowState) error

Compensate is a method of the Engine struct that performs the compensation process for a given workflow state. It retrieves the necessary information and history from the workflow and processes it to determine the compensation steps. It then creates a compensation plan and publishes each step to a designated subject for further processing. Finally, it updates the state of the workflow to indicate that the compensation is in progress. It returns an error if any step of the compensation process encounters an issue.

func (*Engine) GetGatewayInstance 

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

GetGatewayInstance - returns a gateway instance from the KV store.

func (*Engine) GetGatewayInstanceID 

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

GetGatewayInstanceID - returns a gateawy instance ID and a satisfying route to that gateway.

func (*Engine) Shutdown 

func (s *Engine) Shutdown()

Shutdown signals the engine to stop processing.

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.

func (*Engine) StartProcessing 

func (s *Engine) StartProcessing(ctx context.Context) error

StartProcessing begins listening to all the message processing queues.

type MockOps added in v1.1.1404 

type MockOps struct {
	mock.Mock
}

MockOps is an autogenerated mock type for the Ops type

func NewMockOps added in v1.1.1404 

func NewMockOps(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockOps

NewMockOps creates a new instance of MockOps. 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 (*MockOps) CancelProcessInstance added in v1.1.1404 

func (_m *MockOps) CancelProcessInstance(ctx context.Context, state *model.WorkflowState) error

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

func (*MockOps) CompleteManualTask added in v1.1.1404 

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

CompleteManualTask provides a mock function with given fields: ctx, job, newvars

func (*MockOps) CompleteSendMessageTask added in v1.1.1404 

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

CompleteSendMessageTask provides a mock function with given fields: ctx, job, newvars

func (*MockOps) CompleteServiceTask added in v1.1.1404 

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

CompleteServiceTask provides a mock function with given fields: ctx, job, newvars

func (*MockOps) CompleteUserTask added in v1.1.1404 

func (_m *MockOps) CompleteUserTask(ctx context.Context, jobId string) error

CompleteUserTask provides a mock function with given fields: ctx, jobId

func (*MockOps) DeleteFatalError added in v1.1.1404 

func (_m *MockOps) DeleteFatalError(ctx context.Context, state *model.WorkflowState) error

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

func (*MockOps) DeleteJob added in v1.1.1404 

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

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

func (*MockOps) DeleteNamespace added in v1.1.1404 

func (_m *MockOps) DeleteNamespace(ctx context.Context, ns string) error

DeleteNamespace provides a mock function with given fields: ctx, ns

func (*MockOps) DeprecateTaskSpec added in v1.1.1404 

func (_m *MockOps) DeprecateTaskSpec(ctx context.Context, uid []string) error

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

func (*MockOps) DisableWorkflow added in v1.1.1460 

func (_m *MockOps) DisableWorkflow(ctx context.Context, workflowName string) error

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

func (*MockOps) EXPECT added in v1.1.1404 

func (_m *MockOps) EXPECT() *MockOps_Expecter

func (*MockOps) EnableWorkflow added in v1.1.1460 

func (_m *MockOps) EnableWorkflow(ctx context.Context, workflowName string) error

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

func (*MockOps) GetActiveEntries added in v1.1.1404 

func (_m *MockOps) GetActiveEntries(ctx context.Context, processInstanceID string, result chan<- *model.ProcessHistoryEntry, errs chan<- error)

GetActiveEntries provides a mock function with given fields: ctx, processInstanceID, result, errs

func (*MockOps) GetCompensationInputVariables added in v1.1.1404 

func (_m *MockOps) GetCompensationInputVariables(ctx context.Context, processInstanceId string, trackingId string) ([]byte, error)

GetCompensationInputVariables provides a mock function with given fields: ctx, processInstanceId, trackingId

func (*MockOps) GetCompensationOutputVariables added in v1.1.1404 

func (_m *MockOps) GetCompensationOutputVariables(ctx context.Context, processInstanceId string, trackingId string) ([]byte, error)

GetCompensationOutputVariables provides a mock function with given fields: ctx, processInstanceId, trackingId

func (*MockOps) GetExecutableWorkflowIds added in v1.1.1404 

func (_m *MockOps) GetExecutableWorkflowIds(ctx context.Context) ([]string, error)

GetExecutableWorkflowIds provides a mock function with given fields: ctx

func (*MockOps) GetExecution added in v1.1.1404 

func (_m *MockOps) GetExecution(ctx context.Context, executionID string) (*model.Execution, error)

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

func (*MockOps) GetFatalErrors added in v1.1.1404 

func (_m *MockOps) GetFatalErrors(ctx context.Context, keyPrefix string, fatalErrs chan<- *model.FatalError, errs chan<- error)

GetFatalErrors provides a mock function with given fields: ctx, keyPrefix, fatalErrs, errs

func (*MockOps) GetJob added in v1.1.1404 

func (_m *MockOps) GetJob(ctx context.Context, trackingID string) (*model.WorkflowState, error)

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

func (*MockOps) GetProcessHistory added in v1.1.1404 

func (_m *MockOps) 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 (*MockOps) GetProcessHistoryItem added in v1.1.1404 

func (_m *MockOps) GetProcessHistoryItem(ctx context.Context, processInstanceID string, trackingID string, historyType model.ProcessHistoryType) (*model.ProcessHistoryEntry, error)

GetProcessHistoryItem provides a mock function with given fields: ctx, processInstanceID, trackingID, historyType

func (*MockOps) GetProcessIdFor added in v1.1.1404 

func (_m *MockOps) GetProcessIdFor(ctx context.Context, startEventMessageName string) (string, error)

GetProcessIdFor provides a mock function with given fields: ctx, startEventMessageName

func (*MockOps) GetProcessInstance added in v1.1.1404 

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

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

func (*MockOps) GetTaskSpecByUID added in v1.1.1404 

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

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

func (*MockOps) GetTaskSpecUID added in v1.1.1404 

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

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

func (*MockOps) GetTaskSpecUsage added in v1.1.1404 

func (_m *MockOps) GetTaskSpecUsage(ctx context.Context, uid []string) (*model.TaskSpecUsageReport, error)

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

func (*MockOps) GetTaskSpecUsageByName added in v1.1.1404 

func (_m *MockOps) GetTaskSpecUsageByName(ctx context.Context, name string) (*model.TaskSpecUsageReport, error)

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

func (*MockOps) GetTaskSpecVersions added in v1.1.1404 

func (_m *MockOps) GetTaskSpecVersions(ctx context.Context, name string) (*model.TaskSpecVersions, error)

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

func (*MockOps) GetUserTaskIDs added in v1.1.1404 

func (_m *MockOps) GetUserTaskIDs(ctx context.Context, owner string) (*model.UserTasks, error)

GetUserTaskIDs provides a mock function with given fields: ctx, owner

func (*MockOps) GetWorkflow added in v1.1.1404 

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

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

func (*MockOps) HandleWorkflowError added in v1.1.1404 

func (_m *MockOps) HandleWorkflowError(ctx context.Context, errorCode string, inVars []byte, state *model.WorkflowState) error

HandleWorkflowError provides a mock function with given fields: ctx, errorCode, inVars, state

func (*MockOps) Heartbeat added in v1.1.1404 

func (_m *MockOps) Heartbeat(ctx context.Context, req *model.HeartbeatRequest) error

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

func (*MockOps) Launch added in v1.1.1404 

func (_m *MockOps) Launch(ctx context.Context, processId string, vars []byte, headers []byte) (string, string, error)

Launch provides a mock function with given fields: ctx, processId, vars, headers

func (*MockOps) LaunchWithParent added in v1.1.1404 

func (_m *MockOps) LaunchWithParent(ctx context.Context, processId string, ID common.TrackingID, vrs []byte, headers []byte, parentpiID string, parentElID string) (string, string, error)

LaunchWithParent provides a mock function with given fields: ctx, processId, ID, vrs, headers, parentpiID, parentElID

func (*MockOps) ListExecutableProcesses added in v1.1.1404 

func (_m *MockOps) ListExecutableProcesses(ctx context.Context, wch chan<- *model.ListExecutableProcessesItem, errs chan<- error)

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

func (*MockOps) ListExecutionProcesses added in v1.1.1404 

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

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

func (*MockOps) ListExecutions added in v1.1.1404 

func (_m *MockOps) ListExecutions(ctx context.Context, workflowName string, wch chan<- *model.ListExecutionItem, errs chan<- error)

ListExecutions provides a mock function with given fields: ctx, workflowName, wch, errs

func (*MockOps) ListTaskSpecUIDs added in v1.1.1404 

func (_m *MockOps) ListTaskSpecUIDs(ctx context.Context, deprecated bool) ([]string, error)

ListTaskSpecUIDs provides a mock function with given fields: ctx, deprecated

func (*MockOps) ListUserTasks added in v1.1.1492 

func (_m *MockOps) ListUserTasks(ctx context.Context, owner string, group string, res chan<- *model.ListUserTasksResponse, errs chan<- error)

ListUserTasks provides a mock function with given fields: ctx, owner, group, res, errs

func (*MockOps) ListWorkflows added in v1.1.1404 

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

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

func (*MockOps) LoadWorkflow added in v1.1.1404 

func (_m *MockOps) LoadWorkflow(ctx context.Context, _a1 *model.Workflow) (string, error)

LoadWorkflow provides a mock function with given fields: ctx, _a1

func (*MockOps) Log added in v1.1.1404 

func (_m *MockOps) Log(ctx context.Context, req *model.LogRequest) error

Log provides a mock function with given fields: ctx, req

func (*MockOps) OpenUserTask added in v1.1.1492 

func (_m *MockOps) OpenUserTask(ctx context.Context, id string, owner string) ([]byte, error)

OpenUserTask provides a mock function with given fields: ctx, id, owner

func (*MockOps) OwnerID added in v1.1.1404 

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

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

func (*MockOps) OwnerName added in v1.1.1404 

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

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

func (*MockOps) PersistFatalError added in v1.1.1404 

func (_m *MockOps) PersistFatalError(ctx context.Context, fatalError *model.FatalError) (bool, error)

PersistFatalError provides a mock function with given fields: ctx, fatalError

func (*MockOps) ProcessTasks added in v1.1.1492 

func (_m *MockOps) ProcessTasks(ctx context.Context, wf *model.Workflow, svcTaskConsFn ServiceTaskConsumerFn, wfProcessMappingFn WorkflowProcessMappingFn) error

ProcessTasks provides a mock function with given fields: ctx, wf, svcTaskConsFn, wfProcessMappingFn

func (*MockOps) PublishMsg added in v1.1.1404 

func (_m *MockOps) PublishMsg(ctx context.Context, subject string, sharMsg protoreflect.ProtoMessage) error

PublishMsg provides a mock function with given fields: ctx, subject, sharMsg

func (*MockOps) PublishWorkflowState added in v1.1.1404 

func (_m *MockOps) PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, opts ...PublishOpt) error

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

func (*MockOps) PutTaskSpec added in v1.1.1404 

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

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

func (*MockOps) RecordHistory added in v1.1.1404 

func (_m *MockOps) RecordHistory(ctx context.Context, state *model.WorkflowState, historyType model.ProcessHistoryType) error

RecordHistory provides a mock function with given fields: ctx, state, historyType

func (*MockOps) RecordHistoryActivityComplete added in v1.1.1404 

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

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

func (*MockOps) RecordHistoryActivityExecute added in v1.1.1404 

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

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

func (*MockOps) RecordHistoryCompensationCheckpoint added in v1.1.1404 

func (_m *MockOps) RecordHistoryCompensationCheckpoint(ctx context.Context, state *model.WorkflowState) error

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

func (*MockOps) RecordHistoryJobAbort added in v1.1.1404 

func (_m *MockOps) RecordHistoryJobAbort(ctx context.Context, state *model.WorkflowState) error

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

func (*MockOps) RecordHistoryJobComplete added in v1.1.1404 

func (_m *MockOps) RecordHistoryJobComplete(ctx context.Context, state *model.WorkflowState) error

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

func (*MockOps) RecordHistoryJobExecute added in v1.1.1404 

func (_m *MockOps) RecordHistoryJobExecute(ctx context.Context, state *model.WorkflowState) error

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

func (*MockOps) RecordHistoryProcessAbort added in v1.1.1404 

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

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

func (*MockOps) RecordHistoryProcessComplete added in v1.1.1404 

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

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

func (*MockOps) RecordHistoryProcessSpawn added in v1.1.1404 

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

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

func (*MockOps) RecordHistoryProcessStart added in v1.1.1404 

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

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

func (*MockOps) RetryActivity added in v1.1.1404 

func (_m *MockOps) RetryActivity(ctx context.Context, state *model.WorkflowState) error

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

func (*MockOps) SaveUserTask added in v1.1.1492 

func (_m *MockOps) SaveUserTask(ctx context.Context, id string, v []byte, overwrite bool) error

SaveUserTask provides a mock function with given fields: ctx, id, v, overwrite

func (*MockOps) SignalFatalErrorPause added in v1.1.1404 

func (_m *MockOps) SignalFatalErrorPause(ctx context.Context, state *model.WorkflowState, log *slog.Logger)

SignalFatalErrorPause provides a mock function with given fields: ctx, state, log

func (*MockOps) SignalFatalErrorTeardown added in v1.1.1404 

func (_m *MockOps) SignalFatalErrorTeardown(ctx context.Context, state *model.WorkflowState, log *slog.Logger)

SignalFatalErrorTeardown provides a mock function with given fields: ctx, state, log

func (*MockOps) StreamWorkflowVersions added in v1.1.1460 

func (_m *MockOps) StreamWorkflowVersions(ctx context.Context, workflowName string, wch chan<- *model.WorkflowVersion, errs chan<- error)

StreamWorkflowVersions provides a mock function with given fields: ctx, workflowName, wch, errs

type MockOps_CancelProcessInstance_Call added in v1.1.1404 

type MockOps_CancelProcessInstance_Call struct {
	*mock.Call
}

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

func (*MockOps_CancelProcessInstance_Call) Return added in v1.1.1404 

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

func (*MockOps_CancelProcessInstance_Call) Run added in v1.1.1404 

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

func (*MockOps_CancelProcessInstance_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_CompleteManualTask_Call added in v1.1.1404 

type MockOps_CompleteManualTask_Call struct {
	*mock.Call
}

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

func (*MockOps_CompleteManualTask_Call) Return added in v1.1.1404 

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

func (*MockOps_CompleteManualTask_Call) Run added in v1.1.1404 

func (_c *MockOps_CompleteManualTask_Call) Run(run func(ctx context.Context, job *model.WorkflowState, newvars []byte)) *MockOps_CompleteManualTask_Call

func (*MockOps_CompleteManualTask_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_CompleteManualTask_Call) RunAndReturn(run func(context.Context, *model.WorkflowState, []byte) error) *MockOps_CompleteManualTask_Call

type MockOps_CompleteSendMessageTask_Call added in v1.1.1404 

type MockOps_CompleteSendMessageTask_Call struct {
	*mock.Call
}

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

func (*MockOps_CompleteSendMessageTask_Call) Return added in v1.1.1404 

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

func (*MockOps_CompleteSendMessageTask_Call) Run added in v1.1.1404 

func (_c *MockOps_CompleteSendMessageTask_Call) Run(run func(ctx context.Context, job *model.WorkflowState, newvars []byte)) *MockOps_CompleteSendMessageTask_Call

func (*MockOps_CompleteSendMessageTask_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_CompleteSendMessageTask_Call) RunAndReturn(run func(context.Context, *model.WorkflowState, []byte) error) *MockOps_CompleteSendMessageTask_Call

type MockOps_CompleteServiceTask_Call added in v1.1.1404 

type MockOps_CompleteServiceTask_Call struct {
	*mock.Call
}

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

func (*MockOps_CompleteServiceTask_Call) Return added in v1.1.1404 

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

func (*MockOps_CompleteServiceTask_Call) Run added in v1.1.1404 

func (_c *MockOps_CompleteServiceTask_Call) Run(run func(ctx context.Context, job *model.WorkflowState, newvars []byte)) *MockOps_CompleteServiceTask_Call

func (*MockOps_CompleteServiceTask_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_CompleteServiceTask_Call) RunAndReturn(run func(context.Context, *model.WorkflowState, []byte) error) *MockOps_CompleteServiceTask_Call

type MockOps_CompleteUserTask_Call added in v1.1.1404 

type MockOps_CompleteUserTask_Call struct {
	*mock.Call
}

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

func (*MockOps_CompleteUserTask_Call) Return added in v1.1.1404 

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

func (*MockOps_CompleteUserTask_Call) Run added in v1.1.1404 

func (_c *MockOps_CompleteUserTask_Call) Run(run func(ctx context.Context, jobId string)) *MockOps_CompleteUserTask_Call

func (*MockOps_CompleteUserTask_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_DeleteFatalError_Call added in v1.1.1404 

type MockOps_DeleteFatalError_Call struct {
	*mock.Call
}

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

func (*MockOps_DeleteFatalError_Call) Return added in v1.1.1404 

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

func (*MockOps_DeleteFatalError_Call) Run added in v1.1.1404 

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

func (*MockOps_DeleteFatalError_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_DeleteJob_Call added in v1.1.1404 

type MockOps_DeleteJob_Call struct {
	*mock.Call
}

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

func (*MockOps_DeleteJob_Call) Return added in v1.1.1404 

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

func (*MockOps_DeleteJob_Call) Run added in v1.1.1404 

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

func (*MockOps_DeleteJob_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_DeleteNamespace_Call added in v1.1.1404 

type MockOps_DeleteNamespace_Call struct {
	*mock.Call
}

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

func (*MockOps_DeleteNamespace_Call) Return added in v1.1.1404 

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

func (*MockOps_DeleteNamespace_Call) Run added in v1.1.1404 

func (_c *MockOps_DeleteNamespace_Call) Run(run func(ctx context.Context, ns string)) *MockOps_DeleteNamespace_Call

func (*MockOps_DeleteNamespace_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_DeprecateTaskSpec_Call added in v1.1.1404 

type MockOps_DeprecateTaskSpec_Call struct {
	*mock.Call
}

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

func (*MockOps_DeprecateTaskSpec_Call) Return added in v1.1.1404 

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

func (*MockOps_DeprecateTaskSpec_Call) Run added in v1.1.1404 

func (_c *MockOps_DeprecateTaskSpec_Call) Run(run func(ctx context.Context, uid []string)) *MockOps_DeprecateTaskSpec_Call

func (*MockOps_DeprecateTaskSpec_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_DisableWorkflow_Call added in v1.1.1460 

type MockOps_DisableWorkflow_Call struct {
	*mock.Call
}

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

func (*MockOps_DisableWorkflow_Call) Return added in v1.1.1460 

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

func (*MockOps_DisableWorkflow_Call) Run added in v1.1.1460 

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

func (*MockOps_DisableWorkflow_Call) RunAndReturn added in v1.1.1460 

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

type MockOps_EnableWorkflow_Call added in v1.1.1460 

type MockOps_EnableWorkflow_Call struct {
	*mock.Call
}

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

func (*MockOps_EnableWorkflow_Call) Return added in v1.1.1460 

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

func (*MockOps_EnableWorkflow_Call) Run added in v1.1.1460 

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

func (*MockOps_EnableWorkflow_Call) RunAndReturn added in v1.1.1460 

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

type MockOps_Expecter added in v1.1.1404 

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

func (*MockOps_Expecter) CancelProcessInstance added in v1.1.1404 

func (_e *MockOps_Expecter) CancelProcessInstance(ctx interface{}, state interface{}) *MockOps_CancelProcessInstance_Call

CancelProcessInstance is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) CompleteManualTask added in v1.1.1404 

func (_e *MockOps_Expecter) CompleteManualTask(ctx interface{}, job interface{}, newvars interface{}) *MockOps_CompleteManualTask_Call

CompleteManualTask is a helper method to define mock.On call

  • ctx context.Context
  • job *model.WorkflowState
  • newvars []byte

func (*MockOps_Expecter) CompleteSendMessageTask added in v1.1.1404 

func (_e *MockOps_Expecter) CompleteSendMessageTask(ctx interface{}, job interface{}, newvars interface{}) *MockOps_CompleteSendMessageTask_Call

CompleteSendMessageTask is a helper method to define mock.On call

  • ctx context.Context
  • job *model.WorkflowState
  • newvars []byte

func (*MockOps_Expecter) CompleteServiceTask added in v1.1.1404 

func (_e *MockOps_Expecter) CompleteServiceTask(ctx interface{}, job interface{}, newvars interface{}) *MockOps_CompleteServiceTask_Call

CompleteServiceTask is a helper method to define mock.On call

  • ctx context.Context
  • job *model.WorkflowState
  • newvars []byte

func (*MockOps_Expecter) CompleteUserTask added in v1.1.1404 

func (_e *MockOps_Expecter) CompleteUserTask(ctx interface{}, jobId interface{}) *MockOps_CompleteUserTask_Call

CompleteUserTask is a helper method to define mock.On call

  • ctx context.Context
  • jobId string

func (*MockOps_Expecter) DeleteFatalError added in v1.1.1404 

func (_e *MockOps_Expecter) DeleteFatalError(ctx interface{}, state interface{}) *MockOps_DeleteFatalError_Call

DeleteFatalError is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) DeleteJob added in v1.1.1404 

func (_e *MockOps_Expecter) DeleteJob(ctx interface{}, trackingID interface{}) *MockOps_DeleteJob_Call

DeleteJob is a helper method to define mock.On call

  • ctx context.Context
  • trackingID string

func (*MockOps_Expecter) DeleteNamespace added in v1.1.1404 

func (_e *MockOps_Expecter) DeleteNamespace(ctx interface{}, ns interface{}) *MockOps_DeleteNamespace_Call

DeleteNamespace is a helper method to define mock.On call

  • ctx context.Context
  • ns string

func (*MockOps_Expecter) DeprecateTaskSpec added in v1.1.1404 

func (_e *MockOps_Expecter) DeprecateTaskSpec(ctx interface{}, uid interface{}) *MockOps_DeprecateTaskSpec_Call

DeprecateTaskSpec is a helper method to define mock.On call

  • ctx context.Context
  • uid []string

func (*MockOps_Expecter) DisableWorkflow added in v1.1.1460 

func (_e *MockOps_Expecter) DisableWorkflow(ctx interface{}, workflowName interface{}) *MockOps_DisableWorkflow_Call

DisableWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowName string

func (*MockOps_Expecter) EnableWorkflow added in v1.1.1460 

func (_e *MockOps_Expecter) EnableWorkflow(ctx interface{}, workflowName interface{}) *MockOps_EnableWorkflow_Call

EnableWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowName string

func (*MockOps_Expecter) GetActiveEntries added in v1.1.1404 

func (_e *MockOps_Expecter) GetActiveEntries(ctx interface{}, processInstanceID interface{}, result interface{}, errs interface{}) *MockOps_GetActiveEntries_Call

GetActiveEntries is a helper method to define mock.On call

  • ctx context.Context
  • processInstanceID string
  • result chan<- *model.ProcessHistoryEntry
  • errs chan<- error

func (*MockOps_Expecter) GetCompensationInputVariables added in v1.1.1404 

func (_e *MockOps_Expecter) GetCompensationInputVariables(ctx interface{}, processInstanceId interface{}, trackingId interface{}) *MockOps_GetCompensationInputVariables_Call

GetCompensationInputVariables is a helper method to define mock.On call

  • ctx context.Context
  • processInstanceId string
  • trackingId string

func (*MockOps_Expecter) GetCompensationOutputVariables added in v1.1.1404 

func (_e *MockOps_Expecter) GetCompensationOutputVariables(ctx interface{}, processInstanceId interface{}, trackingId interface{}) *MockOps_GetCompensationOutputVariables_Call

GetCompensationOutputVariables is a helper method to define mock.On call

  • ctx context.Context
  • processInstanceId string
  • trackingId string

func (*MockOps_Expecter) GetExecutableWorkflowIds added in v1.1.1404 

func (_e *MockOps_Expecter) GetExecutableWorkflowIds(ctx interface{}) *MockOps_GetExecutableWorkflowIds_Call

GetExecutableWorkflowIds is a helper method to define mock.On call

  • ctx context.Context

func (*MockOps_Expecter) GetExecution added in v1.1.1404 

func (_e *MockOps_Expecter) GetExecution(ctx interface{}, executionID interface{}) *MockOps_GetExecution_Call

GetExecution is a helper method to define mock.On call

  • ctx context.Context
  • executionID string

func (*MockOps_Expecter) GetFatalErrors added in v1.1.1404 

func (_e *MockOps_Expecter) GetFatalErrors(ctx interface{}, keyPrefix interface{}, fatalErrs interface{}, errs interface{}) *MockOps_GetFatalErrors_Call

GetFatalErrors is a helper method to define mock.On call

  • ctx context.Context
  • keyPrefix string
  • fatalErrs chan<- *model.FatalError
  • errs chan<- error

func (*MockOps_Expecter) GetJob added in v1.1.1404 

func (_e *MockOps_Expecter) GetJob(ctx interface{}, trackingID interface{}) *MockOps_GetJob_Call

GetJob is a helper method to define mock.On call

  • ctx context.Context
  • trackingID string

func (*MockOps_Expecter) GetProcessHistory added in v1.1.1404 

func (_e *MockOps_Expecter) GetProcessHistory(ctx interface{}, processInstanceId interface{}, wch interface{}, errs interface{}) *MockOps_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 (*MockOps_Expecter) GetProcessHistoryItem added in v1.1.1404 

func (_e *MockOps_Expecter) GetProcessHistoryItem(ctx interface{}, processInstanceID interface{}, trackingID interface{}, historyType interface{}) *MockOps_GetProcessHistoryItem_Call

GetProcessHistoryItem is a helper method to define mock.On call

  • ctx context.Context
  • processInstanceID string
  • trackingID string
  • historyType model.ProcessHistoryType

func (*MockOps_Expecter) GetProcessIdFor added in v1.1.1404 

func (_e *MockOps_Expecter) GetProcessIdFor(ctx interface{}, startEventMessageName interface{}) *MockOps_GetProcessIdFor_Call

GetProcessIdFor is a helper method to define mock.On call

  • ctx context.Context
  • startEventMessageName string

func (*MockOps_Expecter) GetProcessInstance added in v1.1.1404 

func (_e *MockOps_Expecter) GetProcessInstance(ctx interface{}, processInstanceID interface{}) *MockOps_GetProcessInstance_Call

GetProcessInstance is a helper method to define mock.On call

  • ctx context.Context
  • processInstanceID string

func (*MockOps_Expecter) GetTaskSpecByUID added in v1.1.1404 

func (_e *MockOps_Expecter) GetTaskSpecByUID(ctx interface{}, uid interface{}) *MockOps_GetTaskSpecByUID_Call

GetTaskSpecByUID is a helper method to define mock.On call

  • ctx context.Context
  • uid string

func (*MockOps_Expecter) GetTaskSpecUID added in v1.1.1404 

func (_e *MockOps_Expecter) GetTaskSpecUID(ctx interface{}, name interface{}) *MockOps_GetTaskSpecUID_Call

GetTaskSpecUID is a helper method to define mock.On call

  • ctx context.Context
  • name string

func (*MockOps_Expecter) GetTaskSpecUsage added in v1.1.1404 

func (_e *MockOps_Expecter) GetTaskSpecUsage(ctx interface{}, uid interface{}) *MockOps_GetTaskSpecUsage_Call

GetTaskSpecUsage is a helper method to define mock.On call

  • ctx context.Context
  • uid []string

func (*MockOps_Expecter) GetTaskSpecUsageByName added in v1.1.1404 

func (_e *MockOps_Expecter) GetTaskSpecUsageByName(ctx interface{}, name interface{}) *MockOps_GetTaskSpecUsageByName_Call

GetTaskSpecUsageByName is a helper method to define mock.On call

  • ctx context.Context
  • name string

func (*MockOps_Expecter) GetTaskSpecVersions added in v1.1.1404 

func (_e *MockOps_Expecter) GetTaskSpecVersions(ctx interface{}, name interface{}) *MockOps_GetTaskSpecVersions_Call

GetTaskSpecVersions is a helper method to define mock.On call

  • ctx context.Context
  • name string

func (*MockOps_Expecter) GetUserTaskIDs added in v1.1.1404 

func (_e *MockOps_Expecter) GetUserTaskIDs(ctx interface{}, owner interface{}) *MockOps_GetUserTaskIDs_Call

GetUserTaskIDs is a helper method to define mock.On call

  • ctx context.Context
  • owner string

func (*MockOps_Expecter) GetWorkflow added in v1.1.1404 

func (_e *MockOps_Expecter) GetWorkflow(ctx interface{}, workflowID interface{}) *MockOps_GetWorkflow_Call

GetWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string

func (*MockOps_Expecter) HandleWorkflowError added in v1.1.1404 

func (_e *MockOps_Expecter) HandleWorkflowError(ctx interface{}, errorCode interface{}, inVars interface{}, state interface{}) *MockOps_HandleWorkflowError_Call

HandleWorkflowError is a helper method to define mock.On call

  • ctx context.Context
  • errorCode string
  • inVars []byte
  • state *model.WorkflowState

func (*MockOps_Expecter) Heartbeat added in v1.1.1404 

func (_e *MockOps_Expecter) Heartbeat(ctx interface{}, req interface{}) *MockOps_Heartbeat_Call

Heartbeat is a helper method to define mock.On call

  • ctx context.Context
  • req *model.HeartbeatRequest

func (*MockOps_Expecter) Launch added in v1.1.1404 

func (_e *MockOps_Expecter) Launch(ctx interface{}, processId interface{}, vars interface{}, headers interface{}) *MockOps_Launch_Call

Launch is a helper method to define mock.On call

  • ctx context.Context
  • processId string
  • vars []byte
  • headers []byte

func (*MockOps_Expecter) LaunchWithParent added in v1.1.1404 

func (_e *MockOps_Expecter) LaunchWithParent(ctx interface{}, processId interface{}, ID interface{}, vrs interface{}, headers interface{}, parentpiID interface{}, parentElID interface{}) *MockOps_LaunchWithParent_Call

LaunchWithParent is a helper method to define mock.On call

  • ctx context.Context
  • processId string
  • ID common.TrackingID
  • vrs []byte
  • headers []byte
  • parentpiID string
  • parentElID string

func (*MockOps_Expecter) ListExecutableProcesses added in v1.1.1404 

func (_e *MockOps_Expecter) ListExecutableProcesses(ctx interface{}, wch interface{}, errs interface{}) *MockOps_ListExecutableProcesses_Call

ListExecutableProcesses is a helper method to define mock.On call

  • ctx context.Context
  • wch chan<- *model.ListExecutableProcessesItem
  • errs chan<- error

func (*MockOps_Expecter) ListExecutionProcesses added in v1.1.1404 

func (_e *MockOps_Expecter) ListExecutionProcesses(ctx interface{}, id interface{}) *MockOps_ListExecutionProcesses_Call

ListExecutionProcesses is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*MockOps_Expecter) ListExecutions added in v1.1.1404 

func (_e *MockOps_Expecter) ListExecutions(ctx interface{}, workflowName interface{}, wch interface{}, errs interface{}) *MockOps_ListExecutions_Call

ListExecutions is a helper method to define mock.On call

  • ctx context.Context
  • workflowName string
  • wch chan<- *model.ListExecutionItem
  • errs chan<- error

func (*MockOps_Expecter) ListTaskSpecUIDs added in v1.1.1404 

func (_e *MockOps_Expecter) ListTaskSpecUIDs(ctx interface{}, deprecated interface{}) *MockOps_ListTaskSpecUIDs_Call

ListTaskSpecUIDs is a helper method to define mock.On call

  • ctx context.Context
  • deprecated bool

func (*MockOps_Expecter) ListUserTasks added in v1.1.1492 

func (_e *MockOps_Expecter) ListUserTasks(ctx interface{}, owner interface{}, group interface{}, res interface{}, errs interface{}) *MockOps_ListUserTasks_Call

ListUserTasks is a helper method to define mock.On call

  • ctx context.Context
  • owner string
  • group string
  • res chan<- *model.ListUserTasksResponse
  • errs chan<- error

func (*MockOps_Expecter) ListWorkflows added in v1.1.1404 

func (_e *MockOps_Expecter) ListWorkflows(ctx interface{}, res interface{}, errs interface{}) *MockOps_ListWorkflows_Call

ListWorkflows is a helper method to define mock.On call

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

func (*MockOps_Expecter) LoadWorkflow added in v1.1.1404 

func (_e *MockOps_Expecter) LoadWorkflow(ctx interface{}, _a1 interface{}) *MockOps_LoadWorkflow_Call

LoadWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • _a1 *model.Workflow

func (*MockOps_Expecter) Log added in v1.1.1404 

func (_e *MockOps_Expecter) Log(ctx interface{}, req interface{}) *MockOps_Log_Call

Log is a helper method to define mock.On call

  • ctx context.Context
  • req *model.LogRequest

func (*MockOps_Expecter) OpenUserTask added in v1.1.1492 

func (_e *MockOps_Expecter) OpenUserTask(ctx interface{}, id interface{}, owner interface{}) *MockOps_OpenUserTask_Call

OpenUserTask is a helper method to define mock.On call

  • ctx context.Context
  • id string
  • owner string

func (*MockOps_Expecter) OwnerID added in v1.1.1404 

func (_e *MockOps_Expecter) OwnerID(ctx interface{}, name interface{}) *MockOps_OwnerID_Call

OwnerID is a helper method to define mock.On call

  • ctx context.Context
  • name string

func (*MockOps_Expecter) OwnerName added in v1.1.1404 

func (_e *MockOps_Expecter) OwnerName(ctx interface{}, id interface{}) *MockOps_OwnerName_Call

OwnerName is a helper method to define mock.On call

  • ctx context.Context
  • id string

func (*MockOps_Expecter) PersistFatalError added in v1.1.1404 

func (_e *MockOps_Expecter) PersistFatalError(ctx interface{}, fatalError interface{}) *MockOps_PersistFatalError_Call

PersistFatalError is a helper method to define mock.On call

  • ctx context.Context
  • fatalError *model.FatalError

func (*MockOps_Expecter) ProcessTasks added in v1.1.1492 

func (_e *MockOps_Expecter) ProcessTasks(ctx interface{}, wf interface{}, svcTaskConsFn interface{}, wfProcessMappingFn interface{}) *MockOps_ProcessTasks_Call

ProcessTasks is a helper method to define mock.On call

  • ctx context.Context
  • wf *model.Workflow
  • svcTaskConsFn ServiceTaskConsumerFn
  • wfProcessMappingFn WorkflowProcessMappingFn

func (*MockOps_Expecter) PublishMsg added in v1.1.1404 

func (_e *MockOps_Expecter) PublishMsg(ctx interface{}, subject interface{}, sharMsg interface{}) *MockOps_PublishMsg_Call

PublishMsg is a helper method to define mock.On call

  • ctx context.Context
  • subject string
  • sharMsg protoreflect.ProtoMessage

func (*MockOps_Expecter) PublishWorkflowState added in v1.1.1404 

func (_e *MockOps_Expecter) PublishWorkflowState(ctx interface{}, stateName interface{}, state interface{}, opts ...interface{}) *MockOps_PublishWorkflowState_Call

PublishWorkflowState is a helper method to define mock.On call

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

func (*MockOps_Expecter) PutTaskSpec added in v1.1.1404 

func (_e *MockOps_Expecter) PutTaskSpec(ctx interface{}, spec interface{}) *MockOps_PutTaskSpec_Call

PutTaskSpec is a helper method to define mock.On call

  • ctx context.Context
  • spec *model.TaskSpec

func (*MockOps_Expecter) RecordHistory added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistory(ctx interface{}, state interface{}, historyType interface{}) *MockOps_RecordHistory_Call

RecordHistory is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState
  • historyType model.ProcessHistoryType

func (*MockOps_Expecter) RecordHistoryActivityComplete added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryActivityComplete(ctx interface{}, state interface{}) *MockOps_RecordHistoryActivityComplete_Call

RecordHistoryActivityComplete is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RecordHistoryActivityExecute added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryActivityExecute(ctx interface{}, state interface{}) *MockOps_RecordHistoryActivityExecute_Call

RecordHistoryActivityExecute is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RecordHistoryCompensationCheckpoint added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryCompensationCheckpoint(ctx interface{}, state interface{}) *MockOps_RecordHistoryCompensationCheckpoint_Call

RecordHistoryCompensationCheckpoint is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RecordHistoryJobAbort added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryJobAbort(ctx interface{}, state interface{}) *MockOps_RecordHistoryJobAbort_Call

RecordHistoryJobAbort is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RecordHistoryJobComplete added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryJobComplete(ctx interface{}, state interface{}) *MockOps_RecordHistoryJobComplete_Call

RecordHistoryJobComplete is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RecordHistoryJobExecute added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryJobExecute(ctx interface{}, state interface{}) *MockOps_RecordHistoryJobExecute_Call

RecordHistoryJobExecute is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RecordHistoryProcessAbort added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryProcessAbort(ctx interface{}, state interface{}) *MockOps_RecordHistoryProcessAbort_Call

RecordHistoryProcessAbort is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RecordHistoryProcessComplete added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryProcessComplete(ctx interface{}, state interface{}) *MockOps_RecordHistoryProcessComplete_Call

RecordHistoryProcessComplete is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RecordHistoryProcessSpawn added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryProcessSpawn(ctx interface{}, state interface{}, newProcessInstanceID interface{}) *MockOps_RecordHistoryProcessSpawn_Call

RecordHistoryProcessSpawn is a helper method to define mock.On call

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

func (*MockOps_Expecter) RecordHistoryProcessStart added in v1.1.1404 

func (_e *MockOps_Expecter) RecordHistoryProcessStart(ctx interface{}, state interface{}) *MockOps_RecordHistoryProcessStart_Call

RecordHistoryProcessStart is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) RetryActivity added in v1.1.1404 

func (_e *MockOps_Expecter) RetryActivity(ctx interface{}, state interface{}) *MockOps_RetryActivity_Call

RetryActivity is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState

func (*MockOps_Expecter) SaveUserTask added in v1.1.1492 

func (_e *MockOps_Expecter) SaveUserTask(ctx interface{}, id interface{}, v interface{}, overwrite interface{}) *MockOps_SaveUserTask_Call

SaveUserTask is a helper method to define mock.On call

  • ctx context.Context
  • id string
  • v []byte
  • overwrite bool

func (*MockOps_Expecter) SignalFatalErrorPause added in v1.1.1404 

func (_e *MockOps_Expecter) SignalFatalErrorPause(ctx interface{}, state interface{}, log interface{}) *MockOps_SignalFatalErrorPause_Call

SignalFatalErrorPause is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState
  • log *slog.Logger

func (*MockOps_Expecter) SignalFatalErrorTeardown added in v1.1.1404 

func (_e *MockOps_Expecter) SignalFatalErrorTeardown(ctx interface{}, state interface{}, log interface{}) *MockOps_SignalFatalErrorTeardown_Call

SignalFatalErrorTeardown is a helper method to define mock.On call

  • ctx context.Context
  • state *model.WorkflowState
  • log *slog.Logger

func (*MockOps_Expecter) StreamWorkflowVersions added in v1.1.1460 

func (_e *MockOps_Expecter) StreamWorkflowVersions(ctx interface{}, workflowName interface{}, wch interface{}, errs interface{}) *MockOps_StreamWorkflowVersions_Call

StreamWorkflowVersions is a helper method to define mock.On call

  • ctx context.Context
  • workflowName string
  • wch chan<- *model.WorkflowVersion
  • errs chan<- error

type MockOps_GetActiveEntries_Call added in v1.1.1404 

type MockOps_GetActiveEntries_Call struct {
	*mock.Call
}

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

func (*MockOps_GetActiveEntries_Call) Return added in v1.1.1404 

func (_c *MockOps_GetActiveEntries_Call) Return() *MockOps_GetActiveEntries_Call

func (*MockOps_GetActiveEntries_Call) Run added in v1.1.1404 

func (_c *MockOps_GetActiveEntries_Call) Run(run func(ctx context.Context, processInstanceID string, result chan<- *model.ProcessHistoryEntry, errs chan<- error)) *MockOps_GetActiveEntries_Call

func (*MockOps_GetActiveEntries_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetCompensationInputVariables_Call added in v1.1.1404 

type MockOps_GetCompensationInputVariables_Call struct {
	*mock.Call
}

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

func (*MockOps_GetCompensationInputVariables_Call) Return added in v1.1.1404 

func (_c *MockOps_GetCompensationInputVariables_Call) Return(_a0 []byte, _a1 error) *MockOps_GetCompensationInputVariables_Call

func (*MockOps_GetCompensationInputVariables_Call) Run added in v1.1.1404 

func (_c *MockOps_GetCompensationInputVariables_Call) Run(run func(ctx context.Context, processInstanceId string, trackingId string)) *MockOps_GetCompensationInputVariables_Call

func (*MockOps_GetCompensationInputVariables_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetCompensationOutputVariables_Call added in v1.1.1404 

type MockOps_GetCompensationOutputVariables_Call struct {
	*mock.Call
}

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

func (*MockOps_GetCompensationOutputVariables_Call) Return added in v1.1.1404 

func (_c *MockOps_GetCompensationOutputVariables_Call) Return(_a0 []byte, _a1 error) *MockOps_GetCompensationOutputVariables_Call

func (*MockOps_GetCompensationOutputVariables_Call) Run added in v1.1.1404 

func (_c *MockOps_GetCompensationOutputVariables_Call) Run(run func(ctx context.Context, processInstanceId string, trackingId string)) *MockOps_GetCompensationOutputVariables_Call

func (*MockOps_GetCompensationOutputVariables_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetExecutableWorkflowIds_Call added in v1.1.1404 

type MockOps_GetExecutableWorkflowIds_Call struct {
	*mock.Call
}

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

func (*MockOps_GetExecutableWorkflowIds_Call) Return added in v1.1.1404 

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

func (*MockOps_GetExecutableWorkflowIds_Call) Run added in v1.1.1404 

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

func (*MockOps_GetExecutableWorkflowIds_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetExecution_Call added in v1.1.1404 

type MockOps_GetExecution_Call struct {
	*mock.Call
}

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

func (*MockOps_GetExecution_Call) Return added in v1.1.1404 

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

func (*MockOps_GetExecution_Call) Run added in v1.1.1404 

func (_c *MockOps_GetExecution_Call) Run(run func(ctx context.Context, executionID string)) *MockOps_GetExecution_Call

func (*MockOps_GetExecution_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetFatalErrors_Call added in v1.1.1404 

type MockOps_GetFatalErrors_Call struct {
	*mock.Call
}

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

func (*MockOps_GetFatalErrors_Call) Return added in v1.1.1404 

func (_c *MockOps_GetFatalErrors_Call) Return() *MockOps_GetFatalErrors_Call

func (*MockOps_GetFatalErrors_Call) Run added in v1.1.1404 

func (_c *MockOps_GetFatalErrors_Call) Run(run func(ctx context.Context, keyPrefix string, fatalErrs chan<- *model.FatalError, errs chan<- error)) *MockOps_GetFatalErrors_Call

func (*MockOps_GetFatalErrors_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetJob_Call added in v1.1.1404 

type MockOps_GetJob_Call struct {
	*mock.Call
}

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

func (*MockOps_GetJob_Call) Return added in v1.1.1404 

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

func (*MockOps_GetJob_Call) Run added in v1.1.1404 

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

func (*MockOps_GetJob_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetProcessHistoryItem_Call added in v1.1.1404 

type MockOps_GetProcessHistoryItem_Call struct {
	*mock.Call
}

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

func (*MockOps_GetProcessHistoryItem_Call) Return added in v1.1.1404 

func (_c *MockOps_GetProcessHistoryItem_Call) Return(_a0 *model.ProcessHistoryEntry, _a1 error) *MockOps_GetProcessHistoryItem_Call

func (*MockOps_GetProcessHistoryItem_Call) Run added in v1.1.1404 

func (_c *MockOps_GetProcessHistoryItem_Call) Run(run func(ctx context.Context, processInstanceID string, trackingID string, historyType model.ProcessHistoryType)) *MockOps_GetProcessHistoryItem_Call

func (*MockOps_GetProcessHistoryItem_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_GetProcessHistoryItem_Call) RunAndReturn(run func(context.Context, string, string, model.ProcessHistoryType) (*model.ProcessHistoryEntry, error)) *MockOps_GetProcessHistoryItem_Call

type MockOps_GetProcessHistory_Call added in v1.1.1404 

type MockOps_GetProcessHistory_Call struct {
	*mock.Call
}

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

func (*MockOps_GetProcessHistory_Call) Return added in v1.1.1404 

func (_c *MockOps_GetProcessHistory_Call) Return() *MockOps_GetProcessHistory_Call

func (*MockOps_GetProcessHistory_Call) Run added in v1.1.1404 

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

func (*MockOps_GetProcessHistory_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetProcessIdFor_Call added in v1.1.1404 

type MockOps_GetProcessIdFor_Call struct {
	*mock.Call
}

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

func (*MockOps_GetProcessIdFor_Call) Return added in v1.1.1404 

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

func (*MockOps_GetProcessIdFor_Call) Run added in v1.1.1404 

func (_c *MockOps_GetProcessIdFor_Call) Run(run func(ctx context.Context, startEventMessageName string)) *MockOps_GetProcessIdFor_Call

func (*MockOps_GetProcessIdFor_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetProcessInstance_Call added in v1.1.1404 

type MockOps_GetProcessInstance_Call struct {
	*mock.Call
}

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

func (*MockOps_GetProcessInstance_Call) Return added in v1.1.1404 

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

func (*MockOps_GetProcessInstance_Call) Run added in v1.1.1404 

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

func (*MockOps_GetProcessInstance_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetTaskSpecByUID_Call added in v1.1.1404 

type MockOps_GetTaskSpecByUID_Call struct {
	*mock.Call
}

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

func (*MockOps_GetTaskSpecByUID_Call) Return added in v1.1.1404 

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

func (*MockOps_GetTaskSpecByUID_Call) Run added in v1.1.1404 

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

func (*MockOps_GetTaskSpecByUID_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetTaskSpecUID_Call added in v1.1.1404 

type MockOps_GetTaskSpecUID_Call struct {
	*mock.Call
}

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

func (*MockOps_GetTaskSpecUID_Call) Return added in v1.1.1404 

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

func (*MockOps_GetTaskSpecUID_Call) Run added in v1.1.1404 

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

func (*MockOps_GetTaskSpecUID_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_GetTaskSpecUsageByName_Call added in v1.1.1404 

type MockOps_GetTaskSpecUsageByName_Call struct {
	*mock.Call
}

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

func (*MockOps_GetTaskSpecUsageByName_Call) Return added in v1.1.1404 

func (_c *MockOps_GetTaskSpecUsageByName_Call) Return(_a0 *model.TaskSpecUsageReport, _a1 error) *MockOps_GetTaskSpecUsageByName_Call

func (*MockOps_GetTaskSpecUsageByName_Call) Run added in v1.1.1404 

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

func (*MockOps_GetTaskSpecUsageByName_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_GetTaskSpecUsageByName_Call) RunAndReturn(run func(context.Context, string) (*model.TaskSpecUsageReport, error)) *MockOps_GetTaskSpecUsageByName_Call

type MockOps_GetTaskSpecUsage_Call added in v1.1.1404 

type MockOps_GetTaskSpecUsage_Call struct {
	*mock.Call
}

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

func (*MockOps_GetTaskSpecUsage_Call) Return added in v1.1.1404 

func (_c *MockOps_GetTaskSpecUsage_Call) Return(_a0 *model.TaskSpecUsageReport, _a1 error) *MockOps_GetTaskSpecUsage_Call

func (*MockOps_GetTaskSpecUsage_Call) Run added in v1.1.1404 

func (_c *MockOps_GetTaskSpecUsage_Call) Run(run func(ctx context.Context, uid []string)) *MockOps_GetTaskSpecUsage_Call

func (*MockOps_GetTaskSpecUsage_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_GetTaskSpecUsage_Call) RunAndReturn(run func(context.Context, []string) (*model.TaskSpecUsageReport, error)) *MockOps_GetTaskSpecUsage_Call

type MockOps_GetTaskSpecVersions_Call added in v1.1.1404 

type MockOps_GetTaskSpecVersions_Call struct {
	*mock.Call
}

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

func (*MockOps_GetTaskSpecVersions_Call) Return added in v1.1.1404 

func (_c *MockOps_GetTaskSpecVersions_Call) Return(_a0 *model.TaskSpecVersions, _a1 error) *MockOps_GetTaskSpecVersions_Call

func (*MockOps_GetTaskSpecVersions_Call) Run added in v1.1.1404 

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

func (*MockOps_GetTaskSpecVersions_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_GetTaskSpecVersions_Call) RunAndReturn(run func(context.Context, string) (*model.TaskSpecVersions, error)) *MockOps_GetTaskSpecVersions_Call

type MockOps_GetUserTaskIDs_Call added in v1.1.1404 

type MockOps_GetUserTaskIDs_Call struct {
	*mock.Call
}

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

func (*MockOps_GetUserTaskIDs_Call) Return added in v1.1.1404 

func (_c *MockOps_GetUserTaskIDs_Call) Return(_a0 *model.UserTasks, _a1 error) *MockOps_GetUserTaskIDs_Call

func (*MockOps_GetUserTaskIDs_Call) Run added in v1.1.1404 

func (_c *MockOps_GetUserTaskIDs_Call) Run(run func(ctx context.Context, owner string)) *MockOps_GetUserTaskIDs_Call

func (*MockOps_GetUserTaskIDs_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_GetUserTaskIDs_Call) RunAndReturn(run func(context.Context, string) (*model.UserTasks, error)) *MockOps_GetUserTaskIDs_Call

type MockOps_GetWorkflow_Call added in v1.1.1404 

type MockOps_GetWorkflow_Call struct {
	*mock.Call
}

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

func (*MockOps_GetWorkflow_Call) Return added in v1.1.1404 

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

func (*MockOps_GetWorkflow_Call) Run added in v1.1.1404 

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

func (*MockOps_GetWorkflow_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_HandleWorkflowError_Call added in v1.1.1404 

type MockOps_HandleWorkflowError_Call struct {
	*mock.Call
}

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

func (*MockOps_HandleWorkflowError_Call) Return added in v1.1.1404 

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

func (*MockOps_HandleWorkflowError_Call) Run added in v1.1.1404 

func (_c *MockOps_HandleWorkflowError_Call) Run(run func(ctx context.Context, errorCode string, inVars []byte, state *model.WorkflowState)) *MockOps_HandleWorkflowError_Call

func (*MockOps_HandleWorkflowError_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_Heartbeat_Call added in v1.1.1404 

type MockOps_Heartbeat_Call struct {
	*mock.Call
}

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

func (*MockOps_Heartbeat_Call) Return added in v1.1.1404 

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

func (*MockOps_Heartbeat_Call) Run added in v1.1.1404 

func (_c *MockOps_Heartbeat_Call) Run(run func(ctx context.Context, req *model.HeartbeatRequest)) *MockOps_Heartbeat_Call

func (*MockOps_Heartbeat_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_LaunchWithParent_Call added in v1.1.1404 

type MockOps_LaunchWithParent_Call struct {
	*mock.Call
}

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

func (*MockOps_LaunchWithParent_Call) Return added in v1.1.1404 

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

func (*MockOps_LaunchWithParent_Call) Run added in v1.1.1404 

func (_c *MockOps_LaunchWithParent_Call) Run(run func(ctx context.Context, processId string, ID common.TrackingID, vrs []byte, headers []byte, parentpiID string, parentElID string)) *MockOps_LaunchWithParent_Call

func (*MockOps_LaunchWithParent_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_Launch_Call added in v1.1.1404 

type MockOps_Launch_Call struct {
	*mock.Call
}

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

func (*MockOps_Launch_Call) Return added in v1.1.1404 

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

func (*MockOps_Launch_Call) Run added in v1.1.1404 

func (_c *MockOps_Launch_Call) Run(run func(ctx context.Context, processId string, vars []byte, headers []byte)) *MockOps_Launch_Call

func (*MockOps_Launch_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_ListExecutableProcesses_Call added in v1.1.1404 

type MockOps_ListExecutableProcesses_Call struct {
	*mock.Call
}

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

func (*MockOps_ListExecutableProcesses_Call) Return added in v1.1.1404 

func (_c *MockOps_ListExecutableProcesses_Call) Return() *MockOps_ListExecutableProcesses_Call

func (*MockOps_ListExecutableProcesses_Call) Run added in v1.1.1404 

func (_c *MockOps_ListExecutableProcesses_Call) Run(run func(ctx context.Context, wch chan<- *model.ListExecutableProcessesItem, errs chan<- error)) *MockOps_ListExecutableProcesses_Call

func (*MockOps_ListExecutableProcesses_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_ListExecutionProcesses_Call added in v1.1.1404 

type MockOps_ListExecutionProcesses_Call struct {
	*mock.Call
}

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

func (*MockOps_ListExecutionProcesses_Call) Return added in v1.1.1404 

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

func (*MockOps_ListExecutionProcesses_Call) Run added in v1.1.1404 

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

func (*MockOps_ListExecutionProcesses_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_ListExecutions_Call added in v1.1.1404 

type MockOps_ListExecutions_Call struct {
	*mock.Call
}

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

func (*MockOps_ListExecutions_Call) Return added in v1.1.1404 

func (_c *MockOps_ListExecutions_Call) Return() *MockOps_ListExecutions_Call

func (*MockOps_ListExecutions_Call) Run added in v1.1.1404 

func (_c *MockOps_ListExecutions_Call) Run(run func(ctx context.Context, workflowName string, wch chan<- *model.ListExecutionItem, errs chan<- error)) *MockOps_ListExecutions_Call

func (*MockOps_ListExecutions_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_ListTaskSpecUIDs_Call added in v1.1.1404 

type MockOps_ListTaskSpecUIDs_Call struct {
	*mock.Call
}

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

func (*MockOps_ListTaskSpecUIDs_Call) Return added in v1.1.1404 

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

func (*MockOps_ListTaskSpecUIDs_Call) Run added in v1.1.1404 

func (_c *MockOps_ListTaskSpecUIDs_Call) Run(run func(ctx context.Context, deprecated bool)) *MockOps_ListTaskSpecUIDs_Call

func (*MockOps_ListTaskSpecUIDs_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_ListUserTasks_Call added in v1.1.1492 

type MockOps_ListUserTasks_Call struct {
	*mock.Call
}

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

func (*MockOps_ListUserTasks_Call) Return added in v1.1.1492 

func (_c *MockOps_ListUserTasks_Call) Return() *MockOps_ListUserTasks_Call

func (*MockOps_ListUserTasks_Call) Run added in v1.1.1492 

func (_c *MockOps_ListUserTasks_Call) Run(run func(ctx context.Context, owner string, group string, res chan<- *model.ListUserTasksResponse, errs chan<- error)) *MockOps_ListUserTasks_Call

func (*MockOps_ListUserTasks_Call) RunAndReturn added in v1.1.1492 

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

type MockOps_ListWorkflows_Call added in v1.1.1404 

type MockOps_ListWorkflows_Call struct {
	*mock.Call
}

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

func (*MockOps_ListWorkflows_Call) Return added in v1.1.1404 

func (_c *MockOps_ListWorkflows_Call) Return() *MockOps_ListWorkflows_Call

func (*MockOps_ListWorkflows_Call) Run added in v1.1.1404 

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

func (*MockOps_ListWorkflows_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_LoadWorkflow_Call added in v1.1.1404 

type MockOps_LoadWorkflow_Call struct {
	*mock.Call
}

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

func (*MockOps_LoadWorkflow_Call) Return added in v1.1.1404 

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

func (*MockOps_LoadWorkflow_Call) Run added in v1.1.1404 

func (_c *MockOps_LoadWorkflow_Call) Run(run func(ctx context.Context, _a1 *model.Workflow)) *MockOps_LoadWorkflow_Call

func (*MockOps_LoadWorkflow_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_Log_Call added in v1.1.1404 

type MockOps_Log_Call struct {
	*mock.Call
}

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

func (*MockOps_Log_Call) Return added in v1.1.1404 

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

func (*MockOps_Log_Call) Run added in v1.1.1404 

func (_c *MockOps_Log_Call) Run(run func(ctx context.Context, req *model.LogRequest)) *MockOps_Log_Call

func (*MockOps_Log_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_Log_Call) RunAndReturn(run func(context.Context, *model.LogRequest) error) *MockOps_Log_Call

type MockOps_OpenUserTask_Call added in v1.1.1492 

type MockOps_OpenUserTask_Call struct {
	*mock.Call
}

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

func (*MockOps_OpenUserTask_Call) Return added in v1.1.1492 

func (_c *MockOps_OpenUserTask_Call) Return(_a0 []byte, _a1 error) *MockOps_OpenUserTask_Call

func (*MockOps_OpenUserTask_Call) Run added in v1.1.1492 

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

func (*MockOps_OpenUserTask_Call) RunAndReturn added in v1.1.1492 

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

type MockOps_OwnerID_Call added in v1.1.1404 

type MockOps_OwnerID_Call struct {
	*mock.Call
}

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

func (*MockOps_OwnerID_Call) Return added in v1.1.1404 

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

func (*MockOps_OwnerID_Call) Run added in v1.1.1404 

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

func (*MockOps_OwnerID_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_OwnerName_Call added in v1.1.1404 

type MockOps_OwnerName_Call struct {
	*mock.Call
}

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

func (*MockOps_OwnerName_Call) Return added in v1.1.1404 

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

func (*MockOps_OwnerName_Call) Run added in v1.1.1404 

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

func (*MockOps_OwnerName_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_PersistFatalError_Call added in v1.1.1404 

type MockOps_PersistFatalError_Call struct {
	*mock.Call
}

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

func (*MockOps_PersistFatalError_Call) Return added in v1.1.1404 

func (_c *MockOps_PersistFatalError_Call) Return(_a0 bool, _a1 error) *MockOps_PersistFatalError_Call

func (*MockOps_PersistFatalError_Call) Run added in v1.1.1404 

func (_c *MockOps_PersistFatalError_Call) Run(run func(ctx context.Context, fatalError *model.FatalError)) *MockOps_PersistFatalError_Call

func (*MockOps_PersistFatalError_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_PersistFatalError_Call) RunAndReturn(run func(context.Context, *model.FatalError) (bool, error)) *MockOps_PersistFatalError_Call

type MockOps_ProcessTasks_Call added in v1.1.1492 

type MockOps_ProcessTasks_Call struct {
	*mock.Call
}

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

func (*MockOps_ProcessTasks_Call) Return added in v1.1.1492 

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

func (*MockOps_ProcessTasks_Call) Run added in v1.1.1492 

func (_c *MockOps_ProcessTasks_Call) Run(run func(ctx context.Context, wf *model.Workflow, svcTaskConsFn ServiceTaskConsumerFn, wfProcessMappingFn WorkflowProcessMappingFn)) *MockOps_ProcessTasks_Call

func (*MockOps_ProcessTasks_Call) RunAndReturn added in v1.1.1492 

func (_c *MockOps_ProcessTasks_Call) RunAndReturn(run func(context.Context, *model.Workflow, ServiceTaskConsumerFn, WorkflowProcessMappingFn) error) *MockOps_ProcessTasks_Call

type MockOps_PublishMsg_Call added in v1.1.1404 

type MockOps_PublishMsg_Call struct {
	*mock.Call
}

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

func (*MockOps_PublishMsg_Call) Return added in v1.1.1404 

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

func (*MockOps_PublishMsg_Call) Run added in v1.1.1404 

func (_c *MockOps_PublishMsg_Call) Run(run func(ctx context.Context, subject string, sharMsg protoreflect.ProtoMessage)) *MockOps_PublishMsg_Call

func (*MockOps_PublishMsg_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_PublishMsg_Call) RunAndReturn(run func(context.Context, string, protoreflect.ProtoMessage) error) *MockOps_PublishMsg_Call

type MockOps_PublishWorkflowState_Call added in v1.1.1404 

type MockOps_PublishWorkflowState_Call struct {
	*mock.Call
}

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

func (*MockOps_PublishWorkflowState_Call) Return added in v1.1.1404 

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

func (*MockOps_PublishWorkflowState_Call) Run added in v1.1.1404 

func (_c *MockOps_PublishWorkflowState_Call) Run(run func(ctx context.Context, stateName string, state *model.WorkflowState, opts ...PublishOpt)) *MockOps_PublishWorkflowState_Call

func (*MockOps_PublishWorkflowState_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_PutTaskSpec_Call added in v1.1.1404 

type MockOps_PutTaskSpec_Call struct {
	*mock.Call
}

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

func (*MockOps_PutTaskSpec_Call) Return added in v1.1.1404 

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

func (*MockOps_PutTaskSpec_Call) Run added in v1.1.1404 

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

func (*MockOps_PutTaskSpec_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryActivityComplete_Call added in v1.1.1404 

type MockOps_RecordHistoryActivityComplete_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryActivityComplete_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryActivityComplete_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryActivityComplete_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryActivityExecute_Call added in v1.1.1404 

type MockOps_RecordHistoryActivityExecute_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryActivityExecute_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryActivityExecute_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryActivityExecute_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryCompensationCheckpoint_Call added in v1.1.1404 

type MockOps_RecordHistoryCompensationCheckpoint_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryCompensationCheckpoint_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryCompensationCheckpoint_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryCompensationCheckpoint_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryJobAbort_Call added in v1.1.1404 

type MockOps_RecordHistoryJobAbort_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryJobAbort_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryJobAbort_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryJobAbort_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryJobComplete_Call added in v1.1.1404 

type MockOps_RecordHistoryJobComplete_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryJobComplete_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryJobComplete_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryJobComplete_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryJobExecute_Call added in v1.1.1404 

type MockOps_RecordHistoryJobExecute_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryJobExecute_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryJobExecute_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryJobExecute_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryProcessAbort_Call added in v1.1.1404 

type MockOps_RecordHistoryProcessAbort_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryProcessAbort_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryProcessAbort_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryProcessAbort_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryProcessComplete_Call added in v1.1.1404 

type MockOps_RecordHistoryProcessComplete_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryProcessComplete_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryProcessComplete_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryProcessComplete_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryProcessSpawn_Call added in v1.1.1404 

type MockOps_RecordHistoryProcessSpawn_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryProcessSpawn_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryProcessSpawn_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryProcessSpawn_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistoryProcessStart_Call added in v1.1.1404 

type MockOps_RecordHistoryProcessStart_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistoryProcessStart_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistoryProcessStart_Call) Run added in v1.1.1404 

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

func (*MockOps_RecordHistoryProcessStart_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RecordHistory_Call added in v1.1.1404 

type MockOps_RecordHistory_Call struct {
	*mock.Call
}

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

func (*MockOps_RecordHistory_Call) Return added in v1.1.1404 

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

func (*MockOps_RecordHistory_Call) Run added in v1.1.1404 

func (_c *MockOps_RecordHistory_Call) Run(run func(ctx context.Context, state *model.WorkflowState, historyType model.ProcessHistoryType)) *MockOps_RecordHistory_Call

func (*MockOps_RecordHistory_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_RetryActivity_Call added in v1.1.1404 

type MockOps_RetryActivity_Call struct {
	*mock.Call
}

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

func (*MockOps_RetryActivity_Call) Return added in v1.1.1404 

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

func (*MockOps_RetryActivity_Call) Run added in v1.1.1404 

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

func (*MockOps_RetryActivity_Call) RunAndReturn added in v1.1.1404 

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

type MockOps_SaveUserTask_Call added in v1.1.1492 

type MockOps_SaveUserTask_Call struct {
	*mock.Call
}

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

func (*MockOps_SaveUserTask_Call) Return added in v1.1.1492 

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

func (*MockOps_SaveUserTask_Call) Run added in v1.1.1492 

func (_c *MockOps_SaveUserTask_Call) Run(run func(ctx context.Context, id string, v []byte, overwrite bool)) *MockOps_SaveUserTask_Call

func (*MockOps_SaveUserTask_Call) RunAndReturn added in v1.1.1492 

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

type MockOps_SignalFatalErrorPause_Call added in v1.1.1404 

type MockOps_SignalFatalErrorPause_Call struct {
	*mock.Call
}

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

func (*MockOps_SignalFatalErrorPause_Call) Return added in v1.1.1404 

func (_c *MockOps_SignalFatalErrorPause_Call) Return() *MockOps_SignalFatalErrorPause_Call

func (*MockOps_SignalFatalErrorPause_Call) Run added in v1.1.1404 

func (_c *MockOps_SignalFatalErrorPause_Call) Run(run func(ctx context.Context, state *model.WorkflowState, log *slog.Logger)) *MockOps_SignalFatalErrorPause_Call

func (*MockOps_SignalFatalErrorPause_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_SignalFatalErrorPause_Call) RunAndReturn(run func(context.Context, *model.WorkflowState, *slog.Logger)) *MockOps_SignalFatalErrorPause_Call

type MockOps_SignalFatalErrorTeardown_Call added in v1.1.1404 

type MockOps_SignalFatalErrorTeardown_Call struct {
	*mock.Call
}

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

func (*MockOps_SignalFatalErrorTeardown_Call) Return added in v1.1.1404 

func (_c *MockOps_SignalFatalErrorTeardown_Call) Return() *MockOps_SignalFatalErrorTeardown_Call

func (*MockOps_SignalFatalErrorTeardown_Call) Run added in v1.1.1404 

func (_c *MockOps_SignalFatalErrorTeardown_Call) Run(run func(ctx context.Context, state *model.WorkflowState, log *slog.Logger)) *MockOps_SignalFatalErrorTeardown_Call

func (*MockOps_SignalFatalErrorTeardown_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_SignalFatalErrorTeardown_Call) RunAndReturn(run func(context.Context, *model.WorkflowState, *slog.Logger)) *MockOps_SignalFatalErrorTeardown_Call

type MockOps_StreamWorkflowVersions_Call added in v1.1.1460 

type MockOps_StreamWorkflowVersions_Call struct {
	*mock.Call
}

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

func (*MockOps_StreamWorkflowVersions_Call) Return added in v1.1.1460 

func (_c *MockOps_StreamWorkflowVersions_Call) Return() *MockOps_StreamWorkflowVersions_Call

func (*MockOps_StreamWorkflowVersions_Call) Run added in v1.1.1460 

func (_c *MockOps_StreamWorkflowVersions_Call) Run(run func(ctx context.Context, workflowName string, wch chan<- *model.WorkflowVersion, errs chan<- error)) *MockOps_StreamWorkflowVersions_Call

func (*MockOps_StreamWorkflowVersions_Call) RunAndReturn added in v1.1.1460 

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

type MockPublishOpt added in v1.1.1404 

type MockPublishOpt struct {
	mock.Mock
}

MockPublishOpt is an autogenerated mock type for the PublishOpt type

func NewMockPublishOpt added in v1.1.1404 

func NewMockPublishOpt(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockPublishOpt

NewMockPublishOpt creates a new instance of MockPublishOpt. 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 (*MockPublishOpt) Apply added in v1.1.1404 

func (_m *MockPublishOpt) Apply(n *publishOptions)

Apply provides a mock function with given fields: n

func (*MockPublishOpt) EXPECT added in v1.1.1404 

func (_m *MockPublishOpt) EXPECT() *MockPublishOpt_Expecter

type MockPublishOpt_Apply_Call added in v1.1.1404 

type MockPublishOpt_Apply_Call struct {
	*mock.Call
}

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

func (*MockPublishOpt_Apply_Call) Return added in v1.1.1404 

func (_c *MockPublishOpt_Apply_Call) Return() *MockPublishOpt_Apply_Call

func (*MockPublishOpt_Apply_Call) Run added in v1.1.1404 

func (_c *MockPublishOpt_Apply_Call) Run(run func(n *publishOptions)) *MockPublishOpt_Apply_Call

func (*MockPublishOpt_Apply_Call) RunAndReturn added in v1.1.1404 

func (_c *MockPublishOpt_Apply_Call) RunAndReturn(run func(*publishOptions)) *MockPublishOpt_Apply_Call

type MockPublishOpt_Expecter added in v1.1.1404 

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

func (*MockPublishOpt_Expecter) Apply added in v1.1.1404 

func (_e *MockPublishOpt_Expecter) Apply(n interface{}) *MockPublishOpt_Apply_Call

Apply is a helper method to define mock.On call

  • n *publishOptions

type MockServiceTaskConsumerFn added in v1.1.1404 

type MockServiceTaskConsumerFn struct {
	mock.Mock
}

MockServiceTaskConsumerFn is an autogenerated mock type for the ServiceTaskConsumerFn type

func NewMockServiceTaskConsumerFn added in v1.1.1404 

func NewMockServiceTaskConsumerFn(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockServiceTaskConsumerFn

NewMockServiceTaskConsumerFn creates a new instance of MockServiceTaskConsumerFn. 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 (*MockServiceTaskConsumerFn) EXPECT added in v1.1.1404 

func (_m *MockServiceTaskConsumerFn) EXPECT() *MockServiceTaskConsumerFn_Expecter

func (*MockServiceTaskConsumerFn) Execute added in v1.1.1404 

func (_m *MockServiceTaskConsumerFn) Execute(ctx context.Context, id string) error

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

type MockServiceTaskConsumerFn_Execute_Call added in v1.1.1404 

type MockServiceTaskConsumerFn_Execute_Call struct {
	*mock.Call
}

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

func (*MockServiceTaskConsumerFn_Execute_Call) Return added in v1.1.1404 

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

func (*MockServiceTaskConsumerFn_Execute_Call) Run added in v1.1.1404 

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

func (*MockServiceTaskConsumerFn_Execute_Call) RunAndReturn added in v1.1.1404 

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

type MockServiceTaskConsumerFn_Expecter added in v1.1.1404 

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

func (*MockServiceTaskConsumerFn_Expecter) Execute added in v1.1.1404 

func (_e *MockServiceTaskConsumerFn_Expecter) Execute(ctx interface{}, id interface{}) *MockServiceTaskConsumerFn_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context
  • id string

type MockWorkflowProcessMappingFn added in v1.1.1404 

type MockWorkflowProcessMappingFn struct {
	mock.Mock
}

MockWorkflowProcessMappingFn is an autogenerated mock type for the WorkflowProcessMappingFn type

func NewMockWorkflowProcessMappingFn added in v1.1.1404 

func NewMockWorkflowProcessMappingFn(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockWorkflowProcessMappingFn

NewMockWorkflowProcessMappingFn creates a new instance of MockWorkflowProcessMappingFn. 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 (*MockWorkflowProcessMappingFn) EXPECT added in v1.1.1404 

func (_m *MockWorkflowProcessMappingFn) EXPECT() *MockWorkflowProcessMappingFn_Expecter

func (*MockWorkflowProcessMappingFn) Execute added in v1.1.1404 

func (_m *MockWorkflowProcessMappingFn) Execute(ctx context.Context, wf *model.Workflow, i *model.Process) (uint64, error)

Execute provides a mock function with given fields: ctx, wf, i

type MockWorkflowProcessMappingFn_Execute_Call added in v1.1.1404 

type MockWorkflowProcessMappingFn_Execute_Call struct {
	*mock.Call
}

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

func (*MockWorkflowProcessMappingFn_Execute_Call) Return added in v1.1.1404 

func (_c *MockWorkflowProcessMappingFn_Execute_Call) Return(_a0 uint64, _a1 error) *MockWorkflowProcessMappingFn_Execute_Call

func (*MockWorkflowProcessMappingFn_Execute_Call) Run added in v1.1.1404 

func (_c *MockWorkflowProcessMappingFn_Execute_Call) Run(run func(ctx context.Context, wf *model.Workflow, i *model.Process)) *MockWorkflowProcessMappingFn_Execute_Call

func (*MockWorkflowProcessMappingFn_Execute_Call) RunAndReturn added in v1.1.1404 

func (_c *MockWorkflowProcessMappingFn_Execute_Call) RunAndReturn(run func(context.Context, *model.Workflow, *model.Process) (uint64, error)) *MockWorkflowProcessMappingFn_Execute_Call

type MockWorkflowProcessMappingFn_Expecter added in v1.1.1404 

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

func (*MockWorkflowProcessMappingFn_Expecter) Execute added in v1.1.1404 

func (_e *MockWorkflowProcessMappingFn_Expecter) Execute(ctx interface{}, wf interface{}, i interface{}) *MockWorkflowProcessMappingFn_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context
  • wf *model.Workflow
  • i *model.Process

type MocksetPartyFn added in v1.1.1404 

type MocksetPartyFn struct {
	mock.Mock
}

MocksetPartyFn is an autogenerated mock type for the setPartyFn type

func NewMocksetPartyFn added in v1.1.1404 

func NewMocksetPartyFn(t interface {
	mock.TestingT
	Cleanup(func())
}) *MocksetPartyFn

NewMocksetPartyFn creates a new instance of MocksetPartyFn. 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 (*MocksetPartyFn) EXPECT added in v1.1.1404 

func (_m *MocksetPartyFn) EXPECT() *MocksetPartyFn_Expecter

func (*MocksetPartyFn) Execute added in v1.1.1404 

func (_m *MocksetPartyFn) Execute(exch *model.Exchange) (*model.Exchange, error)

Execute provides a mock function with given fields: exch

type MocksetPartyFn_Execute_Call added in v1.1.1404 

type MocksetPartyFn_Execute_Call struct {
	*mock.Call
}

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

func (*MocksetPartyFn_Execute_Call) Return added in v1.1.1404 

func (_c *MocksetPartyFn_Execute_Call) Return(_a0 *model.Exchange, _a1 error) *MocksetPartyFn_Execute_Call

func (*MocksetPartyFn_Execute_Call) Run added in v1.1.1404 

func (_c *MocksetPartyFn_Execute_Call) Run(run func(exch *model.Exchange)) *MocksetPartyFn_Execute_Call

func (*MocksetPartyFn_Execute_Call) RunAndReturn added in v1.1.1404 

func (_c *MocksetPartyFn_Execute_Call) RunAndReturn(run func(*model.Exchange) (*model.Exchange, error)) *MocksetPartyFn_Execute_Call

type MocksetPartyFn_Expecter added in v1.1.1404 

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

func (*MocksetPartyFn_Expecter) Execute added in v1.1.1404 

func (_e *MocksetPartyFn_Expecter) Execute(exch interface{}) *MocksetPartyFn_Execute_Call

Execute is a helper method to define mock.On call

  • exch *model.Exchange

type Operations added in v1.1.1131 

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

Operations provides methods for executing and managing workflow processes. It provides methods for various tasks such as canceling process instances, completing tasks, retrieving workflow-related information, and managing workflow execution.

func NewOperations added in v1.1.1131 

func NewOperations(natsService *natz.NatsService, natsConn *natz.NatsConnConfiguration) (*Operations, error)

NewOperations constructs a new Operations instance

func (*Operations) CancelProcessInstance added in v1.1.1131 

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

CancelProcessInstance cancels a workflow instance with a reason.

func (*Operations) CompleteManualTask added in v1.1.1131 

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

CompleteManualTask completes a manual workflow task

func (*Operations) CompleteSendMessageTask added in v1.1.1131 

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

CompleteSendMessageTask completes a send message task

func (*Operations) CompleteServiceTask added in v1.1.1131 

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

CompleteServiceTask completes a workflow service task

func (*Operations) CompleteUserTask added in v1.1.1131 

func (c *Operations) CompleteUserTask(ctx context.Context, jobId string) error

CompleteUserTask completes and closes a user task with variables

func (*Operations) DeleteFatalError added in v1.1.1377 

func (s *Operations) DeleteFatalError(ctx context.Context, state *model.WorkflowState) error

DeleteFatalError removes the fatal error for a given workflow state

func (*Operations) DeleteJob added in v1.1.1131 

func (s *Operations) DeleteJob(ctx context.Context, trackingID string) error

DeleteJob removes a workflow task state.

func (*Operations) DeleteNamespace added in v1.1.1131 

func (s *Operations) DeleteNamespace(ctx context.Context, ns string) error

DeleteNamespace deletes the key-value store for the specified namespace in SHAR. It iterates over all the key-value stores and deletes them one by one. The function returns nil if all key-value stores are successfully deleted.

func (*Operations) DeprecateTaskSpec added in v1.1.1131 

func (s *Operations) DeprecateTaskSpec(ctx context.Context, uid []string) error

DeprecateTaskSpec deprecates one or more task specs by ID.

func (*Operations) DisableWorkflow added in v1.1.1460 

func (s *Operations) DisableWorkflow(ctx context.Context, workflowName string) error

DisableWorkflow stops a workflow from being launched

func (*Operations) EnableWorkflow added in v1.1.1460 

func (s *Operations) EnableWorkflow(ctx context.Context, workflowName string) error

EnableWorkflow allows a workflow to be launched

func (*Operations) GetActiveEntries added in v1.1.1349 

func (s *Operations) GetActiveEntries(ctx context.Context, processInstanceID string, result chan<- *model.ProcessHistoryEntry, errs chan<- error)

GetActiveEntries returns a list of workflow statuses for the specified process instance ID.

func (*Operations) GetCompensationInputVariables added in v1.1.1131 

func (s *Operations) GetCompensationInputVariables(ctx context.Context, processInstanceId string, trackingId string) ([]byte, error)

GetCompensationInputVariables is a method of the Operations struct that retrieves the original input variables for a specific process instance and tracking ID. It returns the variables in byte array format.

func (*Operations) GetCompensationOutputVariables added in v1.1.1131 

func (s *Operations) GetCompensationOutputVariables(ctx context.Context, processInstanceId string, trackingId string) ([]byte, error)

GetCompensationOutputVariables is a method of the Operations struct that retrieves the original output variables of a compensation history entry for a specific process instance and tracking ID. It returns the output variables as a byte array.

func (*Operations) GetExecutableWorkflowIds added in v1.1.1131 

func (s *Operations) GetExecutableWorkflowIds(ctx context.Context) ([]string, error)

GetExecutableWorkflowIds returns a list of all workflow Ids that contain executable processes

func (*Operations) GetExecution added in v1.1.1131 

func (s *Operations) GetExecution(ctx context.Context, executionID string) (*model.Execution, error)

GetExecution retrieves an execution given its ID.

func (*Operations) GetFatalErrors added in v1.1.1377 

func (s *Operations) GetFatalErrors(ctx context.Context, keyPrefix string, fatalErrs chan<- *model.FatalError, errs chan<- error)

GetFatalErrors queries the fatal error KV with a key prefix of the format <workflowName>.<executionId>.<processInstanceId>. and sends the results down the provided fatalErrs channel.

func (*Operations) GetJob added in v1.1.1131 

func (s *Operations) GetJob(ctx context.Context, trackingID string) (*model.WorkflowState, error)

GetJob gets a workflow task state.

func (*Operations) GetProcessHistory added in v1.1.1131 

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

GetProcessHistory fetches the history object for a process.

func (*Operations) GetProcessHistoryItem added in v1.1.1131 

func (s *Operations) GetProcessHistoryItem(ctx context.Context, processInstanceID string, trackingID string, historyType model.ProcessHistoryType) (*model.ProcessHistoryEntry, error)

GetProcessHistoryItem retrieves a process history entry based on the given process instance ID, tracking ID, and history type. If the entry is successfully retrieved, it is unmarshaled into a model.ProcessHistoryEntry object and returned. If an error occurs during the retrieval or unmarshaling process, an error is returned.

func (*Operations) GetProcessIdFor added in v1.1.1131 

func (s *Operations) GetProcessIdFor(ctx context.Context, startEventMessageName string) (string, error)

GetProcessIdFor retrieves the processId that a begun by a message start event

func (*Operations) GetProcessInstance added in v1.1.1131 

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

GetProcessInstance returns a process instance for a given process ID

func (*Operations) GetTaskSpecByUID added in v1.1.1131 

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

GetTaskSpecByUID fetches a task spec from the database.

func (*Operations) GetTaskSpecUID added in v1.1.1131 

func (s *Operations) GetTaskSpecUID(ctx context.Context, name string) (string, error)

GetTaskSpecUID fetches

func (*Operations) GetTaskSpecUsage added in v1.1.1131 

func (s *Operations) GetTaskSpecUsage(ctx context.Context, uid []string) (*model.TaskSpecUsageReport, error)

GetTaskSpecUsage returns the usage report for a list of task specs.

func (*Operations) GetTaskSpecUsageByName added in v1.1.1131 

func (s *Operations) GetTaskSpecUsageByName(ctx context.Context, name string) (*model.TaskSpecUsageReport, error)

GetTaskSpecUsageByName produces a report of running and executable places where the task spec is in use.

func (*Operations) GetTaskSpecVersions added in v1.1.1131 

func (s *Operations) GetTaskSpecVersions(ctx context.Context, name string) (*model.TaskSpecVersions, error)

GetTaskSpecVersions fetches the versions of a given task spec name

func (*Operations) GetUserTaskIDs added in v1.1.1131 

func (s *Operations) GetUserTaskIDs(ctx context.Context, owner string) (*model.UserTasks, error)

GetUserTaskIDs gets a list of tasks given an owner.

func (*Operations) GetWorkflow added in v1.1.1131 

func (s *Operations) GetWorkflow(ctx context.Context, workflowID string) (*model.Workflow, error)

GetWorkflow - retrieves a workflow model given its ID

func (*Operations) HandleWorkflowError added in v1.1.1131 

func (c *Operations) HandleWorkflowError(ctx context.Context, errorCode string, inVars []byte, state *model.WorkflowState) error

HandleWorkflowError handles a workflow error by looking up the error definitions in the workflow, determining the appropriate action to take, and publishing the necessary workflow state updates. It returns an error if there was an issue retrieving the workflow definition, if the workflow doesn't support the specified error code.

func (*Operations) Heartbeat added in v1.1.1131 

func (s *Operations) Heartbeat(ctx context.Context, req *model.HeartbeatRequest) error

Heartbeat saves a client status to the client KV.

func (*Operations) Launch added in v1.1.1131 

func (c *Operations) Launch(ctx context.Context, processId string, vars []byte, headers []byte) (string, string, error)

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

func (*Operations) LaunchWithParent added in v1.1.1131 

func (c *Operations) LaunchWithParent(ctx context.Context, processId string, ID common.TrackingID, vrs []byte, headers []byte, parentpiID string, parentElID string) (string, string, error)

LaunchWithParent contains the underlying logic to start a workflow. It is also called to spawn new instances of child workflows.

func (*Operations) ListExecutableProcesses added in v1.1.1131 

func (s *Operations) ListExecutableProcesses(ctx context.Context, wch chan<- *model.ListExecutableProcessesItem, errs chan<- error)

ListExecutableProcesses returns a list of all the executable processes in SHAR. It retrieves the current SHAR namespace from the context and fetches the workflow versions for that namespace from the key-value store. It then iterates through each workflow version and loads the corresponding workflow. For each process in the workflow, it creates a ListExecutableProcessesItem object and populates it with the process name, workflow name, and the executable start parameters obtained from the workflow's start events. It sends each ListExecutableProcessesItem object to the wch channel.

Parameters: - ctx: The context containing the SHAR namespace. - wch: The channel for sending the list of executable processes. - errs: The channel for sending any errors that occur.

Returns: Nothing. Errors are sent to the errs channel if encountered.

func (*Operations) ListExecutionProcesses added in v1.1.1131 

func (s *Operations) ListExecutionProcesses(ctx context.Context, id string) ([]string, error)

ListExecutionProcesses gets the current processIDs for an execution.

func (*Operations) ListExecutions added in v1.1.1131 

func (s *Operations) ListExecutions(ctx context.Context, workflowName string, wch chan<- *model.ListExecutionItem, errs chan<- error)

ListExecutions returns a list of running workflows and versions given a workflow Name

func (*Operations) ListTaskSpecUIDs added in v1.1.1131 

func (s *Operations) ListTaskSpecUIDs(ctx context.Context, deprecated bool) ([]string, error)

ListTaskSpecUIDs lists UIDs of active (and optionally deprecated) tasks specs.

func (*Operations) ListUserTasks added in v1.1.1492 

func (s *Operations) ListUserTasks(ctx context.Context, owner string, group string, res chan<- *model.ListUserTasksResponse, errs chan<- error)

ListUserTasks lists user tasks based on the specified owner or group and returns results to the provided channel.

func (*Operations) ListWorkflows added in v1.1.1131 

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

ListWorkflows returns a list of all the workflows in SHAR.

func (*Operations) LoadWorkflow added in v1.1.1131 

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

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

func (*Operations) Log added in v1.1.1131 

func (s *Operations) Log(ctx context.Context, req *model.LogRequest) error

Log publishes LogRequest to WorkflowTelemetry Logs subject

func (*Operations) OpenUserTask added in v1.1.1492 

func (s *Operations) OpenUserTask(ctx context.Context, id string, owner string) ([]byte, error)

OpenUserTask opens a user task by its ID and owner, ensuring the task is not locked by another owner.

func (*Operations) OwnerID added in v1.1.1131 

func (s *Operations) OwnerID(ctx context.Context, name string) (string, error)

OwnerID gets a unique identifier for a task owner.

func (*Operations) OwnerName added in v1.1.1131 

func (s *Operations) OwnerName(ctx context.Context, id string) (string, error)

OwnerName retrieves an owner name given an ID.

func (*Operations) PersistFatalError added in v1.1.1377 

func (s *Operations) PersistFatalError(ctx context.Context, fatalError *model.FatalError) (bool, error)

PersistFatalError saves a fatal error to the kv

func (*Operations) ProcessTasks added in v1.1.1492 

func (s *Operations) ProcessTasks(ctx context.Context, wf *model.Workflow, svcTaskConsFn ServiceTaskConsumerFn, wfProcessMappingFn WorkflowProcessMappingFn) error

ProcessTasks iterates over service tasks in the processes of a given workflow setting, validating them and setting their uid into their element definitions

func (*Operations) PublishMsg added in v1.1.1131 

func (s *Operations) PublishMsg(ctx context.Context, subject string, sharMsg proto.Message) error

PublishMsg publishes a workflow message.

func (*Operations) PublishWorkflowState added in v1.1.1131 

func (s *Operations) PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, opts ...PublishOpt) error

PublishWorkflowState publishes a SHAR state object to a given subject

func (*Operations) PutTaskSpec added in v1.1.1131 

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

PutTaskSpec writes a task spec to the database.

func (*Operations) RecordHistory added in v1.1.1131 

func (s *Operations) RecordHistory(ctx context.Context, state *model.WorkflowState, historyType model.ProcessHistoryType) error

RecordHistory records into the history KV.

func (*Operations) RecordHistoryActivityComplete added in v1.1.1131 

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

RecordHistoryActivityComplete records the activity completion into the history object.

func (*Operations) RecordHistoryActivityExecute added in v1.1.1131 

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

RecordHistoryActivityExecute records the activity execute into the history object.

func (*Operations) RecordHistoryCompensationCheckpoint added in v1.1.1131 

func (s *Operations) RecordHistoryCompensationCheckpoint(ctx context.Context, state *model.WorkflowState) error

RecordHistoryCompensationCheckpoint records the process aborting into the history object.

func (*Operations) RecordHistoryJobAbort added in v1.1.1131 

func (s *Operations) RecordHistoryJobAbort(ctx context.Context, state *model.WorkflowState) error

RecordHistoryJobAbort records the job abort into the history object.

func (*Operations) RecordHistoryJobComplete added in v1.1.1131 

func (s *Operations) RecordHistoryJobComplete(ctx context.Context, state *model.WorkflowState) error

RecordHistoryJobComplete records the job completion into the history object.

func (*Operations) RecordHistoryJobExecute added in v1.1.1131 

func (s *Operations) RecordHistoryJobExecute(ctx context.Context, state *model.WorkflowState) error

RecordHistoryJobExecute records the job execute into the history object.

func (*Operations) RecordHistoryProcessAbort added in v1.1.1131 

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

RecordHistoryProcessAbort records the process aborting into the history object.

func (*Operations) RecordHistoryProcessComplete added in v1.1.1131 

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

RecordHistoryProcessComplete records the process completion into the history object.

func (*Operations) RecordHistoryProcessSpawn added in v1.1.1131 

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

RecordHistoryProcessSpawn records the process spawning a new process into the history object.

func (*Operations) RecordHistoryProcessStart added in v1.1.1131 

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

RecordHistoryProcessStart records the process start into the history object.

func (*Operations) RetryActivity added in v1.1.1377 

func (s *Operations) RetryActivity(ctx context.Context, state *model.WorkflowState) error

RetryActivity publishes the state from a prior FatalError to attempt a retry

func (*Operations) SaveUserTask added in v1.1.1492 

func (s *Operations) SaveUserTask(ctx context.Context, id string, b []byte, overwrite bool) error

SaveUserTask saves the user task's state, either by overwriting or merging with existing state based on the `overwrite` flag.

func (*Operations) SignalFatalErrorPause added in v1.1.1377 

func (s *Operations) SignalFatalErrorPause(ctx context.Context, state *model.WorkflowState, log *slog.Logger)

SignalFatalErrorPause publishes a FatalError message on FatalErr of a process in a workflow with a Pause strategy

func (*Operations) SignalFatalErrorTeardown added in v1.1.1377 

func (s *Operations) SignalFatalErrorTeardown(ctx context.Context, state *model.WorkflowState, log *slog.Logger)

SignalFatalErrorTeardown publishes a FatalError message on FatalErr of a process in a workflow with a Teardown strategy

func (*Operations) StreamWorkflowVersions added in v1.1.1460 

func (s *Operations) StreamWorkflowVersions(ctx context.Context, workflowName string, wch chan<- *model.WorkflowVersion, errs chan<- error)

StreamWorkflowVersions - send the versions of the workflow down the supplied channel

type Ops added in v1.1.1377 

type Ops interface {
	GetTaskSpecUID(ctx context.Context, name string) (string, error)
	GetTaskSpecVersions(ctx context.Context, name string) (*model.TaskSpecVersions, error)
	PutTaskSpec(ctx context.Context, spec *model.TaskSpec) (string, error)
	GetTaskSpecByUID(ctx context.Context, uid string) (*model.TaskSpec, error)
	GetTaskSpecUsageByName(ctx context.Context, name string) (*model.TaskSpecUsageReport, error)
	GetExecutableWorkflowIds(ctx context.Context) ([]string, error)
	GetTaskSpecUsage(ctx context.Context, uid []string) (*model.TaskSpecUsageReport, error)
	RecordHistory(ctx context.Context, state *model.WorkflowState, historyType model.ProcessHistoryType) error
	RecordHistoryProcessStart(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryActivityExecute(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryActivityComplete(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryJobExecute(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryJobComplete(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryJobAbort(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
	RecordHistoryProcessAbort(ctx context.Context, state *model.WorkflowState) error
	RecordHistoryCompensationCheckpoint(ctx context.Context, state *model.WorkflowState) error
	GetProcessHistory(ctx context.Context, processInstanceId string, wch chan<- *model.ProcessHistoryEntry, errs chan<- error)
	GetProcessHistoryItem(ctx context.Context, processInstanceID string, trackingID string, historyType model.ProcessHistoryType) (*model.ProcessHistoryEntry, error)
	LoadWorkflow(ctx context.Context, model *model.Workflow) (string, error)
	Launch(ctx context.Context, processId string, vars []byte, headers []byte) (string, string, error)
	LaunchWithParent(ctx context.Context, processId string, ID common.TrackingID, vrs []byte, headers []byte, parentpiID string, parentElID string) (string, string, error)
	CancelProcessInstance(ctx context.Context, state *model.WorkflowState) error
	CompleteManualTask(ctx context.Context, job *model.WorkflowState, newvars []byte) error
	CompleteServiceTask(ctx context.Context, job *model.WorkflowState, newvars []byte) error
	CompleteSendMessageTask(ctx context.Context, job *model.WorkflowState, newvars []byte) error
	CompleteUserTask(ctx context.Context, jobId string) error
	ListWorkflows(ctx context.Context, res chan<- *model.ListWorkflowResponse, errs chan<- error)
	ProcessTasks(ctx context.Context, wf *model.Workflow, svcTaskConsFn ServiceTaskConsumerFn, wfProcessMappingFn WorkflowProcessMappingFn) error
	GetWorkflow(ctx context.Context, workflowID string) (*model.Workflow, error)
	StreamWorkflowVersions(ctx context.Context, workflowName string, wch chan<- *model.WorkflowVersion, errs chan<- error)
	GetExecution(ctx context.Context, executionID string) (*model.Execution, error)
	GetJob(ctx context.Context, trackingID string) (*model.WorkflowState, error)
	DeleteJob(ctx context.Context, trackingID string) error
	ListExecutions(ctx context.Context, workflowName string, wch chan<- *model.ListExecutionItem, errs chan<- error)
	ListExecutionProcesses(ctx context.Context, id string) ([]string, error)
	PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, opts ...PublishOpt) error
	SignalFatalErrorTeardown(ctx context.Context, state *model.WorkflowState, log *slog.Logger)
	SignalFatalErrorPause(ctx context.Context, state *model.WorkflowState, log *slog.Logger)
	PublishMsg(ctx context.Context, subject string, sharMsg proto.Message) error
	GetUserTaskIDs(ctx context.Context, owner string) (*model.UserTasks, error)
	OwnerID(ctx context.Context, name string) (string, error)
	OwnerName(ctx context.Context, id string) (string, error)
	GetProcessInstance(ctx context.Context, processInstanceID string) (*model.ProcessInstance, error)
	DeprecateTaskSpec(ctx context.Context, uid []string) error
	ListTaskSpecUIDs(ctx context.Context, deprecated bool) ([]string, error)
	GetProcessIdFor(ctx context.Context, startEventMessageName string) (string, error)
	Heartbeat(ctx context.Context, req *model.HeartbeatRequest) error
	Log(ctx context.Context, req *model.LogRequest) error
	DeleteNamespace(ctx context.Context, ns string) error
	ListExecutableProcesses(ctx context.Context, wch chan<- *model.ListExecutableProcessesItem, errs chan<- error)
	GetCompensationInputVariables(ctx context.Context, processInstanceId string, trackingId string) ([]byte, error)
	GetCompensationOutputVariables(ctx context.Context, processInstanceId string, trackingId string) ([]byte, error)
	HandleWorkflowError(ctx context.Context, errorCode string, inVars []byte, state *model.WorkflowState) error
	GetFatalErrors(ctx context.Context, keyPrefix string, fatalErrs chan<- *model.FatalError, errs chan<- error)
	RetryActivity(ctx context.Context, state *model.WorkflowState) error
	PersistFatalError(ctx context.Context, fatalError *model.FatalError) (bool, error)
	DeleteFatalError(ctx context.Context, state *model.WorkflowState) error
	GetActiveEntries(ctx context.Context, processInstanceID string, result chan<- *model.ProcessHistoryEntry, errs chan<- error)
	DisableWorkflow(ctx context.Context, workflowName string) error
	EnableWorkflow(ctx context.Context, workflowName string) error
	ListUserTasks(ctx context.Context, owner string, group string, res chan<- *model.ListUserTasksResponse, errs chan<- error)
	SaveUserTask(ctx context.Context, id string, v []byte, overwrite bool) error
	OpenUserTask(ctx context.Context, id string, owner string) ([]byte, error)
}

Ops is the interface for the Operations struct

type PublishOpt 

type PublishOpt interface {
	Apply(n *publishOptions)
}

PublishOpt represents an option that can be used when publishing a workflow state

type ServiceTaskConsumerFn 

type ServiceTaskConsumerFn func(ctx context.Context, id string) error

ServiceTaskConsumerFn defines the type of a function that ensures existence of a service task consumer

type WorkflowProcessMappingFn 

type WorkflowProcessMappingFn func(ctx context.Context, wf *model.Workflow, i *model.Process) (uint64, error)

WorkflowProcessMappingFn defines the type of a function that creates a workflow to process mapping

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.