client

package
v0.4.40 Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockClient 

type MockClient struct {
	mock.Mock
}

MockClient is an autogenerated mock type for the Client type

func NewMockClient 

func NewMockClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockClient

NewMockClient creates a new instance of MockClient. 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 (*MockClient) CancelWorkflow 

func (_m *MockClient) CancelWorkflow(ctx context.Context, workflowID string, runID string) error

CancelWorkflow provides a mock function with given fields: ctx, workflowID, runID

func (*MockClient) CheckHealth 

func (_m *MockClient) CheckHealth(ctx context.Context, request *internal.CheckHealthRequest) (*internal.CheckHealthResponse, error)

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

func (*MockClient) Close 

func (_m *MockClient) Close()

Close provides a mock function with given fields:

func (*MockClient) CompleteActivity 

func (_m *MockClient) CompleteActivity(ctx context.Context, taskToken []byte, result interface{}, err error) error

CompleteActivity provides a mock function with given fields: ctx, taskToken, result, err

func (*MockClient) CompleteActivityByID 

func (_m *MockClient) CompleteActivityByID(ctx context.Context, namespace string, workflowID string, runID string, activityID string, result interface{}, err error) error

CompleteActivityByID provides a mock function with given fields: ctx, namespace, workflowID, runID, activityID, result, err

func (*MockClient) CountWorkflow 

func (_m *MockClient) CountWorkflow(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)

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

func (*MockClient) DescribeTaskQueue 

func (_m *MockClient) DescribeTaskQueue(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)

DescribeTaskQueue provides a mock function with given fields: ctx, taskqueue, taskqueueType

func (*MockClient) DescribeWorkflowExecution 

func (_m *MockClient) DescribeWorkflowExecution(ctx context.Context, workflowID string, runID string) (*workflowservice.DescribeWorkflowExecutionResponse, error)

DescribeWorkflowExecution provides a mock function with given fields: ctx, workflowID, runID

func (*MockClient) EXPECT 

func (_m *MockClient) EXPECT() *MockClient_Expecter

func (*MockClient) ExecuteWorkflow 

func (_m *MockClient) ExecuteWorkflow(ctx context.Context, options internal.StartWorkflowOptions, workflow interface{}, args ...interface{}) (internal.WorkflowRun, error)

ExecuteWorkflow provides a mock function with given fields: ctx, options, workflow, args

func (*MockClient) GetSearchAttributes 

func (_m *MockClient) GetSearchAttributes(ctx context.Context) (*workflowservice.GetSearchAttributesResponse, error)

GetSearchAttributes provides a mock function with given fields: ctx

func (*MockClient) GetWorkerBuildIdCompatibility 

func (_m *MockClient) GetWorkerBuildIdCompatibility(ctx context.Context, options *internal.GetWorkerBuildIdCompatibilityOptions) (*internal.WorkerBuildIDVersionSets, error)

GetWorkerBuildIdCompatibility provides a mock function with given fields: ctx, options

func (*MockClient) GetWorkerTaskReachability 

func (_m *MockClient) GetWorkerTaskReachability(ctx context.Context, options *internal.GetWorkerTaskReachabilityOptions) (*internal.WorkerTaskReachability, error)

GetWorkerTaskReachability provides a mock function with given fields: ctx, options

func (*MockClient) GetWorkflow 

func (_m *MockClient) GetWorkflow(ctx context.Context, workflowID string, runID string) internal.WorkflowRun

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

func (*MockClient) GetWorkflowHistory 

func (_m *MockClient) GetWorkflowHistory(ctx context.Context, workflowID string, runID string, isLongPoll bool, filterType enums.HistoryEventFilterType) internal.HistoryEventIterator

GetWorkflowHistory provides a mock function with given fields: ctx, workflowID, runID, isLongPoll, filterType

func (*MockClient) GetWorkflowUpdateHandle 

func (_m *MockClient) GetWorkflowUpdateHandle(ref internal.GetWorkflowUpdateHandleOptions) internal.WorkflowUpdateHandle

GetWorkflowUpdateHandle provides a mock function with given fields: ref

func (*MockClient) ListArchivedWorkflow 

func (_m *MockClient) ListArchivedWorkflow(ctx context.Context, request *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)

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

func (*MockClient) ListClosedWorkflow 

func (_m *MockClient) ListClosedWorkflow(ctx context.Context, request *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)

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

func (*MockClient) ListOpenWorkflow 

func (_m *MockClient) ListOpenWorkflow(ctx context.Context, request *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)

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

func (*MockClient) ListWorkflow 

func (_m *MockClient) ListWorkflow(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)

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

func (*MockClient) OperatorService 

func (_m *MockClient) OperatorService() operatorservice.OperatorServiceClient

OperatorService provides a mock function with given fields:

func (*MockClient) QueryWorkflow 

func (_m *MockClient) QueryWorkflow(ctx context.Context, workflowID string, runID string, queryType string, args ...interface{}) (converter.EncodedValue, error)

QueryWorkflow provides a mock function with given fields: ctx, workflowID, runID, queryType, args

func (*MockClient) QueryWorkflowWithOptions 

func (_m *MockClient) QueryWorkflowWithOptions(ctx context.Context, request *internal.QueryWorkflowWithOptionsRequest) (*internal.QueryWorkflowWithOptionsResponse, error)

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

func (*MockClient) RecordActivityHeartbeat 

func (_m *MockClient) RecordActivityHeartbeat(ctx context.Context, taskToken []byte, details ...interface{}) error

RecordActivityHeartbeat provides a mock function with given fields: ctx, taskToken, details

func (*MockClient) RecordActivityHeartbeatByID 

func (_m *MockClient) RecordActivityHeartbeatByID(ctx context.Context, namespace string, workflowID string, runID string, activityID string, details ...interface{}) error

RecordActivityHeartbeatByID provides a mock function with given fields: ctx, namespace, workflowID, runID, activityID, details

func (*MockClient) ResetWorkflowExecution 

