workflow

package
v1.1.2155 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2026 License: MIT Imports: 53 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func NoOpServiceTaskConsumerFn 

func NoOpServiceTaskConsumerFn(_ context.Context, _ *model.TaskSpec) 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

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 NewEngine added in v1.1.1687 

func NewEngine(natsService *natz.NatsService, operations *Operations, historyOperations store.WorkflowHistoryOperations, wfOperations *WorkflowOperations, options *option.ServerOptions) (*Engine, error)

NewEngine 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 Features added in v1.1.1913 

type Features struct {
	// ExplicitProcessReturns indicates whether the process should return only explicitly declared variables.
	ExplicitProcessReturns bool
}

Features to be enabled or disabled.

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) EXPECT added in v1.1.1404 

func (_m *MockOps) EXPECT() *MockOps_Expecter

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) <-chan data.Result[*model.FatalError]

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

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) GetProcessIdFor added in v1.1.1404 

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

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

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) GetServiceTaskConsumer added in v1.1.1977 

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

GetServiceTaskConsumer provides a mock function with given fields: ctx, zone, spec

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) HandleWorkflowError added in v1.1.1404 

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

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

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, partition string, processId string, vars []byte, headers []byte) (string, string, error)

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

func (*MockOps) LaunchWithParent added in v1.1.1404 

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

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

func (*MockOps) ListExecutableProcesses added in v1.1.1404 

func (_m *MockOps) ListExecutableProcesses(ctx context.Context, partition string) <-chan data.Result[*model.ListExecutableProcessesItem]

ListExecutableProcesses provides a mock function with given fields: ctx, partition

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, partition string) <-chan data.Result[*model.ListExecutionItem]

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

func (*MockOps) ListNamespaces added in v1.1.2055 

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

ListNamespaces provides a mock function with given fields: ctx

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) <-chan data.Result[*model.ListUserTasksResponse]

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

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) PauseServiceTask added in v1.1.1796 

func (_m *MockOps) PauseServiceTask(ctx context.Context, uid string) error

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

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, wfProcessMappingFn WorkflowProcessMappingFn) error

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

func (*MockOps) PruneWorkflow added in v1.1.2024 

func (_m *MockOps) PruneWorkflow(ctx context.Context, workflowId string, partition string) ([]string, error)

PruneWorkflow provides a mock function with given fields: ctx, workflowId, partition

func (*MockOps) PublishMsg added in v1.1.1404 

func (_m *MockOps) PublishMsg(ctx context.Context, subject string, sharMsg proto.Message) 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 ...natz.MsgHeader) 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) ResumeServiceTask added in v1.1.1796 

func (_m *MockOps) ResumeServiceTask(ctx context.Context, uid string) error

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

func (*MockOps) RetryActivity added in v1.1.1404 

func (_m *MockOps) RetryActivity(ctx context.Context, processInstanceId string, elementId string, vars []byte, priorElementId string) error

RetryActivity provides a mock function with given fields: ctx, processInstanceId, elementId, vars, priorElementId

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

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_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) 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{}) *MockOps_GetFatalErrors_Call

GetFatalErrors is a helper method to define mock.On call

  • ctx context.Context
  • keyPrefix string

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) GetProcessIdFor added in v1.1.1404 

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

GetProcessIdFor is a helper method to define mock.On call

  • ctx context.Context
  • partitionedStartEventMessageName 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) GetServiceTaskConsumer added in v1.1.1977 

func (_e *MockOps_Expecter) GetServiceTaskConsumer(ctx interface{}, zone interface{}, spec interface{}) *MockOps_GetServiceTaskConsumer_Call

GetServiceTaskConsumer is a helper method to define mock.On call

  • ctx context.Context
  • zone string
  • spec *model.TaskSpec

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) HandleWorkflowError added in v1.1.1404 

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

HandleWorkflowError is a helper method to define mock.On call

  • ctx context.Context
  • errorCode string
  • inVars []byte
  • state *model.WorkflowState
  • errorIfUnhandled bool
  • source model.WorkflowErrorSource

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{}, partition interface{}, processId interface{}, vars interface{}, headers interface{}) *MockOps_Launch_Call

Launch is a helper method to define mock.On call

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

func (*MockOps_Expecter) LaunchWithParent added in v1.1.1404 

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

LaunchWithParent is a helper method to define mock.On call

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

