Documentation ¶
Overview ¶
Package mocksdk is a generated GoMock package.
Package mocksdk is a generated GoMock package.
Package mocksdk is a generated GoMock package.
Package mocksdk is a generated GoMock package.
Index ¶
- type MockClient
- func (m *MockClient) CancelWorkflow(arg0 context.Context, arg1, arg2 string) error
- func (m *MockClient) CheckHealth(arg0 context.Context, arg1 *client.CheckHealthRequest) (*client.CheckHealthResponse, error)
- func (m *MockClient) Close()
- func (m *MockClient) CompleteActivity(arg0 context.Context, arg1 []byte, arg2 interface{}, arg3 error) error
- func (m *MockClient) CompleteActivityByID(arg0 context.Context, arg1, arg2, arg3, arg4 string, arg5 interface{}, ...) error
- func (m *MockClient) CountWorkflow(arg0 context.Context, arg1 *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)
- func (m *MockClient) DescribeTaskQueue(arg0 context.Context, arg1 string, arg2 enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)
- func (m *MockClient) DescribeWorkflowExecution(arg0 context.Context, arg1, arg2 string) (*workflowservice.DescribeWorkflowExecutionResponse, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) ExecuteWorkflow(arg0 context.Context, arg1 client.StartWorkflowOptions, arg2 interface{}, ...) (client.WorkflowRun, error)
- func (m *MockClient) GetSearchAttributes(arg0 context.Context) (*workflowservice.GetSearchAttributesResponse, error)
- func (m *MockClient) GetWorkerBuildIdCompatibility(arg0 context.Context, arg1 *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)
- func (m *MockClient) GetWorkerTaskReachability(arg0 context.Context, arg1 *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, error)
- func (m *MockClient) GetWorkflow(arg0 context.Context, arg1, arg2 string) client.WorkflowRun
- func (m *MockClient) GetWorkflowHistory(arg0 context.Context, arg1, arg2 string, arg3 bool, ...) client.HistoryEventIterator
- func (m *MockClient) GetWorkflowUpdateHandle(arg0 client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle
- func (m *MockClient) ListArchivedWorkflow(arg0 context.Context, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
- func (m *MockClient) ListClosedWorkflow(arg0 context.Context, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
- func (m *MockClient) ListOpenWorkflow(arg0 context.Context, arg1 *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
- func (m *MockClient) ListWorkflow(arg0 context.Context, arg1 *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)
- func (m *MockClient) OperatorService() operatorservice.OperatorServiceClient
- func (m *MockClient) QueryWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) (converter.EncodedValue, error)
- func (m *MockClient) QueryWorkflowWithOptions(arg0 context.Context, arg1 *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)
- func (m *MockClient) RecordActivityHeartbeat(arg0 context.Context, arg1 []byte, arg2 ...interface{}) error
- func (m *MockClient) RecordActivityHeartbeatByID(arg0 context.Context, arg1, arg2, arg3, arg4 string, arg5 ...interface{}) error
- func (m *MockClient) ResetWorkflowExecution(arg0 context.Context, arg1 *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)
- func (m *MockClient) ScanWorkflow(arg0 context.Context, arg1 *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)
- func (m *MockClient) ScheduleClient() client.ScheduleClient
- func (m *MockClient) SignalWithStartWorkflow(arg0 context.Context, arg1, arg2 string, arg3 interface{}, ...) (client.WorkflowRun, error)
- func (m *MockClient) SignalWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 interface{}) error
- func (m *MockClient) TerminateWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) error
- func (m *MockClient) UpdateWorkerBuildIdCompatibility(arg0 context.Context, arg1 *client.UpdateWorkerBuildIdCompatibilityOptions) error
- func (m *MockClient) UpdateWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) (client.WorkflowUpdateHandle, error)
- func (m *MockClient) UpdateWorkflowWithOptions(arg0 context.Context, arg1 *client.UpdateWorkflowWithOptionsRequest) (client.WorkflowUpdateHandle, error)
- func (m *MockClient) WorkflowService() workflowservice.WorkflowServiceClient
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) CancelWorkflow(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CheckHealth(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Close() *gomock.Call
- func (mr *MockClientMockRecorder) CompleteActivity(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CompleteActivityByID(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CountWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeTaskQueue(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeWorkflowExecution(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ExecuteWorkflow(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetSearchAttributes(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkerTaskReachability(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkflow(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkflowHistory(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkflowUpdateHandle(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListArchivedWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListClosedWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListOpenWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) OperatorService() *gomock.Call
- func (mr *MockClientMockRecorder) QueryWorkflow(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RecordActivityHeartbeat(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RecordActivityHeartbeatByID(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ScanWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ScheduleClient() *gomock.Call
- func (mr *MockClientMockRecorder) SignalWithStartWorkflow(arg0, arg1, arg2, arg3, arg4, arg5 interface{}, arg6 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SignalWorkflow(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) TerminateWorkflow(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateWorkflow(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) WorkflowService() *gomock.Call
- type MockEncodedValue
- type MockEncodedValueMockRecorder
- type MockWorker
- func (m *MockWorker) EXPECT() *MockWorkerMockRecorder
- func (m *MockWorker) RegisterActivity(arg0 interface{})
- func (m *MockWorker) RegisterActivityWithOptions(arg0 interface{}, arg1 activity.RegisterOptions)
- func (m *MockWorker) RegisterWorkflow(arg0 interface{})
- func (m *MockWorker) RegisterWorkflowWithOptions(arg0 interface{}, arg1 workflow.RegisterOptions)
- func (m *MockWorker) Run(arg0 <-chan interface{}) error
- func (m *MockWorker) Start() error
- func (m *MockWorker) Stop()
- type MockWorkerMockRecorder
- func (mr *MockWorkerMockRecorder) RegisterActivity(arg0 interface{}) *gomock.Call
- func (mr *MockWorkerMockRecorder) RegisterActivityWithOptions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerMockRecorder) RegisterWorkflow(arg0 interface{}) *gomock.Call
- func (mr *MockWorkerMockRecorder) RegisterWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkerMockRecorder) Run(arg0 interface{}) *gomock.Call
- func (mr *MockWorkerMockRecorder) Start() *gomock.Call
- func (mr *MockWorkerMockRecorder) Stop() *gomock.Call
- type MockWorkflowRun
- func (m *MockWorkflowRun) EXPECT() *MockWorkflowRunMockRecorder
- func (m *MockWorkflowRun) Get(arg0 context.Context, arg1 interface{}) error
- func (m *MockWorkflowRun) GetID() string
- func (m *MockWorkflowRun) GetRunID() string
- func (m *MockWorkflowRun) GetWithOptions(arg0 context.Context, arg1 interface{}, arg2 client.WorkflowRunGetOptions) error
- type MockWorkflowRunMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface.
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance.
func (*MockClient) CancelWorkflow ¶
func (m *MockClient) CancelWorkflow(arg0 context.Context, arg1, arg2 string) error
CancelWorkflow mocks base method.
func (*MockClient) CheckHealth ¶
func (m *MockClient) CheckHealth(arg0 context.Context, arg1 *client.CheckHealthRequest) (*client.CheckHealthResponse, error)
CheckHealth mocks base method.
func (*MockClient) CompleteActivity ¶
func (m *MockClient) CompleteActivity(arg0 context.Context, arg1 []byte, arg2 interface{}, arg3 error) error
CompleteActivity mocks base method.
func (*MockClient) CompleteActivityByID ¶
func (m *MockClient) CompleteActivityByID(arg0 context.Context, arg1, arg2, arg3, arg4 string, arg5 interface{}, arg6 error) error
CompleteActivityByID mocks base method.
func (*MockClient) CountWorkflow ¶
func (m *MockClient) CountWorkflow(arg0 context.Context, arg1 *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)
CountWorkflow mocks base method.
func (*MockClient) DescribeTaskQueue ¶
func (m *MockClient) DescribeTaskQueue(arg0 context.Context, arg1 string, arg2 enums.TaskQueueType) (*workflowservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue mocks base method.
func (*MockClient) DescribeWorkflowExecution ¶
func (m *MockClient) DescribeWorkflowExecution(arg0 context.Context, arg1, arg2 string) (*workflowservice.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockClient) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) ExecuteWorkflow ¶
func (m *MockClient) ExecuteWorkflow(arg0 context.Context, arg1 client.StartWorkflowOptions, arg2 interface{}, arg3 ...interface{}) (client.WorkflowRun, error)
ExecuteWorkflow mocks base method.
func (*MockClient) GetSearchAttributes ¶
func (m *MockClient) GetSearchAttributes(arg0 context.Context) (*workflowservice.GetSearchAttributesResponse, error)
GetSearchAttributes mocks base method.
func (*MockClient) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockClient) GetWorkerBuildIdCompatibility(arg0 context.Context, arg1 *client.GetWorkerBuildIdCompatibilityOptions) (*client.WorkerBuildIDVersionSets, error)
GetWorkerBuildIdCompatibility mocks base method.
func (*MockClient) GetWorkerTaskReachability ¶ added in v1.22.2
func (m *MockClient) GetWorkerTaskReachability(arg0 context.Context, arg1 *client.GetWorkerTaskReachabilityOptions) (*client.WorkerTaskReachability, error)
GetWorkerTaskReachability mocks base method.
func (*MockClient) GetWorkflow ¶
func (m *MockClient) GetWorkflow(arg0 context.Context, arg1, arg2 string) client.WorkflowRun
GetWorkflow mocks base method.
func (*MockClient) GetWorkflowHistory ¶
func (m *MockClient) GetWorkflowHistory(arg0 context.Context, arg1, arg2 string, arg3 bool, arg4 enums.HistoryEventFilterType) client.HistoryEventIterator
GetWorkflowHistory mocks base method.
func (*MockClient) GetWorkflowUpdateHandle ¶ added in v1.21.0
func (m *MockClient) GetWorkflowUpdateHandle(arg0 client.GetWorkflowUpdateHandleOptions) client.WorkflowUpdateHandle
GetWorkflowUpdateHandle mocks base method.
func (*MockClient) ListArchivedWorkflow ¶
func (m *MockClient) ListArchivedWorkflow(arg0 context.Context, arg1 *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
ListArchivedWorkflow mocks base method.
func (*MockClient) ListClosedWorkflow ¶
func (m *MockClient) ListClosedWorkflow(arg0 context.Context, arg1 *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflow mocks base method.
func (*MockClient) ListOpenWorkflow ¶
func (m *MockClient) ListOpenWorkflow(arg0 context.Context, arg1 *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflow mocks base method.
func (*MockClient) ListWorkflow ¶
func (m *MockClient) ListWorkflow(arg0 context.Context, arg1 *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)
ListWorkflow mocks base method.
func (*MockClient) OperatorService ¶ added in v1.18.0
func (m *MockClient) OperatorService() operatorservice.OperatorServiceClient
OperatorService mocks base method.
func (*MockClient) QueryWorkflow ¶
func (m *MockClient) QueryWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) (converter.EncodedValue, error)
QueryWorkflow mocks base method.
func (*MockClient) QueryWorkflowWithOptions ¶
func (m *MockClient) QueryWorkflowWithOptions(arg0 context.Context, arg1 *client.QueryWorkflowWithOptionsRequest) (*client.QueryWorkflowWithOptionsResponse, error)
QueryWorkflowWithOptions mocks base method.
func (*MockClient) RecordActivityHeartbeat ¶
func (m *MockClient) RecordActivityHeartbeat(arg0 context.Context, arg1 []byte, arg2 ...interface{}) error
RecordActivityHeartbeat mocks base method.
func (*MockClient) RecordActivityHeartbeatByID ¶
func (m *MockClient) RecordActivityHeartbeatByID(arg0 context.Context, arg1, arg2, arg3, arg4 string, arg5 ...interface{}) error
RecordActivityHeartbeatByID mocks base method.
func (*MockClient) ResetWorkflowExecution ¶
func (m *MockClient) ResetWorkflowExecution(arg0 context.Context, arg1 *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method.
func (*MockClient) ScanWorkflow ¶
func (m *MockClient) ScanWorkflow(arg0 context.Context, arg1 *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)
ScanWorkflow mocks base method.
func (*MockClient) ScheduleClient ¶ added in v1.19.0
func (m *MockClient) ScheduleClient() client.ScheduleClient
ScheduleClient mocks base method.
func (*MockClient) SignalWithStartWorkflow ¶
func (m *MockClient) SignalWithStartWorkflow(arg0 context.Context, arg1, arg2 string, arg3 interface{}, arg4 client.StartWorkflowOptions, arg5 interface{}, arg6 ...interface{}) (client.WorkflowRun, error)
SignalWithStartWorkflow mocks base method.
func (*MockClient) SignalWorkflow ¶
func (m *MockClient) SignalWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 interface{}) error
SignalWorkflow mocks base method.
func (*MockClient) TerminateWorkflow ¶
func (m *MockClient) TerminateWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) error
TerminateWorkflow mocks base method.
func (*MockClient) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockClient) UpdateWorkerBuildIdCompatibility(arg0 context.Context, arg1 *client.UpdateWorkerBuildIdCompatibilityOptions) error
UpdateWorkerBuildIdCompatibility mocks base method.
func (*MockClient) UpdateWorkflow ¶ added in v1.20.0
func (m *MockClient) UpdateWorkflow(arg0 context.Context, arg1, arg2, arg3 string, arg4 ...interface{}) (client.WorkflowUpdateHandle, error)
UpdateWorkflow mocks base method.
func (*MockClient) UpdateWorkflowWithOptions ¶ added in v1.20.0
func (m *MockClient) UpdateWorkflowWithOptions(arg0 context.Context, arg1 *client.UpdateWorkflowWithOptionsRequest) (client.WorkflowUpdateHandle, error)
UpdateWorkflowWithOptions mocks base method.
func (*MockClient) WorkflowService ¶
func (m *MockClient) WorkflowService() workflowservice.WorkflowServiceClient
WorkflowService mocks base method.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) CancelWorkflow ¶
func (mr *MockClientMockRecorder) CancelWorkflow(arg0, arg1, arg2 interface{}) *gomock.Call
CancelWorkflow indicates an expected call of CancelWorkflow.
func (*MockClientMockRecorder) CheckHealth ¶
func (mr *MockClientMockRecorder) CheckHealth(arg0, arg1 interface{}) *gomock.Call
CheckHealth indicates an expected call of CheckHealth.
func (*MockClientMockRecorder) Close ¶
func (mr *MockClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockClientMockRecorder) CompleteActivity ¶
func (mr *MockClientMockRecorder) CompleteActivity(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
CompleteActivity indicates an expected call of CompleteActivity.
func (*MockClientMockRecorder) CompleteActivityByID ¶
func (mr *MockClientMockRecorder) CompleteActivityByID(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call
CompleteActivityByID indicates an expected call of CompleteActivityByID.
func (*MockClientMockRecorder) CountWorkflow ¶
func (mr *MockClientMockRecorder) CountWorkflow(arg0, arg1 interface{}) *gomock.Call
CountWorkflow indicates an expected call of CountWorkflow.
func (*MockClientMockRecorder) DescribeTaskQueue ¶
func (mr *MockClientMockRecorder) DescribeTaskQueue(arg0, arg1, arg2 interface{}) *gomock.Call
DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (*MockClientMockRecorder) DescribeWorkflowExecution ¶
func (mr *MockClientMockRecorder) DescribeWorkflowExecution(arg0, arg1, arg2 interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockClientMockRecorder) ExecuteWorkflow ¶
func (mr *MockClientMockRecorder) ExecuteWorkflow(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ExecuteWorkflow indicates an expected call of ExecuteWorkflow.
func (*MockClientMockRecorder) GetSearchAttributes ¶
func (mr *MockClientMockRecorder) GetSearchAttributes(arg0 interface{}) *gomock.Call
GetSearchAttributes indicates an expected call of GetSearchAttributes.
func (*MockClientMockRecorder) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockClientMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (*MockClientMockRecorder) GetWorkerTaskReachability ¶ added in v1.22.2
func (mr *MockClientMockRecorder) GetWorkerTaskReachability(arg0, arg1 interface{}) *gomock.Call
GetWorkerTaskReachability indicates an expected call of GetWorkerTaskReachability.
func (*MockClientMockRecorder) GetWorkflow ¶
func (mr *MockClientMockRecorder) GetWorkflow(arg0, arg1, arg2 interface{}) *gomock.Call
GetWorkflow indicates an expected call of GetWorkflow.
func (*MockClientMockRecorder) GetWorkflowHistory ¶
func (mr *MockClientMockRecorder) GetWorkflowHistory(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
GetWorkflowHistory indicates an expected call of GetWorkflowHistory.
func (*MockClientMockRecorder) GetWorkflowUpdateHandle ¶ added in v1.21.0
func (mr *MockClientMockRecorder) GetWorkflowUpdateHandle(arg0 interface{}) *gomock.Call
GetWorkflowUpdateHandle indicates an expected call of GetWorkflowUpdateHandle.
func (*MockClientMockRecorder) ListArchivedWorkflow ¶
func (mr *MockClientMockRecorder) ListArchivedWorkflow(arg0, arg1 interface{}) *gomock.Call
ListArchivedWorkflow indicates an expected call of ListArchivedWorkflow.
func (*MockClientMockRecorder) ListClosedWorkflow ¶
func (mr *MockClientMockRecorder) ListClosedWorkflow(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflow indicates an expected call of ListClosedWorkflow.
func (*MockClientMockRecorder) ListOpenWorkflow ¶
func (mr *MockClientMockRecorder) ListOpenWorkflow(arg0, arg1 interface{}) *gomock.Call
ListOpenWorkflow indicates an expected call of ListOpenWorkflow.
func (*MockClientMockRecorder) ListWorkflow ¶
func (mr *MockClientMockRecorder) ListWorkflow(arg0, arg1 interface{}) *gomock.Call
ListWorkflow indicates an expected call of ListWorkflow.
func (*MockClientMockRecorder) OperatorService ¶ added in v1.18.0
func (mr *MockClientMockRecorder) OperatorService() *gomock.Call
OperatorService indicates an expected call of OperatorService.
func (*MockClientMockRecorder) QueryWorkflow ¶
func (mr *MockClientMockRecorder) QueryWorkflow(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockClientMockRecorder) QueryWorkflowWithOptions ¶
func (mr *MockClientMockRecorder) QueryWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call
QueryWorkflowWithOptions indicates an expected call of QueryWorkflowWithOptions.
func (*MockClientMockRecorder) RecordActivityHeartbeat ¶
func (mr *MockClientMockRecorder) RecordActivityHeartbeat(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RecordActivityHeartbeat indicates an expected call of RecordActivityHeartbeat.
func (*MockClientMockRecorder) RecordActivityHeartbeatByID ¶
func (mr *MockClientMockRecorder) RecordActivityHeartbeatByID(arg0, arg1, arg2, arg3, arg4 interface{}, arg5 ...interface{}) *gomock.Call
RecordActivityHeartbeatByID indicates an expected call of RecordActivityHeartbeatByID.
func (*MockClientMockRecorder) ResetWorkflowExecution ¶
func (mr *MockClientMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.
func (*MockClientMockRecorder) ScanWorkflow ¶
func (mr *MockClientMockRecorder) ScanWorkflow(arg0, arg1 interface{}) *gomock.Call
ScanWorkflow indicates an expected call of ScanWorkflow.
func (*MockClientMockRecorder) ScheduleClient ¶ added in v1.19.0
func (mr *MockClientMockRecorder) ScheduleClient() *gomock.Call
ScheduleClient indicates an expected call of ScheduleClient.
func (*MockClientMockRecorder) SignalWithStartWorkflow ¶
func (mr *MockClientMockRecorder) SignalWithStartWorkflow(arg0, arg1, arg2, arg3, arg4, arg5 interface{}, arg6 ...interface{}) *gomock.Call
SignalWithStartWorkflow indicates an expected call of SignalWithStartWorkflow.
func (*MockClientMockRecorder) SignalWorkflow ¶
func (mr *MockClientMockRecorder) SignalWorkflow(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
SignalWorkflow indicates an expected call of SignalWorkflow.
func (*MockClientMockRecorder) TerminateWorkflow ¶
func (mr *MockClientMockRecorder) TerminateWorkflow(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
TerminateWorkflow indicates an expected call of TerminateWorkflow.
func (*MockClientMockRecorder) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockClientMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.
func (*MockClientMockRecorder) UpdateWorkflow ¶ added in v1.20.0
func (mr *MockClientMockRecorder) UpdateWorkflow(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
UpdateWorkflow indicates an expected call of UpdateWorkflow.
func (*MockClientMockRecorder) UpdateWorkflowWithOptions ¶ added in v1.20.0
func (mr *MockClientMockRecorder) UpdateWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call
UpdateWorkflowWithOptions indicates an expected call of UpdateWorkflowWithOptions.
func (*MockClientMockRecorder) WorkflowService ¶
func (mr *MockClientMockRecorder) WorkflowService() *gomock.Call
WorkflowService indicates an expected call of WorkflowService.
type MockEncodedValue ¶ added in v1.23.0
type MockEncodedValue struct {
// contains filtered or unexported fields
}
MockEncodedValue is a mock of EncodedValue interface.
func NewMockEncodedValue ¶ added in v1.23.0
func NewMockEncodedValue(ctrl *gomock.Controller) *MockEncodedValue
NewMockEncodedValue creates a new mock instance.
func (*MockEncodedValue) EXPECT ¶ added in v1.23.0
func (m *MockEncodedValue) EXPECT() *MockEncodedValueMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEncodedValue) Get ¶ added in v1.23.0
func (m *MockEncodedValue) Get(arg0 interface{}) error
Get mocks base method.
func (*MockEncodedValue) HasValue ¶ added in v1.23.0
func (m *MockEncodedValue) HasValue() bool
HasValue mocks base method.
type MockEncodedValueMockRecorder ¶ added in v1.23.0
type MockEncodedValueMockRecorder struct {
// contains filtered or unexported fields
}
MockEncodedValueMockRecorder is the mock recorder for MockEncodedValue.
func (*MockEncodedValueMockRecorder) Get ¶ added in v1.23.0
func (mr *MockEncodedValueMockRecorder) Get(arg0 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockEncodedValueMockRecorder) HasValue ¶ added in v1.23.0
func (mr *MockEncodedValueMockRecorder) HasValue() *gomock.Call
HasValue indicates an expected call of HasValue.
type MockWorker ¶
type MockWorker struct {
// contains filtered or unexported fields
}
MockWorker is a mock of Worker interface.
func NewMockWorker ¶
func NewMockWorker(ctrl *gomock.Controller) *MockWorker
NewMockWorker creates a new mock instance.
func (*MockWorker) EXPECT ¶
func (m *MockWorker) EXPECT() *MockWorkerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockWorker) RegisterActivity ¶
func (m *MockWorker) RegisterActivity(arg0 interface{})
RegisterActivity mocks base method.
func (*MockWorker) RegisterActivityWithOptions ¶
func (m *MockWorker) RegisterActivityWithOptions(arg0 interface{}, arg1 activity.RegisterOptions)
RegisterActivityWithOptions mocks base method.
func (*MockWorker) RegisterWorkflow ¶
func (m *MockWorker) RegisterWorkflow(arg0 interface{})
RegisterWorkflow mocks base method.
func (*MockWorker) RegisterWorkflowWithOptions ¶
func (m *MockWorker) RegisterWorkflowWithOptions(arg0 interface{}, arg1 workflow.RegisterOptions)
RegisterWorkflowWithOptions mocks base method.
func (*MockWorker) Run ¶
func (m *MockWorker) Run(arg0 <-chan interface{}) error
Run mocks base method.
type MockWorkerMockRecorder ¶
type MockWorkerMockRecorder struct {
// contains filtered or unexported fields
}
MockWorkerMockRecorder is the mock recorder for MockWorker.
func (*MockWorkerMockRecorder) RegisterActivity ¶
func (mr *MockWorkerMockRecorder) RegisterActivity(arg0 interface{}) *gomock.Call
RegisterActivity indicates an expected call of RegisterActivity.
func (*MockWorkerMockRecorder) RegisterActivityWithOptions ¶
func (mr *MockWorkerMockRecorder) RegisterActivityWithOptions(arg0, arg1 interface{}) *gomock.Call
RegisterActivityWithOptions indicates an expected call of RegisterActivityWithOptions.
func (*MockWorkerMockRecorder) RegisterWorkflow ¶
func (mr *MockWorkerMockRecorder) RegisterWorkflow(arg0 interface{}) *gomock.Call
RegisterWorkflow indicates an expected call of RegisterWorkflow.
func (*MockWorkerMockRecorder) RegisterWorkflowWithOptions ¶
func (mr *MockWorkerMockRecorder) RegisterWorkflowWithOptions(arg0, arg1 interface{}) *gomock.Call
RegisterWorkflowWithOptions indicates an expected call of RegisterWorkflowWithOptions.
func (*MockWorkerMockRecorder) Run ¶
func (mr *MockWorkerMockRecorder) Run(arg0 interface{}) *gomock.Call
Run indicates an expected call of Run.
func (*MockWorkerMockRecorder) Start ¶
func (mr *MockWorkerMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockWorkerMockRecorder) Stop ¶
func (mr *MockWorkerMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
type MockWorkflowRun ¶ added in v1.17.3
type MockWorkflowRun struct {
// contains filtered or unexported fields
}
MockWorkflowRun is a mock of WorkflowRun interface.
func NewMockWorkflowRun ¶ added in v1.17.3
func NewMockWorkflowRun(ctrl *gomock.Controller) *MockWorkflowRun
NewMockWorkflowRun creates a new mock instance.
func (*MockWorkflowRun) EXPECT ¶ added in v1.17.3
func (m *MockWorkflowRun) EXPECT() *MockWorkflowRunMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockWorkflowRun) Get ¶ added in v1.17.3
func (m *MockWorkflowRun) Get(arg0 context.Context, arg1 interface{}) error
Get mocks base method.
func (*MockWorkflowRun) GetID ¶ added in v1.17.3
func (m *MockWorkflowRun) GetID() string
GetID mocks base method.
func (*MockWorkflowRun) GetRunID ¶ added in v1.17.3
func (m *MockWorkflowRun) GetRunID() string
GetRunID mocks base method.
func (*MockWorkflowRun) GetWithOptions ¶ added in v1.17.3
func (m *MockWorkflowRun) GetWithOptions(arg0 context.Context, arg1 interface{}, arg2 client.WorkflowRunGetOptions) error
GetWithOptions mocks base method.
type MockWorkflowRunMockRecorder ¶ added in v1.17.3
type MockWorkflowRunMockRecorder struct {
// contains filtered or unexported fields
}
MockWorkflowRunMockRecorder is the mock recorder for MockWorkflowRun.
func (*MockWorkflowRunMockRecorder) Get ¶ added in v1.17.3
func (mr *MockWorkflowRunMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockWorkflowRunMockRecorder) GetID ¶ added in v1.17.3
func (mr *MockWorkflowRunMockRecorder) GetID() *gomock.Call
GetID indicates an expected call of GetID.
func (*MockWorkflowRunMockRecorder) GetRunID ¶ added in v1.17.3
func (mr *MockWorkflowRunMockRecorder) GetRunID() *gomock.Call
GetRunID indicates an expected call of GetRunID.
func (*MockWorkflowRunMockRecorder) GetWithOptions ¶ added in v1.17.3
func (mr *MockWorkflowRunMockRecorder) GetWithOptions(arg0, arg1, arg2 interface{}) *gomock.Call
GetWithOptions indicates an expected call of GetWithOptions.