func (_m *MockClient) ResetWorkflowExecution(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)

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

func (*MockClient) ScanWorkflow 

func (_m *MockClient) ScanWorkflow(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)

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

func (*MockClient) ScheduleClient 

func (_m *MockClient) ScheduleClient() internal.ScheduleClient

ScheduleClient provides a mock function with given fields:

func (*MockClient) SignalWithStartWorkflow 

func (_m *MockClient) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, signalArg interface{}, options internal.StartWorkflowOptions, workflow interface{}, workflowArgs ...interface{}) (internal.WorkflowRun, error)

SignalWithStartWorkflow provides a mock function with given fields: ctx, workflowID, signalName, signalArg, options, workflow, workflowArgs

func (*MockClient) SignalWorkflow 

func (_m *MockClient) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, arg interface{}) error

SignalWorkflow provides a mock function with given fields: ctx, workflowID, runID, signalName, arg

func (*MockClient) TerminateWorkflow 

func (_m *MockClient) TerminateWorkflow(ctx context.Context, workflowID string, runID string, reason string, details ...interface{}) error

TerminateWorkflow provides a mock function with given fields: ctx, workflowID, runID, reason, details

func (*MockClient) UpdateWorkerBuildIdCompatibility 

func (_m *MockClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, options *internal.UpdateWorkerBuildIdCompatibilityOptions) error

UpdateWorkerBuildIdCompatibility provides a mock function with given fields: ctx, options

func (*MockClient) UpdateWorkflow 

func (_m *MockClient) UpdateWorkflow(ctx context.Context, workflowID string, workflowRunID string, updateName string, args ...interface{}) (internal.WorkflowUpdateHandle, error)

UpdateWorkflow provides a mock function with given fields: ctx, workflowID, workflowRunID, updateName, args

func (*MockClient) UpdateWorkflowWithOptions 

func (_m *MockClient) UpdateWorkflowWithOptions(ctx context.Context, request *internal.UpdateWorkflowWithOptionsRequest) (internal.WorkflowUpdateHandle, error)

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

func (*MockClient) WorkflowService 

func (_m *MockClient) WorkflowService() workflowservice.WorkflowServiceClient

WorkflowService provides a mock function with given fields:

type MockClient_CancelWorkflow_Call 

type MockClient_CancelWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_CancelWorkflow_Call) Return 

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

func (*MockClient_CancelWorkflow_Call) Run 

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

func (*MockClient_CancelWorkflow_Call) RunAndReturn 

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

type MockClient_CheckHealth_Call 

type MockClient_CheckHealth_Call struct {
	*mock.Call
}

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

func (*MockClient_CheckHealth_Call) Return 

func (_c *MockClient_CheckHealth_Call) Return(_a0 *internal.CheckHealthResponse, _a1 error) *MockClient_CheckHealth_Call

func (*MockClient_CheckHealth_Call) Run 

func (_c *MockClient_CheckHealth_Call) Run(run func(ctx context.Context, request *internal.CheckHealthRequest)) *MockClient_CheckHealth_Call

func (*MockClient_CheckHealth_Call) RunAndReturn 

func (_c *MockClient_CheckHealth_Call) RunAndReturn(run func(context.Context, *internal.CheckHealthRequest) (*internal.CheckHealthResponse, error)) *MockClient_CheckHealth_Call

type MockClient_Close_Call 

type MockClient_Close_Call struct {
	*mock.Call
}

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

func (*MockClient_Close_Call) Return 

func (_c *MockClient_Close_Call) Return() *MockClient_Close_Call

func (*MockClient_Close_Call) Run 

func (_c *MockClient_Close_Call) Run(run func()) *MockClient_Close_Call

func (*MockClient_Close_Call) RunAndReturn 

func (_c *MockClient_Close_Call) RunAndReturn(run func()) *MockClient_Close_Call

type MockClient_CompleteActivityByID_Call 

type MockClient_CompleteActivityByID_Call struct {
	*mock.Call
}

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

func (*MockClient_CompleteActivityByID_Call) Return 

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

func (*MockClient_CompleteActivityByID_Call) Run 

func (_c *MockClient_CompleteActivityByID_Call) Run(run func(ctx context.Context, namespace string, workflowID string, runID string, activityID string, result interface{}, err error)) *MockClient_CompleteActivityByID_Call

func (*MockClient_CompleteActivityByID_Call) RunAndReturn 

func (_c *MockClient_CompleteActivityByID_Call) RunAndReturn(run func(context.Context, string, string, string, string, interface{}, error) error) *MockClient_CompleteActivityByID_Call

type MockClient_CompleteActivity_Call 

type MockClient_CompleteActivity_Call struct {
	*mock.Call
}

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

func (*MockClient_CompleteActivity_Call) Return 

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

func (*MockClient_CompleteActivity_Call) Run 

func (_c *MockClient_CompleteActivity_Call) Run(run func(ctx context.Context, taskToken []byte, result interface{}, err error)) *MockClient_CompleteActivity_Call

func (*MockClient_CompleteActivity_Call) RunAndReturn 

func (_c *MockClient_CompleteActivity_Call) RunAndReturn(run func(context.Context, []byte, interface{}, error) error) *MockClient_CompleteActivity_Call

type MockClient_CountWorkflow_Call 

type MockClient_CountWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_CountWorkflow_Call) Return 

func (_c *MockClient_CountWorkflow_Call) Return(_a0 *workflowservice.CountWorkflowExecutionsResponse, _a1 error) *MockClient_CountWorkflow_Call

func (*MockClient_CountWorkflow_Call) Run 

func (_c *MockClient_CountWorkflow_Call) Run(run func(ctx context.Context, request *workflowservice.CountWorkflowExecutionsRequest)) *MockClient_CountWorkflow_Call

func (*MockClient_CountWorkflow_Call) RunAndReturn 

func (_c *MockClient_CountWorkflow_Call) RunAndReturn(run func(context.Context, *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)) *MockClient_CountWorkflow_Call