func (*MockOps_Expecter) ListExecutableProcesses added in v1.1.1404 

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

ListExecutableProcesses is a helper method to define mock.On call

  • ctx context.Context
  • partition string

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{}, partition interface{}) *MockOps_ListExecutions_Call

ListExecutions is a helper method to define mock.On call

  • ctx context.Context
  • workflowName string
  • partition string

func (*MockOps_Expecter) ListNamespaces added in v1.1.2055 

func (_e *MockOps_Expecter) ListNamespaces(ctx interface{}) *MockOps_ListNamespaces_Call

ListNamespaces is a helper method to define mock.On call

  • ctx context.Context

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{}) *MockOps_ListUserTasks_Call

ListUserTasks is a helper method to define mock.On call

  • ctx context.Context
  • owner string
  • group string

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) PauseServiceTask added in v1.1.1796 

func (_e *MockOps_Expecter) PauseServiceTask(ctx interface{}, uid interface{}) *MockOps_PauseServiceTask_Call

PauseServiceTask is a helper method to define mock.On call

  • ctx context.Context
  • uid 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{}, wfProcessMappingFn interface{}) *MockOps_ProcessTasks_Call

ProcessTasks is a helper method to define mock.On call

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

func (*MockOps_Expecter) PruneWorkflow added in v1.1.2024 

func (_e *MockOps_Expecter) PruneWorkflow(ctx interface{}, workflowId interface{}, partition interface{}) *MockOps_PruneWorkflow_Call

PruneWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowId string
  • partition string

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 proto.Message

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 ...natz.MsgHeader

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) ResumeServiceTask added in v1.1.1796 

func (_e *MockOps_Expecter) ResumeServiceTask(ctx interface{}, uid interface{}) *MockOps_ResumeServiceTask_Call

ResumeServiceTask is a helper method to define mock.On call

  • ctx context.Context
  • uid string

func (*MockOps_Expecter) RetryActivity added in v1.1.1404 

func (_e *MockOps_Expecter) RetryActivity(ctx interface{}, processInstanceId interface{}, elementId interface{}, vars interface{}, priorElementId interface{}) *MockOps_RetryActivity_Call

RetryActivity is a helper method to define mock.On call

  • ctx context.Context
  • processInstanceId string
  • elementId string
  • vars []byte
  • priorElementId string

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

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(_a0 <-chan data.Result[*model.FatalError]) *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)) *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 data.Result[*model.FatalError]) *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_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, partitionedStartEventMessageName 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_GetServiceTaskConsumer_Call added in v1.1.1977 

type MockOps_GetServiceTaskConsumer_Call struct {
	*mock.Call
}

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

func (*MockOps_GetServiceTaskConsumer_Call) Return added in v1.1.1977 

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

func (*MockOps_GetServiceTaskConsumer_Call) Run added in v1.1.1977 

func (_c *MockOps_GetServiceTaskConsumer_Call) Run(run func(ctx context.Context, zone string, spec *model.TaskSpec)) *MockOps_GetServiceTaskConsumer_Call

func (*MockOps_GetServiceTaskConsumer_Call) RunAndReturn added in v1.1.1977 

func (_c *MockOps_GetServiceTaskConsumer_Call) RunAndReturn(run func(context.Context, string, *model.TaskSpec) (string, string, error)) *MockOps_GetServiceTaskConsumer_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_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, errorIfUnhandled bool, source model.WorkflowErrorSource)) *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, bool, model.WorkflowErrorSource) 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, partition string, processId string, ID common.TrackingID, vrs []byte, headers []byte, parentpiID string, parentElID string, subProcessWorkflowID 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, string, common.TrackingID, []byte, []byte, string, 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, partition string, 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, 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(_a0 <-chan data.Result[*model.ListExecutableProcessesItem]) *MockOps_ListExecutableProcesses_Call

func (*MockOps_ListExecutableProcesses_Call) Run added in v1.1.1404 

func (_c *MockOps_ListExecutableProcesses_Call) Run(run func(ctx context.Context, partition string)) *MockOps_ListExecutableProcesses_Call

func (*MockOps_ListExecutableProcesses_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_ListExecutableProcesses_Call) RunAndReturn(run func(context.Context, string) <-chan data.Result[*model.ListExecutableProcessesItem]) *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(_a0 <-chan data.Result[*model.ListExecutionItem]) *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, partition string)) *MockOps_ListExecutions_Call