type MockClient_DescribeTaskQueue_Call 

type MockClient_DescribeTaskQueue_Call struct {
	*mock.Call
}

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

func (*MockClient_DescribeTaskQueue_Call) Return 

func (_c *MockClient_DescribeTaskQueue_Call) Return(_a0 *workflowservice.DescribeTaskQueueResponse, _a1 error) *MockClient_DescribeTaskQueue_Call

func (*MockClient_DescribeTaskQueue_Call) Run 

func (_c *MockClient_DescribeTaskQueue_Call) Run(run func(ctx context.Context, taskqueue string, taskqueueType enums.TaskQueueType)) *MockClient_DescribeTaskQueue_Call

func (*MockClient_DescribeTaskQueue_Call) RunAndReturn 

func (_c *MockClient_DescribeTaskQueue_Call) RunAndReturn(run func(context.Context, string, enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)) *MockClient_DescribeTaskQueue_Call

type MockClient_DescribeWorkflowExecution_Call 

type MockClient_DescribeWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*MockClient_DescribeWorkflowExecution_Call) Return 

func (_c *MockClient_DescribeWorkflowExecution_Call) Return(_a0 *workflowservice.DescribeWorkflowExecutionResponse, _a1 error) *MockClient_DescribeWorkflowExecution_Call

func (*MockClient_DescribeWorkflowExecution_Call) Run 

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

func (*MockClient_DescribeWorkflowExecution_Call) RunAndReturn 

func (_c *MockClient_DescribeWorkflowExecution_Call) RunAndReturn(run func(context.Context, string, string) (*workflowservice.DescribeWorkflowExecutionResponse, error)) *MockClient_DescribeWorkflowExecution_Call

type MockClient_ExecuteWorkflow_Call 

type MockClient_ExecuteWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_ExecuteWorkflow_Call) Return 

func (_c *MockClient_ExecuteWorkflow_Call) Return(_a0 internal.WorkflowRun, _a1 error) *MockClient_ExecuteWorkflow_Call

func (*MockClient_ExecuteWorkflow_Call) Run 

func (_c *MockClient_ExecuteWorkflow_Call) Run(run func(ctx context.Context, options internal.StartWorkflowOptions, workflow interface{}, args ...interface{})) *MockClient_ExecuteWorkflow_Call

func (*MockClient_ExecuteWorkflow_Call) RunAndReturn 

func (_c *MockClient_ExecuteWorkflow_Call) RunAndReturn(run func(context.Context, internal.StartWorkflowOptions, interface{}, ...interface{}) (internal.WorkflowRun, error)) *MockClient_ExecuteWorkflow_Call

type MockClient_Expecter 

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

func (*MockClient_Expecter) CancelWorkflow 

func (_e *MockClient_Expecter) CancelWorkflow(ctx interface{}, workflowID interface{}, runID interface{}) *MockClient_CancelWorkflow_Call

CancelWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • runID string

func (*MockClient_Expecter) CheckHealth 

func (_e *MockClient_Expecter) CheckHealth(ctx interface{}, request interface{}) *MockClient_CheckHealth_Call

CheckHealth is a helper method to define mock.On call

  • ctx context.Context
  • request *internal.CheckHealthRequest

func (*MockClient_Expecter) Close 

func (_e *MockClient_Expecter) Close() *MockClient_Close_Call

Close is a helper method to define mock.On call

func (*MockClient_Expecter) CompleteActivity 

func (_e *MockClient_Expecter) CompleteActivity(ctx interface{}, taskToken interface{}, result interface{}, err interface{}) *MockClient_CompleteActivity_Call

CompleteActivity is a helper method to define mock.On call

  • ctx context.Context
  • taskToken []byte
  • result interface{}
  • err error

func (*MockClient_Expecter) CompleteActivityByID 

func (_e *MockClient_Expecter) CompleteActivityByID(ctx interface{}, namespace interface{}, workflowID interface{}, runID interface{}, activityID interface{}, result interface{}, err interface{}) *MockClient_CompleteActivityByID_Call

CompleteActivityByID is a helper method to define mock.On call

  • ctx context.Context
  • namespace string
  • workflowID string
  • runID string
  • activityID string
  • result interface{}
  • err error

func (*MockClient_Expecter) CountWorkflow 

func (_e *MockClient_Expecter) CountWorkflow(ctx interface{}, request interface{}) *MockClient_CountWorkflow_Call

CountWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • request *workflowservice.CountWorkflowExecutionsRequest

func (*MockClient_Expecter) DescribeTaskQueue 

func (_e *MockClient_Expecter) DescribeTaskQueue(ctx interface{}, taskqueue interface{}, taskqueueType interface{}) *MockClient_DescribeTaskQueue_Call

DescribeTaskQueue is a helper method to define mock.On call

  • ctx context.Context
  • taskqueue string
  • taskqueueType enums.TaskQueueType

func (*MockClient_Expecter) DescribeWorkflowExecution 

func (_e *MockClient_Expecter) DescribeWorkflowExecution(ctx interface{}, workflowID interface{}, runID interface{}) *MockClient_DescribeWorkflowExecution_Call

DescribeWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • runID string

func (*MockClient_Expecter) ExecuteWorkflow 

func (_e *MockClient_Expecter) ExecuteWorkflow(ctx interface{}, options interface{}, workflow interface{}, args ...interface{}) *MockClient_ExecuteWorkflow_Call

ExecuteWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • options internal.StartWorkflowOptions
  • workflow interface{}
  • args ...interface{}

func (*MockClient_Expecter) GetSearchAttributes 

func (_e *MockClient_Expecter) GetSearchAttributes(ctx interface{}) *MockClient_GetSearchAttributes_Call

GetSearchAttributes is a helper method to define mock.On call

  • ctx context.Context

func (*MockClient_Expecter) GetWorkerBuildIdCompatibility 

func (_e *MockClient_Expecter) GetWorkerBuildIdCompatibility(ctx interface{}, options interface{}) *MockClient_GetWorkerBuildIdCompatibility_Call

GetWorkerBuildIdCompatibility is a helper method to define mock.On call

  • ctx context.Context
  • options *internal.GetWorkerBuildIdCompatibilityOptions

func (*MockClient_Expecter) GetWorkerTaskReachability 

func (_e *MockClient_Expecter) GetWorkerTaskReachability(ctx interface{}, options interface{}) *MockClient_GetWorkerTaskReachability_Call

GetWorkerTaskReachability is a helper method to define mock.On call

  • ctx context.Context
  • options *internal.GetWorkerTaskReachabilityOptions

func (*MockClient_Expecter) GetWorkflow 

func (_e *MockClient_Expecter) GetWorkflow(ctx interface{}, workflowID interface{}, runID interface{}) *MockClient_GetWorkflow_Call

GetWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • runID string

func (*MockClient_Expecter) GetWorkflowHistory 

func (_e *MockClient_Expecter) GetWorkflowHistory(ctx interface{}, workflowID interface{}, runID interface{}, isLongPoll interface{}, filterType interface{}) *MockClient_GetWorkflowHistory_Call

GetWorkflowHistory is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • runID string
  • isLongPoll bool
  • filterType enums.HistoryEventFilterType

func (*MockClient_Expecter) GetWorkflowUpdateHandle 

func (_e *MockClient_Expecter) GetWorkflowUpdateHandle(ref interface{}) *MockClient_GetWorkflowUpdateHandle_Call

GetWorkflowUpdateHandle is a helper method to define mock.On call

  • ref internal.GetWorkflowUpdateHandleOptions

func (*MockClient_Expecter) ListArchivedWorkflow 

func (_e *MockClient_Expecter) ListArchivedWorkflow(ctx interface{}, request interface{}) *MockClient_ListArchivedWorkflow_Call

ListArchivedWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • request *workflowservice.ListArchivedWorkflowExecutionsRequest

func (*MockClient_Expecter) ListClosedWorkflow 

func (_e *MockClient_Expecter) ListClosedWorkflow(ctx interface{}, request interface{}) *MockClient_ListClosedWorkflow_Call

ListClosedWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • request *workflowservice.ListClosedWorkflowExecutionsRequest

func (*MockClient_Expecter) ListOpenWorkflow 

func (_e *MockClient_Expecter) ListOpenWorkflow(ctx interface{}, request interface{}) *MockClient_ListOpenWorkflow_Call

ListOpenWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • request *workflowservice.ListOpenWorkflowExecutionsRequest

func (*MockClient_Expecter) ListWorkflow 

func (_e *MockClient_Expecter) ListWorkflow(ctx interface{}, request interface{}) *MockClient_ListWorkflow_Call

ListWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • request *workflowservice.ListWorkflowExecutionsRequest

func (*MockClient_Expecter) OperatorService 

func (_e *MockClient_Expecter) OperatorService() *MockClient_OperatorService_Call

OperatorService is a helper method to define mock.On call

func (*MockClient_Expecter) QueryWorkflow 

func (_e *MockClient_Expecter) QueryWorkflow(ctx interface{}, workflowID interface{}, runID interface{}, queryType interface{}, args ...interface{}) *MockClient_QueryWorkflow_Call

QueryWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • runID string
  • queryType string
  • args ...interface{}

func (*MockClient_Expecter) QueryWorkflowWithOptions 

func (_e *MockClient_Expecter) QueryWorkflowWithOptions(ctx interface{}, request interface{}) *MockClient_QueryWorkflowWithOptions_Call

QueryWorkflowWithOptions is a helper method to define mock.On call

  • ctx context.Context
  • request *internal.QueryWorkflowWithOptionsRequest

func (*MockClient_Expecter) RecordActivityHeartbeat 

func (_e *MockClient_Expecter) RecordActivityHeartbeat(ctx interface{}, taskToken interface{}, details ...interface{}) *MockClient_RecordActivityHeartbeat_Call

RecordActivityHeartbeat is a helper method to define mock.On call

  • ctx context.Context
  • taskToken []byte
  • details ...interface{}

func (*MockClient_Expecter) RecordActivityHeartbeatByID 

func (_e *MockClient_Expecter) RecordActivityHeartbeatByID(ctx interface{}, namespace interface{}, workflowID interface{}, runID interface{}, activityID interface{}, details ...interface{}) *MockClient_RecordActivityHeartbeatByID_Call

RecordActivityHeartbeatByID is a helper method to define mock.On call

  • ctx context.Context
  • namespace string
  • workflowID string
  • runID string
  • activityID string
  • details ...interface{}

func (*MockClient_Expecter) ResetWorkflowExecution 

func (_e *MockClient_Expecter) ResetWorkflowExecution(ctx interface{}, request interface{}) *MockClient_ResetWorkflowExecution_Call

ResetWorkflowExecution is a helper method to define mock.On call

  • ctx context.Context
  • request *workflowservice.ResetWorkflowExecutionRequest

func (*MockClient_Expecter) ScanWorkflow 

func (_e *MockClient_Expecter) ScanWorkflow(ctx interface{}, request interface{}) *MockClient_ScanWorkflow_Call

ScanWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • request *workflowservice.ScanWorkflowExecutionsRequest

func (*MockClient_Expecter) ScheduleClient 

func (_e *MockClient_Expecter) ScheduleClient() *MockClient_ScheduleClient_Call

ScheduleClient is a helper method to define mock.On call

func (*MockClient_Expecter) SignalWithStartWorkflow 

func (_e *MockClient_Expecter) SignalWithStartWorkflow(ctx interface{}, workflowID interface{}, signalName interface{}, signalArg interface{}, options interface{}, workflow interface{}, workflowArgs ...interface{}) *MockClient_SignalWithStartWorkflow_Call

SignalWithStartWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • signalName string
  • signalArg interface{}
  • options internal.StartWorkflowOptions
  • workflow interface{}
  • workflowArgs ...interface{}