func (*MockOps_ListExecutions_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_ListExecutions_Call) RunAndReturn(run func(context.Context, string, string) <-chan data.Result[*model.ListExecutionItem]) *MockOps_ListExecutions_Call

type MockOps_ListNamespaces_Call added in v1.1.2055 

type MockOps_ListNamespaces_Call struct {
	*mock.Call
}

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

func (*MockOps_ListNamespaces_Call) Return added in v1.1.2055 

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

func (*MockOps_ListNamespaces_Call) Run added in v1.1.2055 

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

func (*MockOps_ListNamespaces_Call) RunAndReturn added in v1.1.2055 

func (_c *MockOps_ListNamespaces_Call) RunAndReturn(run func(context.Context) ([]string, error)) *MockOps_ListNamespaces_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(_a0 <-chan data.Result[*model.ListUserTasksResponse]) *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)) *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 data.Result[*model.ListUserTasksResponse]) *MockOps_ListUserTasks_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_PauseServiceTask_Call added in v1.1.1796 

type MockOps_PauseServiceTask_Call struct {
	*mock.Call
}

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

func (*MockOps_PauseServiceTask_Call) Return added in v1.1.1796 

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

func (*MockOps_PauseServiceTask_Call) Run added in v1.1.1796 

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

func (*MockOps_PauseServiceTask_Call) RunAndReturn added in v1.1.1796 

func (_c *MockOps_PauseServiceTask_Call) RunAndReturn(run func(context.Context, string) error) *MockOps_PauseServiceTask_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, 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, WorkflowProcessMappingFn) error) *MockOps_ProcessTasks_Call

type MockOps_PruneWorkflow_Call added in v1.1.2024 

type MockOps_PruneWorkflow_Call struct {
	*mock.Call
}

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

func (*MockOps_PruneWorkflow_Call) Return added in v1.1.2024 

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

func (*MockOps_PruneWorkflow_Call) Run added in v1.1.2024 

func (_c *MockOps_PruneWorkflow_Call) Run(run func(ctx context.Context, workflowId string, partition string)) *MockOps_PruneWorkflow_Call

func (*MockOps_PruneWorkflow_Call) RunAndReturn added in v1.1.2024 

func (_c *MockOps_PruneWorkflow_Call) RunAndReturn(run func(context.Context, string, string) ([]string, error)) *MockOps_PruneWorkflow_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 proto.Message)) *MockOps_PublishMsg_Call

func (*MockOps_PublishMsg_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_PublishMsg_Call) RunAndReturn(run func(context.Context, string, proto.Message) 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 ...natz.MsgHeader)) *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, ...natz.MsgHeader) 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_ResumeServiceTask_Call added in v1.1.1796 

type MockOps_ResumeServiceTask_Call struct {
	*mock.Call
}

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

func (*MockOps_ResumeServiceTask_Call) Return added in v1.1.1796 

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

func (*MockOps_ResumeServiceTask_Call) Run added in v1.1.1796 

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

func (*MockOps_ResumeServiceTask_Call) RunAndReturn added in v1.1.1796 

func (_c *MockOps_ResumeServiceTask_Call) RunAndReturn(run func(context.Context, string) error) *MockOps_ResumeServiceTask_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, processInstanceId string, elementId string, vars []byte, priorElementId string)) *MockOps_RetryActivity_Call

func (*MockOps_RetryActivity_Call) RunAndReturn added in v1.1.1404 

func (_c *MockOps_RetryActivity_Call) RunAndReturn(run func(context.Context, string, string, []byte, string) 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 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, taskSpec *model.TaskSpec) error

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

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, taskSpec *model.TaskSpec)) *MockServiceTaskConsumerFn_Execute_Call

func (*MockServiceTaskConsumerFn_Execute_Call) RunAndReturn added in v1.1.1404 

func (_c *MockServiceTaskConsumerFn_Execute_Call) RunAndReturn(run func(context.Context, *model.TaskSpec) 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{}, taskSpec interface{}) *MockServiceTaskConsumerFn_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context
  • taskSpec *model.TaskSpec

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 {
	Feature Features
	// 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, exprEngine *expression.ExprEngine, historyOperations store.WorkflowHistoryOperations, workflowOperations *WorkflowOperations, taskOperations *TaskOperations, tracerProvider trace.TracerProvider) (*Operations, error)

NewOperations constructs a new Operations instance

func (*Operations) AbortProcess added in v1.1.1913 

func (c *Operations) AbortProcess(ctx context.Context, state *model.WorkflowState, cascadeUntilProcessID string) error

AbortProcess aborts the process instance and all parent process instances.

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) 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) GetExecutionZone added in v1.1.1977 

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