func (*MockClient_Expecter) SignalWorkflow 

func (_e *MockClient_Expecter) SignalWorkflow(ctx interface{}, workflowID interface{}, runID interface{}, signalName interface{}, arg interface{}) *MockClient_SignalWorkflow_Call

SignalWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • runID string
  • signalName string
  • arg interface{}

func (*MockClient_Expecter) TerminateWorkflow 

func (_e *MockClient_Expecter) TerminateWorkflow(ctx interface{}, workflowID interface{}, runID interface{}, reason interface{}, details ...interface{}) *MockClient_TerminateWorkflow_Call

TerminateWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • runID string
  • reason string
  • details ...interface{}

func (*MockClient_Expecter) UpdateWorkerBuildIdCompatibility 

func (_e *MockClient_Expecter) UpdateWorkerBuildIdCompatibility(ctx interface{}, options interface{}) *MockClient_UpdateWorkerBuildIdCompatibility_Call

UpdateWorkerBuildIdCompatibility is a helper method to define mock.On call

  • ctx context.Context
  • options *internal.UpdateWorkerBuildIdCompatibilityOptions

func (*MockClient_Expecter) UpdateWorkflow 

func (_e *MockClient_Expecter) UpdateWorkflow(ctx interface{}, workflowID interface{}, workflowRunID interface{}, updateName interface{}, args ...interface{}) *MockClient_UpdateWorkflow_Call

UpdateWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • workflowID string
  • workflowRunID string
  • updateName string
  • args ...interface{}

func (*MockClient_Expecter) UpdateWorkflowWithOptions 

func (_e *MockClient_Expecter) UpdateWorkflowWithOptions(ctx interface{}, request interface{}) *MockClient_UpdateWorkflowWithOptions_Call

UpdateWorkflowWithOptions is a helper method to define mock.On call

  • ctx context.Context
  • request *internal.UpdateWorkflowWithOptionsRequest

func (*MockClient_Expecter) WorkflowService 

func (_e *MockClient_Expecter) WorkflowService() *MockClient_WorkflowService_Call

WorkflowService is a helper method to define mock.On call

type MockClient_GetSearchAttributes_Call 

type MockClient_GetSearchAttributes_Call struct {
	*mock.Call
}

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

func (*MockClient_GetSearchAttributes_Call) Return 

func (_c *MockClient_GetSearchAttributes_Call) Return(_a0 *workflowservice.GetSearchAttributesResponse, _a1 error) *MockClient_GetSearchAttributes_Call

func (*MockClient_GetSearchAttributes_Call) Run 

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

func (*MockClient_GetSearchAttributes_Call) RunAndReturn 

func (_c *MockClient_GetSearchAttributes_Call) RunAndReturn(run func(context.Context) (*workflowservice.GetSearchAttributesResponse, error)) *MockClient_GetSearchAttributes_Call

type MockClient_GetWorkerBuildIdCompatibility_Call 

type MockClient_GetWorkerBuildIdCompatibility_Call struct {
	*mock.Call
}

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

func (*MockClient_GetWorkerBuildIdCompatibility_Call) Return 

func (_c *MockClient_GetWorkerBuildIdCompatibility_Call) Return(_a0 *internal.WorkerBuildIDVersionSets, _a1 error) *MockClient_GetWorkerBuildIdCompatibility_Call

func (*MockClient_GetWorkerBuildIdCompatibility_Call) Run 

func (_c *MockClient_GetWorkerBuildIdCompatibility_Call) Run(run func(ctx context.Context, options *internal.GetWorkerBuildIdCompatibilityOptions)) *MockClient_GetWorkerBuildIdCompatibility_Call

func (*MockClient_GetWorkerBuildIdCompatibility_Call) RunAndReturn 

func (_c *MockClient_GetWorkerBuildIdCompatibility_Call) RunAndReturn(run func(context.Context, *internal.GetWorkerBuildIdCompatibilityOptions) (*internal.WorkerBuildIDVersionSets, error)) *MockClient_GetWorkerBuildIdCompatibility_Call

type MockClient_GetWorkerTaskReachability_Call 

type MockClient_GetWorkerTaskReachability_Call struct {
	*mock.Call
}

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

func (*MockClient_GetWorkerTaskReachability_Call) Return 

func (_c *MockClient_GetWorkerTaskReachability_Call) Return(_a0 *internal.WorkerTaskReachability, _a1 error) *MockClient_GetWorkerTaskReachability_Call

func (*MockClient_GetWorkerTaskReachability_Call) Run 

func (_c *MockClient_GetWorkerTaskReachability_Call) Run(run func(ctx context.Context, options *internal.GetWorkerTaskReachabilityOptions)) *MockClient_GetWorkerTaskReachability_Call

func (*MockClient_GetWorkerTaskReachability_Call) RunAndReturn 

func (_c *MockClient_GetWorkerTaskReachability_Call) RunAndReturn(run func(context.Context, *internal.GetWorkerTaskReachabilityOptions) (*internal.WorkerTaskReachability, error)) *MockClient_GetWorkerTaskReachability_Call

type MockClient_GetWorkflowHistory_Call 

type MockClient_GetWorkflowHistory_Call struct {
	*mock.Call
}

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

func (*MockClient_GetWorkflowHistory_Call) Return 

func (_c *MockClient_GetWorkflowHistory_Call) Return(_a0 internal.HistoryEventIterator) *MockClient_GetWorkflowHistory_Call

func (*MockClient_GetWorkflowHistory_Call) Run 

func (_c *MockClient_GetWorkflowHistory_Call) Run(run func(ctx context.Context, workflowID string, runID string, isLongPoll bool, filterType enums.HistoryEventFilterType)) *MockClient_GetWorkflowHistory_Call

func (*MockClient_GetWorkflowHistory_Call) RunAndReturn 

func (_c *MockClient_GetWorkflowHistory_Call) RunAndReturn(run func(context.Context, string, string, bool, enums.HistoryEventFilterType) internal.HistoryEventIterator) *MockClient_GetWorkflowHistory_Call

type MockClient_GetWorkflowUpdateHandle_Call 

type MockClient_GetWorkflowUpdateHandle_Call struct {
	*mock.Call
}

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

func (*MockClient_GetWorkflowUpdateHandle_Call) Return 

func (_c *MockClient_GetWorkflowUpdateHandle_Call) Return(_a0 internal.WorkflowUpdateHandle) *MockClient_GetWorkflowUpdateHandle_Call

func (*MockClient_GetWorkflowUpdateHandle_Call) Run 

func (_c *MockClient_GetWorkflowUpdateHandle_Call) Run(run func(ref internal.GetWorkflowUpdateHandleOptions)) *MockClient_GetWorkflowUpdateHandle_Call

func (*MockClient_GetWorkflowUpdateHandle_Call) RunAndReturn 

func (_c *MockClient_GetWorkflowUpdateHandle_Call) RunAndReturn(run func(internal.GetWorkflowUpdateHandleOptions) internal.WorkflowUpdateHandle) *MockClient_GetWorkflowUpdateHandle_Call

type MockClient_GetWorkflow_Call 

type MockClient_GetWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_GetWorkflow_Call) Return 

func (_c *MockClient_GetWorkflow_Call) Return(_a0 internal.WorkflowRun) *MockClient_GetWorkflow_Call

func (*MockClient_GetWorkflow_Call) Run 

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

func (*MockClient_GetWorkflow_Call) RunAndReturn 

func (_c *MockClient_GetWorkflow_Call) RunAndReturn(run func(context.Context, string, string) internal.WorkflowRun) *MockClient_GetWorkflow_Call

type MockClient_ListArchivedWorkflow_Call 

type MockClient_ListArchivedWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_ListArchivedWorkflow_Call) Return 

func (_c *MockClient_ListArchivedWorkflow_Call) Return(_a0 *workflowservice.ListArchivedWorkflowExecutionsResponse, _a1 error) *MockClient_ListArchivedWorkflow_Call

func (*MockClient_ListArchivedWorkflow_Call) Run 

func (_c *MockClient_ListArchivedWorkflow_Call) Run(run func(ctx context.Context, request *workflowservice.ListArchivedWorkflowExecutionsRequest)) *MockClient_ListArchivedWorkflow_Call

func (*MockClient_ListArchivedWorkflow_Call) RunAndReturn 

func (_c *MockClient_ListArchivedWorkflow_Call) RunAndReturn(run func(context.Context, *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)) *MockClient_ListArchivedWorkflow_Call

type MockClient_ListClosedWorkflow_Call 

type MockClient_ListClosedWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_ListClosedWorkflow_Call) Return 

func (_c *MockClient_ListClosedWorkflow_Call) Return(_a0 *workflowservice.ListClosedWorkflowExecutionsResponse, _a1 error) *MockClient_ListClosedWorkflow_Call

func (*MockClient_ListClosedWorkflow_Call) Run 

func (_c *MockClient_ListClosedWorkflow_Call) Run(run func(ctx context.Context, request *workflowservice.ListClosedWorkflowExecutionsRequest)) *MockClient_ListClosedWorkflow_Call

func (*MockClient_ListClosedWorkflow_Call) RunAndReturn 

func (_c *MockClient_ListClosedWorkflow_Call) RunAndReturn(run func(context.Context, *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)) *MockClient_ListClosedWorkflow_Call

type MockClient_ListOpenWorkflow_Call 

type MockClient_ListOpenWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_ListOpenWorkflow_Call) Return 

func (_c *MockClient_ListOpenWorkflow_Call) Return(_a0 *workflowservice.ListOpenWorkflowExecutionsResponse, _a1 error) *MockClient_ListOpenWorkflow_Call

func (*MockClient_ListOpenWorkflow_Call) Run 

func (_c *MockClient_ListOpenWorkflow_Call) Run(run func(ctx context.Context, request *workflowservice.ListOpenWorkflowExecutionsRequest)) *MockClient_ListOpenWorkflow_Call

func (*MockClient_ListOpenWorkflow_Call) RunAndReturn 

func (_c *MockClient_ListOpenWorkflow_Call) RunAndReturn(run func(context.Context, *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)) *MockClient_ListOpenWorkflow_Call

type MockClient_ListWorkflow_Call 

type MockClient_ListWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_ListWorkflow_Call) Return 

func (_c *MockClient_ListWorkflow_Call) Return(_a0 *workflowservice.ListWorkflowExecutionsResponse, _a1 error) *MockClient_ListWorkflow_Call

func (*MockClient_ListWorkflow_Call) Run 

func (_c *MockClient_ListWorkflow_Call) Run(run func(ctx context.Context, request *workflowservice.ListWorkflowExecutionsRequest)) *MockClient_ListWorkflow_Call

func (*MockClient_ListWorkflow_Call) RunAndReturn 

func (_c *MockClient_ListWorkflow_Call) RunAndReturn(run func(context.Context, *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)) *MockClient_ListWorkflow_Call

type MockClient_OperatorService_Call 

type MockClient_OperatorService_Call struct {
	*mock.Call
}

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

func (*MockClient_OperatorService_Call) Return 

func (_c *MockClient_OperatorService_Call) Return(_a0 operatorservice.OperatorServiceClient) *MockClient_OperatorService_Call

func (*MockClient_OperatorService_Call) Run 

func (_c *MockClient_OperatorService_Call) Run(run func()) *MockClient_OperatorService_Call

func (*MockClient_OperatorService_Call) RunAndReturn 

func (_c *MockClient_OperatorService_Call) RunAndReturn(run func() operatorservice.OperatorServiceClient) *MockClient_OperatorService_Call

type MockClient_QueryWorkflowWithOptions_Call 

type MockClient_QueryWorkflowWithOptions_Call struct {
	*mock.Call
}

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