GetExecutionZone returns the execution zone.

func (*Operations) GetFatalErrors added in v1.1.1377 

func (s *Operations) GetFatalErrors(ctx context.Context, keyPrefix string) <-chan data.Result[*model.FatalError]

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) GetProcessIdFor added in v1.1.1131 

func (s *Operations) GetProcessIdFor(ctx context.Context, partitionedStartEventMessageName 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) GetServiceTaskConsumer added in v1.1.1977 

func (c *Operations) GetServiceTaskConsumer(ctx context.Context, zone string, spec *model.TaskSpec) (string, string, error)

GetServiceTaskConsumer gets the durable name and subject for a task.

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) HandleWorkflowError added in v1.1.1131 

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

HandleWorkflowError handles a workflow error by looking up the error definitions in the workflow, determining the appropriate action, 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, partition string, 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, partition string, processId string, ID common.TrackingID, vrs []byte, headers []byte, parentpiID string, parentElID string, subProcessWorkflowID 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, partition string) <-chan data.Result[*model.ListExecutableProcessesItem]

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, partition string) <-chan data.Result[*model.ListExecutionItem]

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

func (*Operations) ListNamespaces added in v1.1.2055 

func (c *Operations) ListNamespaces(ctx context.Context) ([]string, error)

ListNamespaces returns a list of SHAR namespaces.

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) <-chan data.Result[*model.ListUserTasksResponse]

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

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) PauseServiceTask added in v1.1.1796 

func (s *Operations) PauseServiceTask(ctx context.Context, uid string) error

PauseServiceTask pause the svc task identified by uid

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, 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) PruneWorkflow added in v1.1.2024 

func (c *Operations) PruneWorkflow(ctx context.Context, workflowName string, partition string) ([]string, error)

PruneWorkflow removes unused (not running) workflow versions. If the workflow is launch disabled, then remove it altogether.

func (*Operations) PublishMsg added in v1.1.1131 

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

PublishMsg publishes a proto message.

func (*Operations) PublishWorkflowState added in v1.1.1131 

func (s *Operations) PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, headers ...natz.MsgHeader) 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) ResumeServiceTask added in v1.1.1796 

func (s *Operations) ResumeServiceTask(ctx context.Context, uid string) error

ResumeServiceTask pause the svc task identified by uid

func (*Operations) RetryActivity added in v1.1.1377 

func (s *Operations) RetryActivity(ctx context.Context, processInstanceId string, failedElementId string, vars []byte, priorElementId string) error

RetryActivity publishes the state from a prior FatalError to attempt a retry. Vars are optional and if present, are merged for 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

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)
	Launch(ctx context.Context, partition string, processId string, vars []byte, headers []byte) (string, string, error)
	LaunchWithParent(ctx context.Context, partition string, processId string, ID common.TrackingID, vrs []byte, headers []byte, parentpiID string, parentElID string, subProcessWorkflowID 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
	ProcessTasks(ctx context.Context, wf *model.Workflow, wfProcessMappingFn WorkflowProcessMappingFn) 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, partition string) <-chan data.Result[*model.ListExecutionItem]
	ListExecutionProcesses(ctx context.Context, id string) ([]string, error)
	PublishWorkflowState(ctx context.Context, stateName string, state *model.WorkflowState, opts ...natz.MsgHeader) 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, partitionedStartEventMessageName 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, partition string) <-chan data.Result[*model.ListExecutableProcessesItem]
	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, errorIfUnhandled bool, source model.WorkflowErrorSource) error
	GetFatalErrors(ctx context.Context, keyPrefix string) <-chan data.Result[*model.FatalError]
	RetryActivity(ctx context.Context, processInstanceId string, elementId string, vars []byte, priorElementId string) error
	PersistFatalError(ctx context.Context, fatalError *model.FatalError) (bool, error)
	DeleteFatalError(ctx context.Context, state *model.WorkflowState) error
	ListUserTasks(ctx context.Context, owner string, group string) <-chan data.Result[*model.ListUserTasksResponse]
	SaveUserTask(ctx context.Context, id string, v []byte, overwrite bool) error
	OpenUserTask(ctx context.Context, id string, owner string) ([]byte, error)
	PauseServiceTask(ctx context.Context, uid string) error
	ResumeServiceTask(ctx context.Context, uid string) error
	GetServiceTaskConsumer(ctx context.Context, zone string, spec *model.TaskSpec) (string, string, error)
	PruneWorkflow(ctx context.Context, workflowId string, partition string) ([]string, error)
	ListNamespaces(ctx context.Context) ([]string, error)
}

Ops is the interface for the Operations struct

type ServiceTaskConsumerFn 

type ServiceTaskConsumerFn func(ctx context.Context, taskSpec *model.TaskSpec) error

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

type TaskOperations added in v1.1.1687 

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

TaskOperations is a struct off of which to hang varios svc task related opereations off of

func NewTaskOperations added in v1.1.1687 

func NewTaskOperations(natsService *natz.NatsService) *TaskOperations

NewTaskOperations construct new Task Operations

func (*TaskOperations) EnsureServiceConsumer added in v1.1.1977 

func (to *TaskOperations) EnsureServiceConsumer(ctx context.Context, spec *model.TaskSpec, zone string) (string, string, error)

EnsureServiceConsumer creates or updates a service task consumer.

func (*TaskOperations) GetLatestTaskSpecUID added in v1.1.1727 

func (to *TaskOperations) GetLatestTaskSpecUID(ctx context.Context, name string) (string, error)

GetLatestTaskSpecUID fetches

func (*TaskOperations) GetTaskSpecByUID added in v1.1.1687 

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

GetTaskSpecByUID fetches a task spec from the database.

func (*TaskOperations) GetTaskSpecVersions added in v1.1.1687 

func (to *TaskOperations) GetTaskSpecVersions(ctx context.Context, name string) (*model.TaskSpecVersions, error)

GetTaskSpecVersions fetches the versions of a given task spec name

func (*TaskOperations) PauseServiceTask added in v1.1.1796 

func (s *TaskOperations) PauseServiceTask(ctx context.Context, uid string) error

PauseServiceTask pause the svc task identified by uid

func (*TaskOperations) ResumeServiceTask added in v1.1.1796 

func (s *TaskOperations) ResumeServiceTask(ctx context.Context, uid string) error

ResumeServiceTask pause the svc task identified by uid

type WorkflowOperations added in v1.1.1687 

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

WorkflowOperations is a place to hang operations related to the Workflow model off of

func NewWorkflowOperations added in v1.1.1687 

func NewWorkflowOperations(natsService *natz.NatsService, taskOperations *TaskOperations, exprEngine expression.Engine) (*WorkflowOperations, error)

NewWorkflowOperations constructs a new WorkflowOperations struct

func (*WorkflowOperations) DisableWorkflow added in v1.1.1687 

func (wfo *WorkflowOperations) DisableWorkflow(ctx context.Context, workflowName string, partition string) error

DisableWorkflow stops a workflow from being launched

func (*WorkflowOperations) EnableWorkflow added in v1.1.1687 

func (wfo *WorkflowOperations) EnableWorkflow(ctx context.Context, workflowName string, partition string) error

EnableWorkflow allows a workflow to be launched

func (*WorkflowOperations) GetWorkflow added in v1.1.1687 

func (wfo *WorkflowOperations) GetWorkflow(ctx context.Context, workflowID string) (*model.Workflow, error)

GetWorkflow - retrieves a workflow model given its ID

func (*WorkflowOperations) ListWorkflows added in v1.1.1687 

func (wfo *WorkflowOperations) ListWorkflows(ctx context.Context, partition string) <-chan data.Result[*model.ListWorkflowResponse]

ListWorkflows returns a list of all the workflows in SHAR.

func (*WorkflowOperations) LoadWorkflow added in v1.1.1687 

func (wfo *WorkflowOperations) LoadWorkflow(ctx context.Context, partition string, workflow *model.Workflow) (string, error)

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

func (*WorkflowOperations) ProcessTasks added in v1.1.1687 

func (wfo *WorkflowOperations) ProcessTasks(ctx context.Context, wf *model.Workflow, 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 (*WorkflowOperations) StreamWorkflowVersions added in v1.1.1687 

func (wfo *WorkflowOperations) StreamWorkflowVersions(ctx context.Context, partition string, workflowName string) <-chan data.Result[*model.WorkflowVersion]

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

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.