func (*MockClient_QueryWorkflowWithOptions_Call) Return 

func (_c *MockClient_QueryWorkflowWithOptions_Call) Return(_a0 *internal.QueryWorkflowWithOptionsResponse, _a1 error) *MockClient_QueryWorkflowWithOptions_Call

func (*MockClient_QueryWorkflowWithOptions_Call) Run 

func (_c *MockClient_QueryWorkflowWithOptions_Call) Run(run func(ctx context.Context, request *internal.QueryWorkflowWithOptionsRequest)) *MockClient_QueryWorkflowWithOptions_Call

func (*MockClient_QueryWorkflowWithOptions_Call) RunAndReturn 

func (_c *MockClient_QueryWorkflowWithOptions_Call) RunAndReturn(run func(context.Context, *internal.QueryWorkflowWithOptionsRequest) (*internal.QueryWorkflowWithOptionsResponse, error)) *MockClient_QueryWorkflowWithOptions_Call

type MockClient_QueryWorkflow_Call 

type MockClient_QueryWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_QueryWorkflow_Call) Return 

func (_c *MockClient_QueryWorkflow_Call) Return(_a0 converter.EncodedValue, _a1 error) *MockClient_QueryWorkflow_Call

func (*MockClient_QueryWorkflow_Call) Run 

func (_c *MockClient_QueryWorkflow_Call) Run(run func(ctx context.Context, workflowID string, runID string, queryType string, args ...interface{})) *MockClient_QueryWorkflow_Call

func (*MockClient_QueryWorkflow_Call) RunAndReturn 

func (_c *MockClient_QueryWorkflow_Call) RunAndReturn(run func(context.Context, string, string, string, ...interface{}) (converter.EncodedValue, error)) *MockClient_QueryWorkflow_Call

type MockClient_RecordActivityHeartbeatByID_Call 

type MockClient_RecordActivityHeartbeatByID_Call struct {
	*mock.Call
}

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

func (*MockClient_RecordActivityHeartbeatByID_Call) Return 

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

func (*MockClient_RecordActivityHeartbeatByID_Call) Run 

func (_c *MockClient_RecordActivityHeartbeatByID_Call) Run(run func(ctx context.Context, namespace string, workflowID string, runID string, activityID string, details ...interface{})) *MockClient_RecordActivityHeartbeatByID_Call

func (*MockClient_RecordActivityHeartbeatByID_Call) RunAndReturn 

func (_c *MockClient_RecordActivityHeartbeatByID_Call) RunAndReturn(run func(context.Context, string, string, string, string, ...interface{}) error) *MockClient_RecordActivityHeartbeatByID_Call

type MockClient_RecordActivityHeartbeat_Call 

type MockClient_RecordActivityHeartbeat_Call struct {
	*mock.Call
}

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

func (*MockClient_RecordActivityHeartbeat_Call) Return 

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

func (*MockClient_RecordActivityHeartbeat_Call) Run 

func (_c *MockClient_RecordActivityHeartbeat_Call) Run(run func(ctx context.Context, taskToken []byte, details ...interface{})) *MockClient_RecordActivityHeartbeat_Call

func (*MockClient_RecordActivityHeartbeat_Call) RunAndReturn 

func (_c *MockClient_RecordActivityHeartbeat_Call) RunAndReturn(run func(context.Context, []byte, ...interface{}) error) *MockClient_RecordActivityHeartbeat_Call

type MockClient_ResetWorkflowExecution_Call 

type MockClient_ResetWorkflowExecution_Call struct {
	*mock.Call
}

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

func (*MockClient_ResetWorkflowExecution_Call) Return 

func (_c *MockClient_ResetWorkflowExecution_Call) Return(_a0 *workflowservice.ResetWorkflowExecutionResponse, _a1 error) *MockClient_ResetWorkflowExecution_Call

func (*MockClient_ResetWorkflowExecution_Call) Run 

func (_c *MockClient_ResetWorkflowExecution_Call) Run(run func(ctx context.Context, request *workflowservice.ResetWorkflowExecutionRequest)) *MockClient_ResetWorkflowExecution_Call

func (*MockClient_ResetWorkflowExecution_Call) RunAndReturn 

func (_c *MockClient_ResetWorkflowExecution_Call) RunAndReturn(run func(context.Context, *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)) *MockClient_ResetWorkflowExecution_Call

type MockClient_ScanWorkflow_Call 

type MockClient_ScanWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_ScanWorkflow_Call) Return 

func (_c *MockClient_ScanWorkflow_Call) Return(_a0 *workflowservice.ScanWorkflowExecutionsResponse, _a1 error) *MockClient_ScanWorkflow_Call

func (*MockClient_ScanWorkflow_Call) Run 

func (_c *MockClient_ScanWorkflow_Call) Run(run func(ctx context.Context, request *workflowservice.ScanWorkflowExecutionsRequest)) *MockClient_ScanWorkflow_Call

func (*MockClient_ScanWorkflow_Call) RunAndReturn 

func (_c *MockClient_ScanWorkflow_Call) RunAndReturn(run func(context.Context, *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)) *MockClient_ScanWorkflow_Call

type MockClient_ScheduleClient_Call 

type MockClient_ScheduleClient_Call struct {
	*mock.Call
}

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

func (*MockClient_ScheduleClient_Call) Return 

func (_c *MockClient_ScheduleClient_Call) Return(_a0 internal.ScheduleClient) *MockClient_ScheduleClient_Call

func (*MockClient_ScheduleClient_Call) Run 

func (_c *MockClient_ScheduleClient_Call) Run(run func()) *MockClient_ScheduleClient_Call

func (*MockClient_ScheduleClient_Call) RunAndReturn 

func (_c *MockClient_ScheduleClient_Call) RunAndReturn(run func() internal.ScheduleClient) *MockClient_ScheduleClient_Call

type MockClient_SignalWithStartWorkflow_Call 

type MockClient_SignalWithStartWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_SignalWithStartWorkflow_Call) Return 

func (_c *MockClient_SignalWithStartWorkflow_Call) Return(_a0 internal.WorkflowRun, _a1 error) *MockClient_SignalWithStartWorkflow_Call

func (*MockClient_SignalWithStartWorkflow_Call) Run 

func (_c *MockClient_SignalWithStartWorkflow_Call) Run(run func(ctx context.Context, workflowID string, signalName string, signalArg interface{}, options internal.StartWorkflowOptions, workflow interface{}, workflowArgs ...interface{})) *MockClient_SignalWithStartWorkflow_Call

func (*MockClient_SignalWithStartWorkflow_Call) RunAndReturn 

func (_c *MockClient_SignalWithStartWorkflow_Call) RunAndReturn(run func(context.Context, string, string, interface{}, internal.StartWorkflowOptions, interface{}, ...interface{}) (internal.WorkflowRun, error)) *MockClient_SignalWithStartWorkflow_Call

type MockClient_SignalWorkflow_Call 

type MockClient_SignalWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_SignalWorkflow_Call) Return 

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

func (*MockClient_SignalWorkflow_Call) Run 

func (_c *MockClient_SignalWorkflow_Call) Run(run func(ctx context.Context, workflowID string, runID string, signalName string, arg interface{})) *MockClient_SignalWorkflow_Call

func (*MockClient_SignalWorkflow_Call) RunAndReturn 

func (_c *MockClient_SignalWorkflow_Call) RunAndReturn(run func(context.Context, string, string, string, interface{}) error) *MockClient_SignalWorkflow_Call

type MockClient_TerminateWorkflow_Call 

type MockClient_TerminateWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_TerminateWorkflow_Call) Return 

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

func (*MockClient_TerminateWorkflow_Call) Run 

func (_c *MockClient_TerminateWorkflow_Call) Run(run func(ctx context.Context, workflowID string, runID string, reason string, details ...interface{})) *MockClient_TerminateWorkflow_Call

func (*MockClient_TerminateWorkflow_Call) RunAndReturn 

func (_c *MockClient_TerminateWorkflow_Call) RunAndReturn(run func(context.Context, string, string, string, ...interface{}) error) *MockClient_TerminateWorkflow_Call

type MockClient_UpdateWorkerBuildIdCompatibility_Call 

type MockClient_UpdateWorkerBuildIdCompatibility_Call struct {
	*mock.Call
}

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

func (*MockClient_UpdateWorkerBuildIdCompatibility_Call) Return 

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

func (*MockClient_UpdateWorkerBuildIdCompatibility_Call) Run 

func (_c *MockClient_UpdateWorkerBuildIdCompatibility_Call) Run(run func(ctx context.Context, options *internal.UpdateWorkerBuildIdCompatibilityOptions)) *MockClient_UpdateWorkerBuildIdCompatibility_Call

func (*MockClient_UpdateWorkerBuildIdCompatibility_Call) RunAndReturn 

func (_c *MockClient_UpdateWorkerBuildIdCompatibility_Call) RunAndReturn(run func(context.Context, *internal.UpdateWorkerBuildIdCompatibilityOptions) error) *MockClient_UpdateWorkerBuildIdCompatibility_Call

type MockClient_UpdateWorkflowWithOptions_Call 

type MockClient_UpdateWorkflowWithOptions_Call struct {
	*mock.Call
}

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

func (*MockClient_UpdateWorkflowWithOptions_Call) Return 

func (_c *MockClient_UpdateWorkflowWithOptions_Call) Return(_a0 internal.WorkflowUpdateHandle, _a1 error) *MockClient_UpdateWorkflowWithOptions_Call

func (*MockClient_UpdateWorkflowWithOptions_Call) Run 

func (_c *MockClient_UpdateWorkflowWithOptions_Call) Run(run func(ctx context.Context, request *internal.UpdateWorkflowWithOptionsRequest)) *MockClient_UpdateWorkflowWithOptions_Call

func (*MockClient_UpdateWorkflowWithOptions_Call) RunAndReturn 

func (_c *MockClient_UpdateWorkflowWithOptions_Call) RunAndReturn(run func(context.Context, *internal.UpdateWorkflowWithOptionsRequest) (internal.WorkflowUpdateHandle, error)) *MockClient_UpdateWorkflowWithOptions_Call

type MockClient_UpdateWorkflow_Call 

type MockClient_UpdateWorkflow_Call struct {
	*mock.Call
}

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

func (*MockClient_UpdateWorkflow_Call) Return 

func (_c *MockClient_UpdateWorkflow_Call) Return(_a0 internal.WorkflowUpdateHandle, _a1 error) *MockClient_UpdateWorkflow_Call

func (*MockClient_UpdateWorkflow_Call) Run 

func (_c *MockClient_UpdateWorkflow_Call) Run(run func(ctx context.Context, workflowID string, workflowRunID string, updateName string, args ...interface{})) *MockClient_UpdateWorkflow_Call

func (*MockClient_UpdateWorkflow_Call) RunAndReturn 

func (_c *MockClient_UpdateWorkflow_Call) RunAndReturn(run func(context.Context, string, string, string, ...interface{}) (internal.WorkflowUpdateHandle, error)) *MockClient_UpdateWorkflow_Call

type MockClient_WorkflowService_Call 

type MockClient_WorkflowService_Call struct {
	*mock.Call
}

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

func (*MockClient_WorkflowService_Call) Return 

func (_c *MockClient_WorkflowService_Call) Return(_a0 workflowservice.WorkflowServiceClient) *MockClient_WorkflowService_Call

func (*MockClient_WorkflowService_Call) Run 

func (_c *MockClient_WorkflowService_Call) Run(run func()) *MockClient_WorkflowService_Call

func (*MockClient_WorkflowService_Call) RunAndReturn 

func (_c *MockClient_WorkflowService_Call) RunAndReturn(run func() workflowservice.WorkflowServiceClient) *MockClient_WorkflowService_Call

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.