Documentation ¶
Overview ¶
Package workflowservicemock is a generated GoMock package.
Index ¶
- type MockUnsafeWorkflowServiceServer
- type MockUnsafeWorkflowServiceServerMockRecorder
- type MockWorkflowServiceClient
- func (m *MockWorkflowServiceClient) CountWorkflowExecutions(ctx context.Context, in *workflowservice.CountWorkflowExecutionsRequest, ...) (*workflowservice.CountWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceClient) CreateSchedule(ctx context.Context, in *workflowservice.CreateScheduleRequest, ...) (*workflowservice.CreateScheduleResponse, error)
- func (m *MockWorkflowServiceClient) DeleteSchedule(ctx context.Context, in *workflowservice.DeleteScheduleRequest, ...) (*workflowservice.DeleteScheduleResponse, error)
- func (m *MockWorkflowServiceClient) DeleteWorkflowExecution(ctx context.Context, in *workflowservice.DeleteWorkflowExecutionRequest, ...) (*workflowservice.DeleteWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) DeprecateNamespace(ctx context.Context, in *workflowservice.DeprecateNamespaceRequest, ...) (*workflowservice.DeprecateNamespaceResponse, error)
- func (m *MockWorkflowServiceClient) DescribeBatchOperation(ctx context.Context, in *workflowservice.DescribeBatchOperationRequest, ...) (*workflowservice.DescribeBatchOperationResponse, error)
- func (m *MockWorkflowServiceClient) DescribeDeployment(ctx context.Context, in *workflowservice.DescribeDeploymentRequest, ...) (*workflowservice.DescribeDeploymentResponse, error)
- func (m *MockWorkflowServiceClient) DescribeNamespace(ctx context.Context, in *workflowservice.DescribeNamespaceRequest, ...) (*workflowservice.DescribeNamespaceResponse, error)
- func (m *MockWorkflowServiceClient) DescribeSchedule(ctx context.Context, in *workflowservice.DescribeScheduleRequest, ...) (*workflowservice.DescribeScheduleResponse, error)
- func (m *MockWorkflowServiceClient) DescribeTaskQueue(ctx context.Context, in *workflowservice.DescribeTaskQueueRequest, ...) (*workflowservice.DescribeTaskQueueResponse, error)
- func (m *MockWorkflowServiceClient) DescribeWorkflowExecution(ctx context.Context, in *workflowservice.DescribeWorkflowExecutionRequest, ...) (*workflowservice.DescribeWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) EXPECT() *MockWorkflowServiceClientMockRecorder
- func (m *MockWorkflowServiceClient) ExecuteMultiOperation(ctx context.Context, in *workflowservice.ExecuteMultiOperationRequest, ...) (*workflowservice.ExecuteMultiOperationResponse, error)
- func (m *MockWorkflowServiceClient) GetClusterInfo(ctx context.Context, in *workflowservice.GetClusterInfoRequest, ...) (*workflowservice.GetClusterInfoResponse, error)
- func (m *MockWorkflowServiceClient) GetCurrentDeployment(ctx context.Context, in *workflowservice.GetCurrentDeploymentRequest, ...) (*workflowservice.GetCurrentDeploymentResponse, error)
- func (m *MockWorkflowServiceClient) GetDeploymentReachability(ctx context.Context, in *workflowservice.GetDeploymentReachabilityRequest, ...) (*workflowservice.GetDeploymentReachabilityResponse, error)
- func (m *MockWorkflowServiceClient) GetSearchAttributes(ctx context.Context, in *workflowservice.GetSearchAttributesRequest, ...) (*workflowservice.GetSearchAttributesResponse, error)
- func (m *MockWorkflowServiceClient) GetSystemInfo(ctx context.Context, in *workflowservice.GetSystemInfoRequest, ...) (*workflowservice.GetSystemInfoResponse, error)
- func (m *MockWorkflowServiceClient) GetWorkerBuildIdCompatibility(ctx context.Context, in *workflowservice.GetWorkerBuildIdCompatibilityRequest, ...) (*workflowservice.GetWorkerBuildIdCompatibilityResponse, error)
- func (m *MockWorkflowServiceClient) GetWorkerTaskReachability(ctx context.Context, in *workflowservice.GetWorkerTaskReachabilityRequest, ...) (*workflowservice.GetWorkerTaskReachabilityResponse, error)
- func (m *MockWorkflowServiceClient) GetWorkerVersioningRules(ctx context.Context, in *workflowservice.GetWorkerVersioningRulesRequest, ...) (*workflowservice.GetWorkerVersioningRulesResponse, error)
- func (m *MockWorkflowServiceClient) GetWorkflowExecutionHistory(ctx context.Context, in *workflowservice.GetWorkflowExecutionHistoryRequest, ...) (*workflowservice.GetWorkflowExecutionHistoryResponse, error)
- func (m *MockWorkflowServiceClient) GetWorkflowExecutionHistoryReverse(ctx context.Context, ...) (*workflowservice.GetWorkflowExecutionHistoryReverseResponse, error)
- func (m *MockWorkflowServiceClient) ListArchivedWorkflowExecutions(ctx context.Context, in *workflowservice.ListArchivedWorkflowExecutionsRequest, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceClient) ListBatchOperations(ctx context.Context, in *workflowservice.ListBatchOperationsRequest, ...) (*workflowservice.ListBatchOperationsResponse, error)
- func (m *MockWorkflowServiceClient) ListClosedWorkflowExecutions(ctx context.Context, in *workflowservice.ListClosedWorkflowExecutionsRequest, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceClient) ListDeployments(ctx context.Context, in *workflowservice.ListDeploymentsRequest, ...) (*workflowservice.ListDeploymentsResponse, error)
- func (m *MockWorkflowServiceClient) ListNamespaces(ctx context.Context, in *workflowservice.ListNamespacesRequest, ...) (*workflowservice.ListNamespacesResponse, error)
- func (m *MockWorkflowServiceClient) ListOpenWorkflowExecutions(ctx context.Context, in *workflowservice.ListOpenWorkflowExecutionsRequest, ...) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceClient) ListScheduleMatchingTimes(ctx context.Context, in *workflowservice.ListScheduleMatchingTimesRequest, ...) (*workflowservice.ListScheduleMatchingTimesResponse, error)
- func (m *MockWorkflowServiceClient) ListSchedules(ctx context.Context, in *workflowservice.ListSchedulesRequest, ...) (*workflowservice.ListSchedulesResponse, error)
- func (m *MockWorkflowServiceClient) ListTaskQueuePartitions(ctx context.Context, in *workflowservice.ListTaskQueuePartitionsRequest, ...) (*workflowservice.ListTaskQueuePartitionsResponse, error)
- func (m *MockWorkflowServiceClient) ListWorkflowExecutions(ctx context.Context, in *workflowservice.ListWorkflowExecutionsRequest, ...) (*workflowservice.ListWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceClient) PatchSchedule(ctx context.Context, in *workflowservice.PatchScheduleRequest, ...) (*workflowservice.PatchScheduleResponse, error)
- func (m *MockWorkflowServiceClient) PauseActivityById(ctx context.Context, in *workflowservice.PauseActivityByIdRequest, ...) (*workflowservice.PauseActivityByIdResponse, error)
- func (m *MockWorkflowServiceClient) PollActivityTaskQueue(ctx context.Context, in *workflowservice.PollActivityTaskQueueRequest, ...) (*workflowservice.PollActivityTaskQueueResponse, error)
- func (m *MockWorkflowServiceClient) PollNexusTaskQueue(ctx context.Context, in *workflowservice.PollNexusTaskQueueRequest, ...) (*workflowservice.PollNexusTaskQueueResponse, error)
- func (m *MockWorkflowServiceClient) PollWorkflowExecutionUpdate(ctx context.Context, in *workflowservice.PollWorkflowExecutionUpdateRequest, ...) (*workflowservice.PollWorkflowExecutionUpdateResponse, error)
- func (m *MockWorkflowServiceClient) PollWorkflowTaskQueue(ctx context.Context, in *workflowservice.PollWorkflowTaskQueueRequest, ...) (*workflowservice.PollWorkflowTaskQueueResponse, error)
- func (m *MockWorkflowServiceClient) QueryWorkflow(ctx context.Context, in *workflowservice.QueryWorkflowRequest, ...) (*workflowservice.QueryWorkflowResponse, error)
- func (m *MockWorkflowServiceClient) RecordActivityTaskHeartbeat(ctx context.Context, in *workflowservice.RecordActivityTaskHeartbeatRequest, ...) (*workflowservice.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockWorkflowServiceClient) RecordActivityTaskHeartbeatById(ctx context.Context, ...) (*workflowservice.RecordActivityTaskHeartbeatByIdResponse, error)
- func (m *MockWorkflowServiceClient) RegisterNamespace(ctx context.Context, in *workflowservice.RegisterNamespaceRequest, ...) (*workflowservice.RegisterNamespaceResponse, error)
- func (m *MockWorkflowServiceClient) RequestCancelWorkflowExecution(ctx context.Context, in *workflowservice.RequestCancelWorkflowExecutionRequest, ...) (*workflowservice.RequestCancelWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) ResetActivityById(ctx context.Context, in *workflowservice.ResetActivityByIdRequest, ...) (*workflowservice.ResetActivityByIdResponse, error)
- func (m *MockWorkflowServiceClient) ResetStickyTaskQueue(ctx context.Context, in *workflowservice.ResetStickyTaskQueueRequest, ...) (*workflowservice.ResetStickyTaskQueueResponse, error)
- func (m *MockWorkflowServiceClient) ResetWorkflowExecution(ctx context.Context, in *workflowservice.ResetWorkflowExecutionRequest, ...) (*workflowservice.ResetWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) RespondActivityTaskCanceled(ctx context.Context, in *workflowservice.RespondActivityTaskCanceledRequest, ...) (*workflowservice.RespondActivityTaskCanceledResponse, error)
- func (m *MockWorkflowServiceClient) RespondActivityTaskCanceledById(ctx context.Context, ...) (*workflowservice.RespondActivityTaskCanceledByIdResponse, error)
- func (m *MockWorkflowServiceClient) RespondActivityTaskCompleted(ctx context.Context, in *workflowservice.RespondActivityTaskCompletedRequest, ...) (*workflowservice.RespondActivityTaskCompletedResponse, error)
- func (m *MockWorkflowServiceClient) RespondActivityTaskCompletedById(ctx context.Context, ...) (*workflowservice.RespondActivityTaskCompletedByIdResponse, error)
- func (m *MockWorkflowServiceClient) RespondActivityTaskFailed(ctx context.Context, in *workflowservice.RespondActivityTaskFailedRequest, ...) (*workflowservice.RespondActivityTaskFailedResponse, error)
- func (m *MockWorkflowServiceClient) RespondActivityTaskFailedById(ctx context.Context, in *workflowservice.RespondActivityTaskFailedByIdRequest, ...) (*workflowservice.RespondActivityTaskFailedByIdResponse, error)
- func (m *MockWorkflowServiceClient) RespondNexusTaskCompleted(ctx context.Context, in *workflowservice.RespondNexusTaskCompletedRequest, ...) (*workflowservice.RespondNexusTaskCompletedResponse, error)
- func (m *MockWorkflowServiceClient) RespondNexusTaskFailed(ctx context.Context, in *workflowservice.RespondNexusTaskFailedRequest, ...) (*workflowservice.RespondNexusTaskFailedResponse, error)
- func (m *MockWorkflowServiceClient) RespondQueryTaskCompleted(ctx context.Context, in *workflowservice.RespondQueryTaskCompletedRequest, ...) (*workflowservice.RespondQueryTaskCompletedResponse, error)
- func (m *MockWorkflowServiceClient) RespondWorkflowTaskCompleted(ctx context.Context, in *workflowservice.RespondWorkflowTaskCompletedRequest, ...) (*workflowservice.RespondWorkflowTaskCompletedResponse, error)
- func (m *MockWorkflowServiceClient) RespondWorkflowTaskFailed(ctx context.Context, in *workflowservice.RespondWorkflowTaskFailedRequest, ...) (*workflowservice.RespondWorkflowTaskFailedResponse, error)
- func (m *MockWorkflowServiceClient) ScanWorkflowExecutions(ctx context.Context, in *workflowservice.ScanWorkflowExecutionsRequest, ...) (*workflowservice.ScanWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceClient) SetCurrentDeployment(ctx context.Context, in *workflowservice.SetCurrentDeploymentRequest, ...) (*workflowservice.SetCurrentDeploymentResponse, error)
- func (m *MockWorkflowServiceClient) ShutdownWorker(ctx context.Context, in *workflowservice.ShutdownWorkerRequest, ...) (*workflowservice.ShutdownWorkerResponse, error)
- func (m *MockWorkflowServiceClient) SignalWithStartWorkflowExecution(ctx context.Context, ...) (*workflowservice.SignalWithStartWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) SignalWorkflowExecution(ctx context.Context, in *workflowservice.SignalWorkflowExecutionRequest, ...) (*workflowservice.SignalWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) StartBatchOperation(ctx context.Context, in *workflowservice.StartBatchOperationRequest, ...) (*workflowservice.StartBatchOperationResponse, error)
- func (m *MockWorkflowServiceClient) StartWorkflowExecution(ctx context.Context, in *workflowservice.StartWorkflowExecutionRequest, ...) (*workflowservice.StartWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) StopBatchOperation(ctx context.Context, in *workflowservice.StopBatchOperationRequest, ...) (*workflowservice.StopBatchOperationResponse, error)
- func (m *MockWorkflowServiceClient) TerminateWorkflowExecution(ctx context.Context, in *workflowservice.TerminateWorkflowExecutionRequest, ...) (*workflowservice.TerminateWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) UnpauseActivityById(ctx context.Context, in *workflowservice.UnpauseActivityByIdRequest, ...) (*workflowservice.UnpauseActivityByIdResponse, error)
- func (m *MockWorkflowServiceClient) UpdateActivityOptionsById(ctx context.Context, in *workflowservice.UpdateActivityOptionsByIdRequest, ...) (*workflowservice.UpdateActivityOptionsByIdResponse, error)
- func (m *MockWorkflowServiceClient) UpdateNamespace(ctx context.Context, in *workflowservice.UpdateNamespaceRequest, ...) (*workflowservice.UpdateNamespaceResponse, error)
- func (m *MockWorkflowServiceClient) UpdateSchedule(ctx context.Context, in *workflowservice.UpdateScheduleRequest, ...) (*workflowservice.UpdateScheduleResponse, error)
- func (m *MockWorkflowServiceClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, ...) (*workflowservice.UpdateWorkerBuildIdCompatibilityResponse, error)
- func (m *MockWorkflowServiceClient) UpdateWorkerVersioningRules(ctx context.Context, in *workflowservice.UpdateWorkerVersioningRulesRequest, ...) (*workflowservice.UpdateWorkerVersioningRulesResponse, error)
- func (m *MockWorkflowServiceClient) UpdateWorkflowExecution(ctx context.Context, in *workflowservice.UpdateWorkflowExecutionRequest, ...) (*workflowservice.UpdateWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceClient) UpdateWorkflowExecutionOptions(ctx context.Context, in *workflowservice.UpdateWorkflowExecutionOptionsRequest, ...) (*workflowservice.UpdateWorkflowExecutionOptionsResponse, error)
- type MockWorkflowServiceClientMockRecorder
- func (mr *MockWorkflowServiceClientMockRecorder) CountWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) CreateSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DeleteSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DeleteWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DeprecateNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DescribeBatchOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DescribeDeployment(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DescribeNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DescribeSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DescribeTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) DescribeWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ExecuteMultiOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetClusterInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetCurrentDeployment(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetDeploymentReachability(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetSearchAttributes(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetSystemInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerTaskReachability(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerVersioningRules(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetWorkflowExecutionHistory(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) GetWorkflowExecutionHistoryReverse(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListArchivedWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListBatchOperations(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListClosedWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListDeployments(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListNamespaces(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListOpenWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListScheduleMatchingTimes(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListSchedules(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListTaskQueuePartitions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ListWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) PatchSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) PauseActivityById(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) PollActivityTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) PollNexusTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) PollWorkflowExecutionUpdate(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) PollWorkflowTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) QueryWorkflow(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RecordActivityTaskHeartbeat(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RecordActivityTaskHeartbeatById(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RegisterNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RequestCancelWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ResetActivityById(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ResetStickyTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ResetWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCanceled(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCanceledById(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCompletedById(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskFailedById(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondNexusTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondNexusTaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondQueryTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondWorkflowTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) RespondWorkflowTaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ScanWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) SetCurrentDeployment(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) ShutdownWorker(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) SignalWithStartWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) SignalWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) StartBatchOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) StartWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) StopBatchOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) TerminateWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) UnpauseActivityById(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) UpdateActivityOptionsById(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) UpdateNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) UpdateSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkerVersioningRules(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkflowExecutionOptions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockWorkflowServiceServer
- func (m *MockWorkflowServiceServer) CountWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceServer) CreateSchedule(arg0 context.Context, arg1 *workflowservice.CreateScheduleRequest) (*workflowservice.CreateScheduleResponse, error)
- func (m *MockWorkflowServiceServer) DeleteSchedule(arg0 context.Context, arg1 *workflowservice.DeleteScheduleRequest) (*workflowservice.DeleteScheduleResponse, error)
- func (m *MockWorkflowServiceServer) DeleteWorkflowExecution(arg0 context.Context, arg1 *workflowservice.DeleteWorkflowExecutionRequest) (*workflowservice.DeleteWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) DeprecateNamespace(arg0 context.Context, arg1 *workflowservice.DeprecateNamespaceRequest) (*workflowservice.DeprecateNamespaceResponse, error)
- func (m *MockWorkflowServiceServer) DescribeBatchOperation(arg0 context.Context, arg1 *workflowservice.DescribeBatchOperationRequest) (*workflowservice.DescribeBatchOperationResponse, error)
- func (m *MockWorkflowServiceServer) DescribeDeployment(arg0 context.Context, arg1 *workflowservice.DescribeDeploymentRequest) (*workflowservice.DescribeDeploymentResponse, error)
- func (m *MockWorkflowServiceServer) DescribeNamespace(arg0 context.Context, arg1 *workflowservice.DescribeNamespaceRequest) (*workflowservice.DescribeNamespaceResponse, error)
- func (m *MockWorkflowServiceServer) DescribeSchedule(arg0 context.Context, arg1 *workflowservice.DescribeScheduleRequest) (*workflowservice.DescribeScheduleResponse, error)
- func (m *MockWorkflowServiceServer) DescribeTaskQueue(arg0 context.Context, arg1 *workflowservice.DescribeTaskQueueRequest) (*workflowservice.DescribeTaskQueueResponse, error)
- func (m *MockWorkflowServiceServer) DescribeWorkflowExecution(arg0 context.Context, arg1 *workflowservice.DescribeWorkflowExecutionRequest) (*workflowservice.DescribeWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) EXPECT() *MockWorkflowServiceServerMockRecorder
- func (m *MockWorkflowServiceServer) ExecuteMultiOperation(arg0 context.Context, arg1 *workflowservice.ExecuteMultiOperationRequest) (*workflowservice.ExecuteMultiOperationResponse, error)
- func (m *MockWorkflowServiceServer) GetClusterInfo(arg0 context.Context, arg1 *workflowservice.GetClusterInfoRequest) (*workflowservice.GetClusterInfoResponse, error)
- func (m *MockWorkflowServiceServer) GetCurrentDeployment(arg0 context.Context, arg1 *workflowservice.GetCurrentDeploymentRequest) (*workflowservice.GetCurrentDeploymentResponse, error)
- func (m *MockWorkflowServiceServer) GetDeploymentReachability(arg0 context.Context, arg1 *workflowservice.GetDeploymentReachabilityRequest) (*workflowservice.GetDeploymentReachabilityResponse, error)
- func (m *MockWorkflowServiceServer) GetSearchAttributes(arg0 context.Context, arg1 *workflowservice.GetSearchAttributesRequest) (*workflowservice.GetSearchAttributesResponse, error)
- func (m *MockWorkflowServiceServer) GetSystemInfo(arg0 context.Context, arg1 *workflowservice.GetSystemInfoRequest) (*workflowservice.GetSystemInfoResponse, error)
- func (m *MockWorkflowServiceServer) GetWorkerBuildIdCompatibility(arg0 context.Context, ...) (*workflowservice.GetWorkerBuildIdCompatibilityResponse, error)
- func (m *MockWorkflowServiceServer) GetWorkerTaskReachability(arg0 context.Context, arg1 *workflowservice.GetWorkerTaskReachabilityRequest) (*workflowservice.GetWorkerTaskReachabilityResponse, error)
- func (m *MockWorkflowServiceServer) GetWorkerVersioningRules(arg0 context.Context, arg1 *workflowservice.GetWorkerVersioningRulesRequest) (*workflowservice.GetWorkerVersioningRulesResponse, error)
- func (m *MockWorkflowServiceServer) GetWorkflowExecutionHistory(arg0 context.Context, arg1 *workflowservice.GetWorkflowExecutionHistoryRequest) (*workflowservice.GetWorkflowExecutionHistoryResponse, error)
- func (m *MockWorkflowServiceServer) GetWorkflowExecutionHistoryReverse(arg0 context.Context, ...) (*workflowservice.GetWorkflowExecutionHistoryReverseResponse, error)
- func (m *MockWorkflowServiceServer) ListArchivedWorkflowExecutions(arg0 context.Context, ...) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceServer) ListBatchOperations(arg0 context.Context, arg1 *workflowservice.ListBatchOperationsRequest) (*workflowservice.ListBatchOperationsResponse, error)
- func (m *MockWorkflowServiceServer) ListClosedWorkflowExecutions(arg0 context.Context, ...) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceServer) ListDeployments(arg0 context.Context, arg1 *workflowservice.ListDeploymentsRequest) (*workflowservice.ListDeploymentsResponse, error)
- func (m *MockWorkflowServiceServer) ListNamespaces(arg0 context.Context, arg1 *workflowservice.ListNamespacesRequest) (*workflowservice.ListNamespacesResponse, error)
- func (m *MockWorkflowServiceServer) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceServer) ListScheduleMatchingTimes(arg0 context.Context, arg1 *workflowservice.ListScheduleMatchingTimesRequest) (*workflowservice.ListScheduleMatchingTimesResponse, error)
- func (m *MockWorkflowServiceServer) ListSchedules(arg0 context.Context, arg1 *workflowservice.ListSchedulesRequest) (*workflowservice.ListSchedulesResponse, error)
- func (m *MockWorkflowServiceServer) ListTaskQueuePartitions(arg0 context.Context, arg1 *workflowservice.ListTaskQueuePartitionsRequest) (*workflowservice.ListTaskQueuePartitionsResponse, error)
- func (m *MockWorkflowServiceServer) ListWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceServer) PatchSchedule(arg0 context.Context, arg1 *workflowservice.PatchScheduleRequest) (*workflowservice.PatchScheduleResponse, error)
- func (m *MockWorkflowServiceServer) PauseActivityById(arg0 context.Context, arg1 *workflowservice.PauseActivityByIdRequest) (*workflowservice.PauseActivityByIdResponse, error)
- func (m *MockWorkflowServiceServer) PollActivityTaskQueue(arg0 context.Context, arg1 *workflowservice.PollActivityTaskQueueRequest) (*workflowservice.PollActivityTaskQueueResponse, error)
- func (m *MockWorkflowServiceServer) PollNexusTaskQueue(arg0 context.Context, arg1 *workflowservice.PollNexusTaskQueueRequest) (*workflowservice.PollNexusTaskQueueResponse, error)
- func (m *MockWorkflowServiceServer) PollWorkflowExecutionUpdate(arg0 context.Context, arg1 *workflowservice.PollWorkflowExecutionUpdateRequest) (*workflowservice.PollWorkflowExecutionUpdateResponse, error)
- func (m *MockWorkflowServiceServer) PollWorkflowTaskQueue(arg0 context.Context, arg1 *workflowservice.PollWorkflowTaskQueueRequest) (*workflowservice.PollWorkflowTaskQueueResponse, error)
- func (m *MockWorkflowServiceServer) QueryWorkflow(arg0 context.Context, arg1 *workflowservice.QueryWorkflowRequest) (*workflowservice.QueryWorkflowResponse, error)
- func (m *MockWorkflowServiceServer) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *workflowservice.RecordActivityTaskHeartbeatRequest) (*workflowservice.RecordActivityTaskHeartbeatResponse, error)
- func (m *MockWorkflowServiceServer) RecordActivityTaskHeartbeatById(arg0 context.Context, ...) (*workflowservice.RecordActivityTaskHeartbeatByIdResponse, error)
- func (m *MockWorkflowServiceServer) RegisterNamespace(arg0 context.Context, arg1 *workflowservice.RegisterNamespaceRequest) (*workflowservice.RegisterNamespaceResponse, error)
- func (m *MockWorkflowServiceServer) RequestCancelWorkflowExecution(arg0 context.Context, ...) (*workflowservice.RequestCancelWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) ResetActivityById(arg0 context.Context, arg1 *workflowservice.ResetActivityByIdRequest) (*workflowservice.ResetActivityByIdResponse, error)
- func (m *MockWorkflowServiceServer) ResetStickyTaskQueue(arg0 context.Context, arg1 *workflowservice.ResetStickyTaskQueueRequest) (*workflowservice.ResetStickyTaskQueueResponse, error)
- func (m *MockWorkflowServiceServer) ResetWorkflowExecution(arg0 context.Context, arg1 *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) RespondActivityTaskCanceled(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCanceledRequest) (*workflowservice.RespondActivityTaskCanceledResponse, error)
- func (m *MockWorkflowServiceServer) RespondActivityTaskCanceledById(arg0 context.Context, ...) (*workflowservice.RespondActivityTaskCanceledByIdResponse, error)
- func (m *MockWorkflowServiceServer) RespondActivityTaskCompleted(arg0 context.Context, ...) (*workflowservice.RespondActivityTaskCompletedResponse, error)
- func (m *MockWorkflowServiceServer) RespondActivityTaskCompletedById(arg0 context.Context, ...) (*workflowservice.RespondActivityTaskCompletedByIdResponse, error)
- func (m *MockWorkflowServiceServer) RespondActivityTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskFailedRequest) (*workflowservice.RespondActivityTaskFailedResponse, error)
- func (m *MockWorkflowServiceServer) RespondActivityTaskFailedById(arg0 context.Context, ...) (*workflowservice.RespondActivityTaskFailedByIdResponse, error)
- func (m *MockWorkflowServiceServer) RespondNexusTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondNexusTaskCompletedRequest) (*workflowservice.RespondNexusTaskCompletedResponse, error)
- func (m *MockWorkflowServiceServer) RespondNexusTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondNexusTaskFailedRequest) (*workflowservice.RespondNexusTaskFailedResponse, error)
- func (m *MockWorkflowServiceServer) RespondQueryTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondQueryTaskCompletedRequest) (*workflowservice.RespondQueryTaskCompletedResponse, error)
- func (m *MockWorkflowServiceServer) RespondWorkflowTaskCompleted(arg0 context.Context, ...) (*workflowservice.RespondWorkflowTaskCompletedResponse, error)
- func (m *MockWorkflowServiceServer) RespondWorkflowTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondWorkflowTaskFailedRequest) (*workflowservice.RespondWorkflowTaskFailedResponse, error)
- func (m *MockWorkflowServiceServer) ScanWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)
- func (m *MockWorkflowServiceServer) SetCurrentDeployment(arg0 context.Context, arg1 *workflowservice.SetCurrentDeploymentRequest) (*workflowservice.SetCurrentDeploymentResponse, error)
- func (m *MockWorkflowServiceServer) ShutdownWorker(arg0 context.Context, arg1 *workflowservice.ShutdownWorkerRequest) (*workflowservice.ShutdownWorkerResponse, error)
- func (m *MockWorkflowServiceServer) SignalWithStartWorkflowExecution(arg0 context.Context, ...) (*workflowservice.SignalWithStartWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) SignalWorkflowExecution(arg0 context.Context, arg1 *workflowservice.SignalWorkflowExecutionRequest) (*workflowservice.SignalWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) StartBatchOperation(arg0 context.Context, arg1 *workflowservice.StartBatchOperationRequest) (*workflowservice.StartBatchOperationResponse, error)
- func (m *MockWorkflowServiceServer) StartWorkflowExecution(arg0 context.Context, arg1 *workflowservice.StartWorkflowExecutionRequest) (*workflowservice.StartWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) StopBatchOperation(arg0 context.Context, arg1 *workflowservice.StopBatchOperationRequest) (*workflowservice.StopBatchOperationResponse, error)
- func (m *MockWorkflowServiceServer) TerminateWorkflowExecution(arg0 context.Context, arg1 *workflowservice.TerminateWorkflowExecutionRequest) (*workflowservice.TerminateWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) UnpauseActivityById(arg0 context.Context, arg1 *workflowservice.UnpauseActivityByIdRequest) (*workflowservice.UnpauseActivityByIdResponse, error)
- func (m *MockWorkflowServiceServer) UpdateActivityOptionsById(arg0 context.Context, arg1 *workflowservice.UpdateActivityOptionsByIdRequest) (*workflowservice.UpdateActivityOptionsByIdResponse, error)
- func (m *MockWorkflowServiceServer) UpdateNamespace(arg0 context.Context, arg1 *workflowservice.UpdateNamespaceRequest) (*workflowservice.UpdateNamespaceResponse, error)
- func (m *MockWorkflowServiceServer) UpdateSchedule(arg0 context.Context, arg1 *workflowservice.UpdateScheduleRequest) (*workflowservice.UpdateScheduleResponse, error)
- func (m *MockWorkflowServiceServer) UpdateWorkerBuildIdCompatibility(arg0 context.Context, ...) (*workflowservice.UpdateWorkerBuildIdCompatibilityResponse, error)
- func (m *MockWorkflowServiceServer) UpdateWorkerVersioningRules(arg0 context.Context, arg1 *workflowservice.UpdateWorkerVersioningRulesRequest) (*workflowservice.UpdateWorkerVersioningRulesResponse, error)
- func (m *MockWorkflowServiceServer) UpdateWorkflowExecution(arg0 context.Context, arg1 *workflowservice.UpdateWorkflowExecutionRequest) (*workflowservice.UpdateWorkflowExecutionResponse, error)
- func (m *MockWorkflowServiceServer) UpdateWorkflowExecutionOptions(arg0 context.Context, ...) (*workflowservice.UpdateWorkflowExecutionOptionsResponse, error)
- type MockWorkflowServiceServerMockRecorder
- func (mr *MockWorkflowServiceServerMockRecorder) CountWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) CreateSchedule(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DeleteSchedule(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DeprecateNamespace(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DescribeBatchOperation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DescribeDeployment(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DescribeNamespace(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DescribeSchedule(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DescribeTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ExecuteMultiOperation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetClusterInfo(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetCurrentDeployment(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetDeploymentReachability(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetSearchAttributes(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetSystemInfo(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetWorkerTaskReachability(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetWorkerVersioningRules(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetWorkflowExecutionHistory(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) GetWorkflowExecutionHistoryReverse(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListArchivedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListBatchOperations(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListDeployments(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListNamespaces(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListScheduleMatchingTimes(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListSchedules(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListTaskQueuePartitions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ListWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) PatchSchedule(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) PauseActivityById(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) PollActivityTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) PollNexusTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) PollWorkflowExecutionUpdate(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) PollWorkflowTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) QueryWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RecordActivityTaskHeartbeatById(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RegisterNamespace(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ResetActivityById(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ResetStickyTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskCanceledById(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskCompletedById(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskFailedById(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondNexusTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondNexusTaskFailed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondQueryTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondWorkflowTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) RespondWorkflowTaskFailed(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ScanWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) SetCurrentDeployment(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) ShutdownWorker(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) StartBatchOperation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) StopBatchOperation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) UnpauseActivityById(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) UpdateActivityOptionsById(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) UpdateNamespace(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) UpdateSchedule(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) UpdateWorkerVersioningRules(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) UpdateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockWorkflowServiceServerMockRecorder) UpdateWorkflowExecutionOptions(arg0, arg1 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockUnsafeWorkflowServiceServer ¶ added in v1.26.1
type MockUnsafeWorkflowServiceServer struct {
// contains filtered or unexported fields
}
MockUnsafeWorkflowServiceServer is a mock of UnsafeWorkflowServiceServer interface.
func NewMockUnsafeWorkflowServiceServer ¶ added in v1.26.1
func NewMockUnsafeWorkflowServiceServer(ctrl *gomock.Controller) *MockUnsafeWorkflowServiceServer
NewMockUnsafeWorkflowServiceServer creates a new mock instance.
func (*MockUnsafeWorkflowServiceServer) EXPECT ¶ added in v1.26.1
func (m *MockUnsafeWorkflowServiceServer) EXPECT() *MockUnsafeWorkflowServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeWorkflowServiceServerMockRecorder ¶ added in v1.26.1
type MockUnsafeWorkflowServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeWorkflowServiceServerMockRecorder is the mock recorder for MockUnsafeWorkflowServiceServer.
type MockWorkflowServiceClient ¶
type MockWorkflowServiceClient struct {
// contains filtered or unexported fields
}
MockWorkflowServiceClient is a mock of WorkflowServiceClient interface.
func NewMockWorkflowServiceClient ¶
func NewMockWorkflowServiceClient(ctrl *gomock.Controller) *MockWorkflowServiceClient
NewMockWorkflowServiceClient creates a new mock instance.
func (*MockWorkflowServiceClient) CountWorkflowExecutions ¶
func (m *MockWorkflowServiceClient) CountWorkflowExecutions(ctx context.Context, in *workflowservice.CountWorkflowExecutionsRequest, opts ...grpc.CallOption) (*workflowservice.CountWorkflowExecutionsResponse, error)
CountWorkflowExecutions mocks base method.
func (*MockWorkflowServiceClient) CreateSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) CreateSchedule(ctx context.Context, in *workflowservice.CreateScheduleRequest, opts ...grpc.CallOption) (*workflowservice.CreateScheduleResponse, error)
CreateSchedule mocks base method.
func (*MockWorkflowServiceClient) DeleteSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) DeleteSchedule(ctx context.Context, in *workflowservice.DeleteScheduleRequest, opts ...grpc.CallOption) (*workflowservice.DeleteScheduleResponse, error)
DeleteSchedule mocks base method.
func (*MockWorkflowServiceClient) DeleteWorkflowExecution ¶ added in v1.12.0
func (m *MockWorkflowServiceClient) DeleteWorkflowExecution(ctx context.Context, in *workflowservice.DeleteWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.DeleteWorkflowExecutionResponse, error)
DeleteWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) DeprecateNamespace ¶
func (m *MockWorkflowServiceClient) DeprecateNamespace(ctx context.Context, in *workflowservice.DeprecateNamespaceRequest, opts ...grpc.CallOption) (*workflowservice.DeprecateNamespaceResponse, error)
DeprecateNamespace mocks base method.
func (*MockWorkflowServiceClient) DescribeBatchOperation ¶ added in v1.12.0
func (m *MockWorkflowServiceClient) DescribeBatchOperation(ctx context.Context, in *workflowservice.DescribeBatchOperationRequest, opts ...grpc.CallOption) (*workflowservice.DescribeBatchOperationResponse, error)
DescribeBatchOperation mocks base method.
func (*MockWorkflowServiceClient) DescribeDeployment ¶ added in v1.43.0
func (m *MockWorkflowServiceClient) DescribeDeployment(ctx context.Context, in *workflowservice.DescribeDeploymentRequest, opts ...grpc.CallOption) (*workflowservice.DescribeDeploymentResponse, error)
DescribeDeployment mocks base method.
func (*MockWorkflowServiceClient) DescribeNamespace ¶
func (m *MockWorkflowServiceClient) DescribeNamespace(ctx context.Context, in *workflowservice.DescribeNamespaceRequest, opts ...grpc.CallOption) (*workflowservice.DescribeNamespaceResponse, error)
DescribeNamespace mocks base method.
func (*MockWorkflowServiceClient) DescribeSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) DescribeSchedule(ctx context.Context, in *workflowservice.DescribeScheduleRequest, opts ...grpc.CallOption) (*workflowservice.DescribeScheduleResponse, error)
DescribeSchedule mocks base method.
func (*MockWorkflowServiceClient) DescribeTaskQueue ¶
func (m *MockWorkflowServiceClient) DescribeTaskQueue(ctx context.Context, in *workflowservice.DescribeTaskQueueRequest, opts ...grpc.CallOption) (*workflowservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue mocks base method.
func (*MockWorkflowServiceClient) DescribeWorkflowExecution ¶
func (m *MockWorkflowServiceClient) DescribeWorkflowExecution(ctx context.Context, in *workflowservice.DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) EXPECT ¶
func (m *MockWorkflowServiceClient) EXPECT() *MockWorkflowServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockWorkflowServiceClient) ExecuteMultiOperation ¶ added in v1.32.1
func (m *MockWorkflowServiceClient) ExecuteMultiOperation(ctx context.Context, in *workflowservice.ExecuteMultiOperationRequest, opts ...grpc.CallOption) (*workflowservice.ExecuteMultiOperationResponse, error)
ExecuteMultiOperation mocks base method.
func (*MockWorkflowServiceClient) GetClusterInfo ¶
func (m *MockWorkflowServiceClient) GetClusterInfo(ctx context.Context, in *workflowservice.GetClusterInfoRequest, opts ...grpc.CallOption) (*workflowservice.GetClusterInfoResponse, error)
GetClusterInfo mocks base method.
func (*MockWorkflowServiceClient) GetCurrentDeployment ¶ added in v1.43.0
func (m *MockWorkflowServiceClient) GetCurrentDeployment(ctx context.Context, in *workflowservice.GetCurrentDeploymentRequest, opts ...grpc.CallOption) (*workflowservice.GetCurrentDeploymentResponse, error)
GetCurrentDeployment mocks base method.
func (*MockWorkflowServiceClient) GetDeploymentReachability ¶ added in v1.43.0
func (m *MockWorkflowServiceClient) GetDeploymentReachability(ctx context.Context, in *workflowservice.GetDeploymentReachabilityRequest, opts ...grpc.CallOption) (*workflowservice.GetDeploymentReachabilityResponse, error)
GetDeploymentReachability mocks base method.
func (*MockWorkflowServiceClient) GetSearchAttributes ¶
func (m *MockWorkflowServiceClient) GetSearchAttributes(ctx context.Context, in *workflowservice.GetSearchAttributesRequest, opts ...grpc.CallOption) (*workflowservice.GetSearchAttributesResponse, error)
GetSearchAttributes mocks base method.
func (*MockWorkflowServiceClient) GetSystemInfo ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) GetSystemInfo(ctx context.Context, in *workflowservice.GetSystemInfoRequest, opts ...grpc.CallOption) (*workflowservice.GetSystemInfoResponse, error)
GetSystemInfo mocks base method.
func (*MockWorkflowServiceClient) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockWorkflowServiceClient) GetWorkerBuildIdCompatibility(ctx context.Context, in *workflowservice.GetWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption) (*workflowservice.GetWorkerBuildIdCompatibilityResponse, error)
GetWorkerBuildIdCompatibility mocks base method.
func (*MockWorkflowServiceClient) GetWorkerTaskReachability ¶ added in v1.21.0
func (m *MockWorkflowServiceClient) GetWorkerTaskReachability(ctx context.Context, in *workflowservice.GetWorkerTaskReachabilityRequest, opts ...grpc.CallOption) (*workflowservice.GetWorkerTaskReachabilityResponse, error)
GetWorkerTaskReachability mocks base method.
func (*MockWorkflowServiceClient) GetWorkerVersioningRules ¶ added in v1.32.0
func (m *MockWorkflowServiceClient) GetWorkerVersioningRules(ctx context.Context, in *workflowservice.GetWorkerVersioningRulesRequest, opts ...grpc.CallOption) (*workflowservice.GetWorkerVersioningRulesResponse, error)
GetWorkerVersioningRules mocks base method.
func (*MockWorkflowServiceClient) GetWorkflowExecutionHistory ¶
func (m *MockWorkflowServiceClient) GetWorkflowExecutionHistory(ctx context.Context, in *workflowservice.GetWorkflowExecutionHistoryRequest, opts ...grpc.CallOption) (*workflowservice.GetWorkflowExecutionHistoryResponse, error)
GetWorkflowExecutionHistory mocks base method.
func (*MockWorkflowServiceClient) GetWorkflowExecutionHistoryReverse ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) GetWorkflowExecutionHistoryReverse(ctx context.Context, in *workflowservice.GetWorkflowExecutionHistoryReverseRequest, opts ...grpc.CallOption) (*workflowservice.GetWorkflowExecutionHistoryReverseResponse, error)
GetWorkflowExecutionHistoryReverse mocks base method.
func (*MockWorkflowServiceClient) ListArchivedWorkflowExecutions ¶
func (m *MockWorkflowServiceClient) ListArchivedWorkflowExecutions(ctx context.Context, in *workflowservice.ListArchivedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
ListArchivedWorkflowExecutions mocks base method.
func (*MockWorkflowServiceClient) ListBatchOperations ¶ added in v1.12.0
func (m *MockWorkflowServiceClient) ListBatchOperations(ctx context.Context, in *workflowservice.ListBatchOperationsRequest, opts ...grpc.CallOption) (*workflowservice.ListBatchOperationsResponse, error)
ListBatchOperations mocks base method.
func (*MockWorkflowServiceClient) ListClosedWorkflowExecutions ¶
func (m *MockWorkflowServiceClient) ListClosedWorkflowExecutions(ctx context.Context, in *workflowservice.ListClosedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutions mocks base method.
func (*MockWorkflowServiceClient) ListDeployments ¶ added in v1.43.0
func (m *MockWorkflowServiceClient) ListDeployments(ctx context.Context, in *workflowservice.ListDeploymentsRequest, opts ...grpc.CallOption) (*workflowservice.ListDeploymentsResponse, error)
ListDeployments mocks base method.
func (*MockWorkflowServiceClient) ListNamespaces ¶
func (m *MockWorkflowServiceClient) ListNamespaces(ctx context.Context, in *workflowservice.ListNamespacesRequest, opts ...grpc.CallOption) (*workflowservice.ListNamespacesResponse, error)
ListNamespaces mocks base method.
func (*MockWorkflowServiceClient) ListOpenWorkflowExecutions ¶
func (m *MockWorkflowServiceClient) ListOpenWorkflowExecutions(ctx context.Context, in *workflowservice.ListOpenWorkflowExecutionsRequest, opts ...grpc.CallOption) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutions mocks base method.
func (*MockWorkflowServiceClient) ListScheduleMatchingTimes ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) ListScheduleMatchingTimes(ctx context.Context, in *workflowservice.ListScheduleMatchingTimesRequest, opts ...grpc.CallOption) (*workflowservice.ListScheduleMatchingTimesResponse, error)
ListScheduleMatchingTimes mocks base method.
func (*MockWorkflowServiceClient) ListSchedules ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) ListSchedules(ctx context.Context, in *workflowservice.ListSchedulesRequest, opts ...grpc.CallOption) (*workflowservice.ListSchedulesResponse, error)
ListSchedules mocks base method.
func (*MockWorkflowServiceClient) ListTaskQueuePartitions ¶
func (m *MockWorkflowServiceClient) ListTaskQueuePartitions(ctx context.Context, in *workflowservice.ListTaskQueuePartitionsRequest, opts ...grpc.CallOption) (*workflowservice.ListTaskQueuePartitionsResponse, error)
ListTaskQueuePartitions mocks base method.
func (*MockWorkflowServiceClient) ListWorkflowExecutions ¶
func (m *MockWorkflowServiceClient) ListWorkflowExecutions(ctx context.Context, in *workflowservice.ListWorkflowExecutionsRequest, opts ...grpc.CallOption) (*workflowservice.ListWorkflowExecutionsResponse, error)
ListWorkflowExecutions mocks base method.
func (*MockWorkflowServiceClient) PatchSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) PatchSchedule(ctx context.Context, in *workflowservice.PatchScheduleRequest, opts ...grpc.CallOption) (*workflowservice.PatchScheduleResponse, error)
PatchSchedule mocks base method.
func (*MockWorkflowServiceClient) PauseActivityById ¶ added in v1.41.0
func (m *MockWorkflowServiceClient) PauseActivityById(ctx context.Context, in *workflowservice.PauseActivityByIdRequest, opts ...grpc.CallOption) (*workflowservice.PauseActivityByIdResponse, error)
PauseActivityById mocks base method.
func (*MockWorkflowServiceClient) PollActivityTaskQueue ¶
func (m *MockWorkflowServiceClient) PollActivityTaskQueue(ctx context.Context, in *workflowservice.PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*workflowservice.PollActivityTaskQueueResponse, error)
PollActivityTaskQueue mocks base method.
func (*MockWorkflowServiceClient) PollNexusTaskQueue ¶ added in v1.27.0
func (m *MockWorkflowServiceClient) PollNexusTaskQueue(ctx context.Context, in *workflowservice.PollNexusTaskQueueRequest, opts ...grpc.CallOption) (*workflowservice.PollNexusTaskQueueResponse, error)
PollNexusTaskQueue mocks base method.
func (*MockWorkflowServiceClient) PollWorkflowExecutionUpdate ¶ added in v1.21.0
func (m *MockWorkflowServiceClient) PollWorkflowExecutionUpdate(ctx context.Context, in *workflowservice.PollWorkflowExecutionUpdateRequest, opts ...grpc.CallOption) (*workflowservice.PollWorkflowExecutionUpdateResponse, error)
PollWorkflowExecutionUpdate mocks base method.
func (*MockWorkflowServiceClient) PollWorkflowTaskQueue ¶
func (m *MockWorkflowServiceClient) PollWorkflowTaskQueue(ctx context.Context, in *workflowservice.PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*workflowservice.PollWorkflowTaskQueueResponse, error)
PollWorkflowTaskQueue mocks base method.
func (*MockWorkflowServiceClient) QueryWorkflow ¶
func (m *MockWorkflowServiceClient) QueryWorkflow(ctx context.Context, in *workflowservice.QueryWorkflowRequest, opts ...grpc.CallOption) (*workflowservice.QueryWorkflowResponse, error)
QueryWorkflow mocks base method.
func (*MockWorkflowServiceClient) RecordActivityTaskHeartbeat ¶
func (m *MockWorkflowServiceClient) RecordActivityTaskHeartbeat(ctx context.Context, in *workflowservice.RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*workflowservice.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat mocks base method.
func (*MockWorkflowServiceClient) RecordActivityTaskHeartbeatById ¶
func (m *MockWorkflowServiceClient) RecordActivityTaskHeartbeatById(ctx context.Context, in *workflowservice.RecordActivityTaskHeartbeatByIdRequest, opts ...grpc.CallOption) (*workflowservice.RecordActivityTaskHeartbeatByIdResponse, error)
RecordActivityTaskHeartbeatById mocks base method.
func (*MockWorkflowServiceClient) RegisterNamespace ¶
func (m *MockWorkflowServiceClient) RegisterNamespace(ctx context.Context, in *workflowservice.RegisterNamespaceRequest, opts ...grpc.CallOption) (*workflowservice.RegisterNamespaceResponse, error)
RegisterNamespace mocks base method.
func (*MockWorkflowServiceClient) RequestCancelWorkflowExecution ¶
func (m *MockWorkflowServiceClient) RequestCancelWorkflowExecution(ctx context.Context, in *workflowservice.RequestCancelWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.RequestCancelWorkflowExecutionResponse, error)
RequestCancelWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) ResetActivityById ¶ added in v1.41.0
func (m *MockWorkflowServiceClient) ResetActivityById(ctx context.Context, in *workflowservice.ResetActivityByIdRequest, opts ...grpc.CallOption) (*workflowservice.ResetActivityByIdResponse, error)
ResetActivityById mocks base method.
func (*MockWorkflowServiceClient) ResetStickyTaskQueue ¶
func (m *MockWorkflowServiceClient) ResetStickyTaskQueue(ctx context.Context, in *workflowservice.ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*workflowservice.ResetStickyTaskQueueResponse, error)
ResetStickyTaskQueue mocks base method.
func (*MockWorkflowServiceClient) ResetWorkflowExecution ¶
func (m *MockWorkflowServiceClient) ResetWorkflowExecution(ctx context.Context, in *workflowservice.ResetWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) RespondActivityTaskCanceled ¶
func (m *MockWorkflowServiceClient) RespondActivityTaskCanceled(ctx context.Context, in *workflowservice.RespondActivityTaskCanceledRequest, opts ...grpc.CallOption) (*workflowservice.RespondActivityTaskCanceledResponse, error)
RespondActivityTaskCanceled mocks base method.
func (*MockWorkflowServiceClient) RespondActivityTaskCanceledById ¶
func (m *MockWorkflowServiceClient) RespondActivityTaskCanceledById(ctx context.Context, in *workflowservice.RespondActivityTaskCanceledByIdRequest, opts ...grpc.CallOption) (*workflowservice.RespondActivityTaskCanceledByIdResponse, error)
RespondActivityTaskCanceledById mocks base method.
func (*MockWorkflowServiceClient) RespondActivityTaskCompleted ¶
func (m *MockWorkflowServiceClient) RespondActivityTaskCompleted(ctx context.Context, in *workflowservice.RespondActivityTaskCompletedRequest, opts ...grpc.CallOption) (*workflowservice.RespondActivityTaskCompletedResponse, error)
RespondActivityTaskCompleted mocks base method.
func (*MockWorkflowServiceClient) RespondActivityTaskCompletedById ¶
func (m *MockWorkflowServiceClient) RespondActivityTaskCompletedById(ctx context.Context, in *workflowservice.RespondActivityTaskCompletedByIdRequest, opts ...grpc.CallOption) (*workflowservice.RespondActivityTaskCompletedByIdResponse, error)
RespondActivityTaskCompletedById mocks base method.
func (*MockWorkflowServiceClient) RespondActivityTaskFailed ¶
func (m *MockWorkflowServiceClient) RespondActivityTaskFailed(ctx context.Context, in *workflowservice.RespondActivityTaskFailedRequest, opts ...grpc.CallOption) (*workflowservice.RespondActivityTaskFailedResponse, error)
RespondActivityTaskFailed mocks base method.
func (*MockWorkflowServiceClient) RespondActivityTaskFailedById ¶
func (m *MockWorkflowServiceClient) RespondActivityTaskFailedById(ctx context.Context, in *workflowservice.RespondActivityTaskFailedByIdRequest, opts ...grpc.CallOption) (*workflowservice.RespondActivityTaskFailedByIdResponse, error)
RespondActivityTaskFailedById mocks base method.
func (*MockWorkflowServiceClient) RespondNexusTaskCompleted ¶ added in v1.27.0
func (m *MockWorkflowServiceClient) RespondNexusTaskCompleted(ctx context.Context, in *workflowservice.RespondNexusTaskCompletedRequest, opts ...grpc.CallOption) (*workflowservice.RespondNexusTaskCompletedResponse, error)
RespondNexusTaskCompleted mocks base method.
func (*MockWorkflowServiceClient) RespondNexusTaskFailed ¶ added in v1.27.0
func (m *MockWorkflowServiceClient) RespondNexusTaskFailed(ctx context.Context, in *workflowservice.RespondNexusTaskFailedRequest, opts ...grpc.CallOption) (*workflowservice.RespondNexusTaskFailedResponse, error)
RespondNexusTaskFailed mocks base method.
func (*MockWorkflowServiceClient) RespondQueryTaskCompleted ¶
func (m *MockWorkflowServiceClient) RespondQueryTaskCompleted(ctx context.Context, in *workflowservice.RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*workflowservice.RespondQueryTaskCompletedResponse, error)
RespondQueryTaskCompleted mocks base method.
func (*MockWorkflowServiceClient) RespondWorkflowTaskCompleted ¶
func (m *MockWorkflowServiceClient) RespondWorkflowTaskCompleted(ctx context.Context, in *workflowservice.RespondWorkflowTaskCompletedRequest, opts ...grpc.CallOption) (*workflowservice.RespondWorkflowTaskCompletedResponse, error)
RespondWorkflowTaskCompleted mocks base method.
func (*MockWorkflowServiceClient) RespondWorkflowTaskFailed ¶
func (m *MockWorkflowServiceClient) RespondWorkflowTaskFailed(ctx context.Context, in *workflowservice.RespondWorkflowTaskFailedRequest, opts ...grpc.CallOption) (*workflowservice.RespondWorkflowTaskFailedResponse, error)
RespondWorkflowTaskFailed mocks base method.
func (*MockWorkflowServiceClient) ScanWorkflowExecutions ¶
func (m *MockWorkflowServiceClient) ScanWorkflowExecutions(ctx context.Context, in *workflowservice.ScanWorkflowExecutionsRequest, opts ...grpc.CallOption) (*workflowservice.ScanWorkflowExecutionsResponse, error)
ScanWorkflowExecutions mocks base method.
func (*MockWorkflowServiceClient) SetCurrentDeployment ¶ added in v1.43.0
func (m *MockWorkflowServiceClient) SetCurrentDeployment(ctx context.Context, in *workflowservice.SetCurrentDeploymentRequest, opts ...grpc.CallOption) (*workflowservice.SetCurrentDeploymentResponse, error)
SetCurrentDeployment mocks base method.
func (*MockWorkflowServiceClient) ShutdownWorker ¶ added in v1.39.0
func (m *MockWorkflowServiceClient) ShutdownWorker(ctx context.Context, in *workflowservice.ShutdownWorkerRequest, opts ...grpc.CallOption) (*workflowservice.ShutdownWorkerResponse, error)
ShutdownWorker mocks base method.
func (*MockWorkflowServiceClient) SignalWithStartWorkflowExecution ¶
func (m *MockWorkflowServiceClient) SignalWithStartWorkflowExecution(ctx context.Context, in *workflowservice.SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.SignalWithStartWorkflowExecutionResponse, error)
SignalWithStartWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) SignalWorkflowExecution ¶
func (m *MockWorkflowServiceClient) SignalWorkflowExecution(ctx context.Context, in *workflowservice.SignalWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.SignalWorkflowExecutionResponse, error)
SignalWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) StartBatchOperation ¶ added in v1.12.0
func (m *MockWorkflowServiceClient) StartBatchOperation(ctx context.Context, in *workflowservice.StartBatchOperationRequest, opts ...grpc.CallOption) (*workflowservice.StartBatchOperationResponse, error)
StartBatchOperation mocks base method.
func (*MockWorkflowServiceClient) StartWorkflowExecution ¶
func (m *MockWorkflowServiceClient) StartWorkflowExecution(ctx context.Context, in *workflowservice.StartWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.StartWorkflowExecutionResponse, error)
StartWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) StopBatchOperation ¶ added in v1.12.0
func (m *MockWorkflowServiceClient) StopBatchOperation(ctx context.Context, in *workflowservice.StopBatchOperationRequest, opts ...grpc.CallOption) (*workflowservice.StopBatchOperationResponse, error)
StopBatchOperation mocks base method.
func (*MockWorkflowServiceClient) TerminateWorkflowExecution ¶
func (m *MockWorkflowServiceClient) TerminateWorkflowExecution(ctx context.Context, in *workflowservice.TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.TerminateWorkflowExecutionResponse, error)
TerminateWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) UnpauseActivityById ¶ added in v1.41.0
func (m *MockWorkflowServiceClient) UnpauseActivityById(ctx context.Context, in *workflowservice.UnpauseActivityByIdRequest, opts ...grpc.CallOption) (*workflowservice.UnpauseActivityByIdResponse, error)
UnpauseActivityById mocks base method.
func (*MockWorkflowServiceClient) UpdateActivityOptionsById ¶ added in v1.40.0
func (m *MockWorkflowServiceClient) UpdateActivityOptionsById(ctx context.Context, in *workflowservice.UpdateActivityOptionsByIdRequest, opts ...grpc.CallOption) (*workflowservice.UpdateActivityOptionsByIdResponse, error)
UpdateActivityOptionsById mocks base method.
func (*MockWorkflowServiceClient) UpdateNamespace ¶
func (m *MockWorkflowServiceClient) UpdateNamespace(ctx context.Context, in *workflowservice.UpdateNamespaceRequest, opts ...grpc.CallOption) (*workflowservice.UpdateNamespaceResponse, error)
UpdateNamespace mocks base method.
func (*MockWorkflowServiceClient) UpdateSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceClient) UpdateSchedule(ctx context.Context, in *workflowservice.UpdateScheduleRequest, opts ...grpc.CallOption) (*workflowservice.UpdateScheduleResponse, error)
UpdateSchedule mocks base method.
func (*MockWorkflowServiceClient) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockWorkflowServiceClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, in *workflowservice.UpdateWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption) (*workflowservice.UpdateWorkerBuildIdCompatibilityResponse, error)
UpdateWorkerBuildIdCompatibility mocks base method.
func (*MockWorkflowServiceClient) UpdateWorkerVersioningRules ¶ added in v1.32.0
func (m *MockWorkflowServiceClient) UpdateWorkerVersioningRules(ctx context.Context, in *workflowservice.UpdateWorkerVersioningRulesRequest, opts ...grpc.CallOption) (*workflowservice.UpdateWorkerVersioningRulesResponse, error)
UpdateWorkerVersioningRules mocks base method.
func (*MockWorkflowServiceClient) UpdateWorkflowExecution ¶ added in v1.16.0
func (m *MockWorkflowServiceClient) UpdateWorkflowExecution(ctx context.Context, in *workflowservice.UpdateWorkflowExecutionRequest, opts ...grpc.CallOption) (*workflowservice.UpdateWorkflowExecutionResponse, error)
UpdateWorkflowExecution mocks base method.
func (*MockWorkflowServiceClient) UpdateWorkflowExecutionOptions ¶ added in v1.43.0
func (m *MockWorkflowServiceClient) UpdateWorkflowExecutionOptions(ctx context.Context, in *workflowservice.UpdateWorkflowExecutionOptionsRequest, opts ...grpc.CallOption) (*workflowservice.UpdateWorkflowExecutionOptionsResponse, error)
UpdateWorkflowExecutionOptions mocks base method.
type MockWorkflowServiceClientMockRecorder ¶
type MockWorkflowServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockWorkflowServiceClientMockRecorder is the mock recorder for MockWorkflowServiceClient.
func (*MockWorkflowServiceClientMockRecorder) CountWorkflowExecutions ¶
func (mr *MockWorkflowServiceClientMockRecorder) CountWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.
func (*MockWorkflowServiceClientMockRecorder) CreateSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) CreateSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
CreateSchedule indicates an expected call of CreateSchedule.
func (*MockWorkflowServiceClientMockRecorder) DeleteSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) DeleteSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeleteSchedule indicates an expected call of DeleteSchedule.
func (*MockWorkflowServiceClientMockRecorder) DeleteWorkflowExecution ¶ added in v1.12.0
func (mr *MockWorkflowServiceClientMockRecorder) DeleteWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) DeprecateNamespace ¶
func (mr *MockWorkflowServiceClientMockRecorder) DeprecateNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeprecateNamespace indicates an expected call of DeprecateNamespace.
func (*MockWorkflowServiceClientMockRecorder) DescribeBatchOperation ¶ added in v1.12.0
func (mr *MockWorkflowServiceClientMockRecorder) DescribeBatchOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeBatchOperation indicates an expected call of DescribeBatchOperation.
func (*MockWorkflowServiceClientMockRecorder) DescribeDeployment ¶ added in v1.43.0
func (mr *MockWorkflowServiceClientMockRecorder) DescribeDeployment(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeDeployment indicates an expected call of DescribeDeployment.
func (*MockWorkflowServiceClientMockRecorder) DescribeNamespace ¶
func (mr *MockWorkflowServiceClientMockRecorder) DescribeNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeNamespace indicates an expected call of DescribeNamespace.
func (*MockWorkflowServiceClientMockRecorder) DescribeSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) DescribeSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeSchedule indicates an expected call of DescribeSchedule.
func (*MockWorkflowServiceClientMockRecorder) DescribeTaskQueue ¶
func (mr *MockWorkflowServiceClientMockRecorder) DescribeTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (*MockWorkflowServiceClientMockRecorder) DescribeWorkflowExecution ¶
func (mr *MockWorkflowServiceClientMockRecorder) DescribeWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) ExecuteMultiOperation ¶ added in v1.32.1
func (mr *MockWorkflowServiceClientMockRecorder) ExecuteMultiOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
ExecuteMultiOperation indicates an expected call of ExecuteMultiOperation.
func (*MockWorkflowServiceClientMockRecorder) GetClusterInfo ¶
func (mr *MockWorkflowServiceClientMockRecorder) GetClusterInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetClusterInfo indicates an expected call of GetClusterInfo.
func (*MockWorkflowServiceClientMockRecorder) GetCurrentDeployment ¶ added in v1.43.0
func (mr *MockWorkflowServiceClientMockRecorder) GetCurrentDeployment(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetCurrentDeployment indicates an expected call of GetCurrentDeployment.
func (*MockWorkflowServiceClientMockRecorder) GetDeploymentReachability ¶ added in v1.43.0
func (mr *MockWorkflowServiceClientMockRecorder) GetDeploymentReachability(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetDeploymentReachability indicates an expected call of GetDeploymentReachability.
func (*MockWorkflowServiceClientMockRecorder) GetSearchAttributes ¶
func (mr *MockWorkflowServiceClientMockRecorder) GetSearchAttributes(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetSearchAttributes indicates an expected call of GetSearchAttributes.
func (*MockWorkflowServiceClientMockRecorder) GetSystemInfo ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) GetSystemInfo(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetSystemInfo indicates an expected call of GetSystemInfo.
func (*MockWorkflowServiceClientMockRecorder) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (*MockWorkflowServiceClientMockRecorder) GetWorkerTaskReachability ¶ added in v1.21.0
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerTaskReachability(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetWorkerTaskReachability indicates an expected call of GetWorkerTaskReachability.
func (*MockWorkflowServiceClientMockRecorder) GetWorkerVersioningRules ¶ added in v1.32.0
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerVersioningRules(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetWorkerVersioningRules indicates an expected call of GetWorkerVersioningRules.
func (*MockWorkflowServiceClientMockRecorder) GetWorkflowExecutionHistory ¶
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkflowExecutionHistory(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory.
func (*MockWorkflowServiceClientMockRecorder) GetWorkflowExecutionHistoryReverse ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkflowExecutionHistoryReverse(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetWorkflowExecutionHistoryReverse indicates an expected call of GetWorkflowExecutionHistoryReverse.
func (*MockWorkflowServiceClientMockRecorder) ListArchivedWorkflowExecutions ¶
func (mr *MockWorkflowServiceClientMockRecorder) ListArchivedWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions.
func (*MockWorkflowServiceClientMockRecorder) ListBatchOperations ¶ added in v1.12.0
func (mr *MockWorkflowServiceClientMockRecorder) ListBatchOperations(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListBatchOperations indicates an expected call of ListBatchOperations.
func (*MockWorkflowServiceClientMockRecorder) ListClosedWorkflowExecutions ¶
func (mr *MockWorkflowServiceClientMockRecorder) ListClosedWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.
func (*MockWorkflowServiceClientMockRecorder) ListDeployments ¶ added in v1.43.0
func (mr *MockWorkflowServiceClientMockRecorder) ListDeployments(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListDeployments indicates an expected call of ListDeployments.
func (*MockWorkflowServiceClientMockRecorder) ListNamespaces ¶
func (mr *MockWorkflowServiceClientMockRecorder) ListNamespaces(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListNamespaces indicates an expected call of ListNamespaces.
func (*MockWorkflowServiceClientMockRecorder) ListOpenWorkflowExecutions ¶
func (mr *MockWorkflowServiceClientMockRecorder) ListOpenWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.
func (*MockWorkflowServiceClientMockRecorder) ListScheduleMatchingTimes ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) ListScheduleMatchingTimes(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListScheduleMatchingTimes indicates an expected call of ListScheduleMatchingTimes.
func (*MockWorkflowServiceClientMockRecorder) ListSchedules ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) ListSchedules(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListSchedules indicates an expected call of ListSchedules.
func (*MockWorkflowServiceClientMockRecorder) ListTaskQueuePartitions ¶
func (mr *MockWorkflowServiceClientMockRecorder) ListTaskQueuePartitions(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListTaskQueuePartitions indicates an expected call of ListTaskQueuePartitions.
func (*MockWorkflowServiceClientMockRecorder) ListWorkflowExecutions ¶
func (mr *MockWorkflowServiceClientMockRecorder) ListWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.
func (*MockWorkflowServiceClientMockRecorder) PatchSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) PatchSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
PatchSchedule indicates an expected call of PatchSchedule.
func (*MockWorkflowServiceClientMockRecorder) PauseActivityById ¶ added in v1.41.0
func (mr *MockWorkflowServiceClientMockRecorder) PauseActivityById(ctx, in interface{}, opts ...interface{}) *gomock.Call
PauseActivityById indicates an expected call of PauseActivityById.
func (*MockWorkflowServiceClientMockRecorder) PollActivityTaskQueue ¶
func (mr *MockWorkflowServiceClientMockRecorder) PollActivityTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
PollActivityTaskQueue indicates an expected call of PollActivityTaskQueue.
func (*MockWorkflowServiceClientMockRecorder) PollNexusTaskQueue ¶ added in v1.27.0
func (mr *MockWorkflowServiceClientMockRecorder) PollNexusTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
PollNexusTaskQueue indicates an expected call of PollNexusTaskQueue.
func (*MockWorkflowServiceClientMockRecorder) PollWorkflowExecutionUpdate ¶ added in v1.21.0
func (mr *MockWorkflowServiceClientMockRecorder) PollWorkflowExecutionUpdate(ctx, in interface{}, opts ...interface{}) *gomock.Call
PollWorkflowExecutionUpdate indicates an expected call of PollWorkflowExecutionUpdate.
func (*MockWorkflowServiceClientMockRecorder) PollWorkflowTaskQueue ¶
func (mr *MockWorkflowServiceClientMockRecorder) PollWorkflowTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
PollWorkflowTaskQueue indicates an expected call of PollWorkflowTaskQueue.
func (*MockWorkflowServiceClientMockRecorder) QueryWorkflow ¶
func (mr *MockWorkflowServiceClientMockRecorder) QueryWorkflow(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockWorkflowServiceClientMockRecorder) RecordActivityTaskHeartbeat ¶
func (mr *MockWorkflowServiceClientMockRecorder) RecordActivityTaskHeartbeat(ctx, in interface{}, opts ...interface{}) *gomock.Call
RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.
func (*MockWorkflowServiceClientMockRecorder) RecordActivityTaskHeartbeatById ¶
func (mr *MockWorkflowServiceClientMockRecorder) RecordActivityTaskHeartbeatById(ctx, in interface{}, opts ...interface{}) *gomock.Call
RecordActivityTaskHeartbeatById indicates an expected call of RecordActivityTaskHeartbeatById.
func (*MockWorkflowServiceClientMockRecorder) RegisterNamespace ¶
func (mr *MockWorkflowServiceClientMockRecorder) RegisterNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call
RegisterNamespace indicates an expected call of RegisterNamespace.
func (*MockWorkflowServiceClientMockRecorder) RequestCancelWorkflowExecution ¶
func (mr *MockWorkflowServiceClientMockRecorder) RequestCancelWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) ResetActivityById ¶ added in v1.41.0
func (mr *MockWorkflowServiceClientMockRecorder) ResetActivityById(ctx, in interface{}, opts ...interface{}) *gomock.Call
ResetActivityById indicates an expected call of ResetActivityById.
func (*MockWorkflowServiceClientMockRecorder) ResetStickyTaskQueue ¶
func (mr *MockWorkflowServiceClientMockRecorder) ResetStickyTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
ResetStickyTaskQueue indicates an expected call of ResetStickyTaskQueue.
func (*MockWorkflowServiceClientMockRecorder) ResetWorkflowExecution ¶
func (mr *MockWorkflowServiceClientMockRecorder) ResetWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) RespondActivityTaskCanceled ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCanceled(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.
func (*MockWorkflowServiceClientMockRecorder) RespondActivityTaskCanceledById ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCanceledById(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondActivityTaskCanceledById indicates an expected call of RespondActivityTaskCanceledById.
func (*MockWorkflowServiceClientMockRecorder) RespondActivityTaskCompleted ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.
func (*MockWorkflowServiceClientMockRecorder) RespondActivityTaskCompletedById ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCompletedById(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondActivityTaskCompletedById indicates an expected call of RespondActivityTaskCompletedById.
func (*MockWorkflowServiceClientMockRecorder) RespondActivityTaskFailed ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.
func (*MockWorkflowServiceClientMockRecorder) RespondActivityTaskFailedById ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskFailedById(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondActivityTaskFailedById indicates an expected call of RespondActivityTaskFailedById.
func (*MockWorkflowServiceClientMockRecorder) RespondNexusTaskCompleted ¶ added in v1.27.0
func (mr *MockWorkflowServiceClientMockRecorder) RespondNexusTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondNexusTaskCompleted indicates an expected call of RespondNexusTaskCompleted.
func (*MockWorkflowServiceClientMockRecorder) RespondNexusTaskFailed ¶ added in v1.27.0
func (mr *MockWorkflowServiceClientMockRecorder) RespondNexusTaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondNexusTaskFailed indicates an expected call of RespondNexusTaskFailed.
func (*MockWorkflowServiceClientMockRecorder) RespondQueryTaskCompleted ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondQueryTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.
func (*MockWorkflowServiceClientMockRecorder) RespondWorkflowTaskCompleted ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondWorkflowTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondWorkflowTaskCompleted indicates an expected call of RespondWorkflowTaskCompleted.
func (*MockWorkflowServiceClientMockRecorder) RespondWorkflowTaskFailed ¶
func (mr *MockWorkflowServiceClientMockRecorder) RespondWorkflowTaskFailed(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondWorkflowTaskFailed indicates an expected call of RespondWorkflowTaskFailed.
func (*MockWorkflowServiceClientMockRecorder) ScanWorkflowExecutions ¶
func (mr *MockWorkflowServiceClientMockRecorder) ScanWorkflowExecutions(ctx, in interface{}, opts ...interface{}) *gomock.Call
ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.
func (*MockWorkflowServiceClientMockRecorder) SetCurrentDeployment ¶ added in v1.43.0
func (mr *MockWorkflowServiceClientMockRecorder) SetCurrentDeployment(ctx, in interface{}, opts ...interface{}) *gomock.Call
SetCurrentDeployment indicates an expected call of SetCurrentDeployment.
func (*MockWorkflowServiceClientMockRecorder) ShutdownWorker ¶ added in v1.39.0
func (mr *MockWorkflowServiceClientMockRecorder) ShutdownWorker(ctx, in interface{}, opts ...interface{}) *gomock.Call
ShutdownWorker indicates an expected call of ShutdownWorker.
func (*MockWorkflowServiceClientMockRecorder) SignalWithStartWorkflowExecution ¶
func (mr *MockWorkflowServiceClientMockRecorder) SignalWithStartWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) SignalWorkflowExecution ¶
func (mr *MockWorkflowServiceClientMockRecorder) SignalWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) StartBatchOperation ¶ added in v1.12.0
func (mr *MockWorkflowServiceClientMockRecorder) StartBatchOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
StartBatchOperation indicates an expected call of StartBatchOperation.
func (*MockWorkflowServiceClientMockRecorder) StartWorkflowExecution ¶
func (mr *MockWorkflowServiceClientMockRecorder) StartWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
StartWorkflowExecution indicates an expected call of StartWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) StopBatchOperation ¶ added in v1.12.0
func (mr *MockWorkflowServiceClientMockRecorder) StopBatchOperation(ctx, in interface{}, opts ...interface{}) *gomock.Call
StopBatchOperation indicates an expected call of StopBatchOperation.
func (*MockWorkflowServiceClientMockRecorder) TerminateWorkflowExecution ¶
func (mr *MockWorkflowServiceClientMockRecorder) TerminateWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) UnpauseActivityById ¶ added in v1.41.0
func (mr *MockWorkflowServiceClientMockRecorder) UnpauseActivityById(ctx, in interface{}, opts ...interface{}) *gomock.Call
UnpauseActivityById indicates an expected call of UnpauseActivityById.
func (*MockWorkflowServiceClientMockRecorder) UpdateActivityOptionsById ¶ added in v1.40.0
func (mr *MockWorkflowServiceClientMockRecorder) UpdateActivityOptionsById(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateActivityOptionsById indicates an expected call of UpdateActivityOptionsById.
func (*MockWorkflowServiceClientMockRecorder) UpdateNamespace ¶
func (mr *MockWorkflowServiceClientMockRecorder) UpdateNamespace(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateNamespace indicates an expected call of UpdateNamespace.
func (*MockWorkflowServiceClientMockRecorder) UpdateSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceClientMockRecorder) UpdateSchedule(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateSchedule indicates an expected call of UpdateSchedule.
func (*MockWorkflowServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.
func (*MockWorkflowServiceClientMockRecorder) UpdateWorkerVersioningRules ¶ added in v1.32.0
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkerVersioningRules(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateWorkerVersioningRules indicates an expected call of UpdateWorkerVersioningRules.
func (*MockWorkflowServiceClientMockRecorder) UpdateWorkflowExecution ¶ added in v1.16.0
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkflowExecution(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
func (*MockWorkflowServiceClientMockRecorder) UpdateWorkflowExecutionOptions ¶ added in v1.43.0
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkflowExecutionOptions(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateWorkflowExecutionOptions indicates an expected call of UpdateWorkflowExecutionOptions.
type MockWorkflowServiceServer ¶
type MockWorkflowServiceServer struct { workflowservice.UnimplementedWorkflowServiceServer // contains filtered or unexported fields }
MockWorkflowServiceServer is a mock of WorkflowServiceServer interface.
func NewMockWorkflowServiceServer ¶
func NewMockWorkflowServiceServer(ctrl *gomock.Controller) *MockWorkflowServiceServer
NewMockWorkflowServiceServer creates a new mock instance.
func (*MockWorkflowServiceServer) CountWorkflowExecutions ¶
func (m *MockWorkflowServiceServer) CountWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.CountWorkflowExecutionsRequest) (*workflowservice.CountWorkflowExecutionsResponse, error)
CountWorkflowExecutions mocks base method.
func (*MockWorkflowServiceServer) CreateSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) CreateSchedule(arg0 context.Context, arg1 *workflowservice.CreateScheduleRequest) (*workflowservice.CreateScheduleResponse, error)
CreateSchedule mocks base method.
func (*MockWorkflowServiceServer) DeleteSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) DeleteSchedule(arg0 context.Context, arg1 *workflowservice.DeleteScheduleRequest) (*workflowservice.DeleteScheduleResponse, error)
DeleteSchedule mocks base method.
func (*MockWorkflowServiceServer) DeleteWorkflowExecution ¶ added in v1.12.0
func (m *MockWorkflowServiceServer) DeleteWorkflowExecution(arg0 context.Context, arg1 *workflowservice.DeleteWorkflowExecutionRequest) (*workflowservice.DeleteWorkflowExecutionResponse, error)
DeleteWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) DeprecateNamespace ¶
func (m *MockWorkflowServiceServer) DeprecateNamespace(arg0 context.Context, arg1 *workflowservice.DeprecateNamespaceRequest) (*workflowservice.DeprecateNamespaceResponse, error)
DeprecateNamespace mocks base method.
func (*MockWorkflowServiceServer) DescribeBatchOperation ¶ added in v1.12.0
func (m *MockWorkflowServiceServer) DescribeBatchOperation(arg0 context.Context, arg1 *workflowservice.DescribeBatchOperationRequest) (*workflowservice.DescribeBatchOperationResponse, error)
DescribeBatchOperation mocks base method.
func (*MockWorkflowServiceServer) DescribeDeployment ¶ added in v1.43.0
func (m *MockWorkflowServiceServer) DescribeDeployment(arg0 context.Context, arg1 *workflowservice.DescribeDeploymentRequest) (*workflowservice.DescribeDeploymentResponse, error)
DescribeDeployment mocks base method.
func (*MockWorkflowServiceServer) DescribeNamespace ¶
func (m *MockWorkflowServiceServer) DescribeNamespace(arg0 context.Context, arg1 *workflowservice.DescribeNamespaceRequest) (*workflowservice.DescribeNamespaceResponse, error)
DescribeNamespace mocks base method.
func (*MockWorkflowServiceServer) DescribeSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) DescribeSchedule(arg0 context.Context, arg1 *workflowservice.DescribeScheduleRequest) (*workflowservice.DescribeScheduleResponse, error)
DescribeSchedule mocks base method.
func (*MockWorkflowServiceServer) DescribeTaskQueue ¶
func (m *MockWorkflowServiceServer) DescribeTaskQueue(arg0 context.Context, arg1 *workflowservice.DescribeTaskQueueRequest) (*workflowservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue mocks base method.
func (*MockWorkflowServiceServer) DescribeWorkflowExecution ¶
func (m *MockWorkflowServiceServer) DescribeWorkflowExecution(arg0 context.Context, arg1 *workflowservice.DescribeWorkflowExecutionRequest) (*workflowservice.DescribeWorkflowExecutionResponse, error)
DescribeWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) EXPECT ¶
func (m *MockWorkflowServiceServer) EXPECT() *MockWorkflowServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockWorkflowServiceServer) ExecuteMultiOperation ¶ added in v1.32.1
func (m *MockWorkflowServiceServer) ExecuteMultiOperation(arg0 context.Context, arg1 *workflowservice.ExecuteMultiOperationRequest) (*workflowservice.ExecuteMultiOperationResponse, error)
ExecuteMultiOperation mocks base method.
func (*MockWorkflowServiceServer) GetClusterInfo ¶
func (m *MockWorkflowServiceServer) GetClusterInfo(arg0 context.Context, arg1 *workflowservice.GetClusterInfoRequest) (*workflowservice.GetClusterInfoResponse, error)
GetClusterInfo mocks base method.
func (*MockWorkflowServiceServer) GetCurrentDeployment ¶ added in v1.43.0
func (m *MockWorkflowServiceServer) GetCurrentDeployment(arg0 context.Context, arg1 *workflowservice.GetCurrentDeploymentRequest) (*workflowservice.GetCurrentDeploymentResponse, error)
GetCurrentDeployment mocks base method.
func (*MockWorkflowServiceServer) GetDeploymentReachability ¶ added in v1.43.0
func (m *MockWorkflowServiceServer) GetDeploymentReachability(arg0 context.Context, arg1 *workflowservice.GetDeploymentReachabilityRequest) (*workflowservice.GetDeploymentReachabilityResponse, error)
GetDeploymentReachability mocks base method.
func (*MockWorkflowServiceServer) GetSearchAttributes ¶
func (m *MockWorkflowServiceServer) GetSearchAttributes(arg0 context.Context, arg1 *workflowservice.GetSearchAttributesRequest) (*workflowservice.GetSearchAttributesResponse, error)
GetSearchAttributes mocks base method.
func (*MockWorkflowServiceServer) GetSystemInfo ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) GetSystemInfo(arg0 context.Context, arg1 *workflowservice.GetSystemInfoRequest) (*workflowservice.GetSystemInfoResponse, error)
GetSystemInfo mocks base method.
func (*MockWorkflowServiceServer) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockWorkflowServiceServer) GetWorkerBuildIdCompatibility(arg0 context.Context, arg1 *workflowservice.GetWorkerBuildIdCompatibilityRequest) (*workflowservice.GetWorkerBuildIdCompatibilityResponse, error)
GetWorkerBuildIdCompatibility mocks base method.
func (*MockWorkflowServiceServer) GetWorkerTaskReachability ¶ added in v1.21.0
func (m *MockWorkflowServiceServer) GetWorkerTaskReachability(arg0 context.Context, arg1 *workflowservice.GetWorkerTaskReachabilityRequest) (*workflowservice.GetWorkerTaskReachabilityResponse, error)
GetWorkerTaskReachability mocks base method.
func (*MockWorkflowServiceServer) GetWorkerVersioningRules ¶ added in v1.32.0
func (m *MockWorkflowServiceServer) GetWorkerVersioningRules(arg0 context.Context, arg1 *workflowservice.GetWorkerVersioningRulesRequest) (*workflowservice.GetWorkerVersioningRulesResponse, error)
GetWorkerVersioningRules mocks base method.
func (*MockWorkflowServiceServer) GetWorkflowExecutionHistory ¶
func (m *MockWorkflowServiceServer) GetWorkflowExecutionHistory(arg0 context.Context, arg1 *workflowservice.GetWorkflowExecutionHistoryRequest) (*workflowservice.GetWorkflowExecutionHistoryResponse, error)
GetWorkflowExecutionHistory mocks base method.
func (*MockWorkflowServiceServer) GetWorkflowExecutionHistoryReverse ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) GetWorkflowExecutionHistoryReverse(arg0 context.Context, arg1 *workflowservice.GetWorkflowExecutionHistoryReverseRequest) (*workflowservice.GetWorkflowExecutionHistoryReverseResponse, error)
GetWorkflowExecutionHistoryReverse mocks base method.
func (*MockWorkflowServiceServer) ListArchivedWorkflowExecutions ¶
func (m *MockWorkflowServiceServer) ListArchivedWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListArchivedWorkflowExecutionsRequest) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error)
ListArchivedWorkflowExecutions mocks base method.
func (*MockWorkflowServiceServer) ListBatchOperations ¶ added in v1.12.0
func (m *MockWorkflowServiceServer) ListBatchOperations(arg0 context.Context, arg1 *workflowservice.ListBatchOperationsRequest) (*workflowservice.ListBatchOperationsResponse, error)
ListBatchOperations mocks base method.
func (*MockWorkflowServiceServer) ListClosedWorkflowExecutions ¶
func (m *MockWorkflowServiceServer) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListClosedWorkflowExecutionsRequest) (*workflowservice.ListClosedWorkflowExecutionsResponse, error)
ListClosedWorkflowExecutions mocks base method.
func (*MockWorkflowServiceServer) ListDeployments ¶ added in v1.43.0
func (m *MockWorkflowServiceServer) ListDeployments(arg0 context.Context, arg1 *workflowservice.ListDeploymentsRequest) (*workflowservice.ListDeploymentsResponse, error)
ListDeployments mocks base method.
func (*MockWorkflowServiceServer) ListNamespaces ¶
func (m *MockWorkflowServiceServer) ListNamespaces(arg0 context.Context, arg1 *workflowservice.ListNamespacesRequest) (*workflowservice.ListNamespacesResponse, error)
ListNamespaces mocks base method.
func (*MockWorkflowServiceServer) ListOpenWorkflowExecutions ¶
func (m *MockWorkflowServiceServer) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListOpenWorkflowExecutionsRequest) (*workflowservice.ListOpenWorkflowExecutionsResponse, error)
ListOpenWorkflowExecutions mocks base method.
func (*MockWorkflowServiceServer) ListScheduleMatchingTimes ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) ListScheduleMatchingTimes(arg0 context.Context, arg1 *workflowservice.ListScheduleMatchingTimesRequest) (*workflowservice.ListScheduleMatchingTimesResponse, error)
ListScheduleMatchingTimes mocks base method.
func (*MockWorkflowServiceServer) ListSchedules ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) ListSchedules(arg0 context.Context, arg1 *workflowservice.ListSchedulesRequest) (*workflowservice.ListSchedulesResponse, error)
ListSchedules mocks base method.
func (*MockWorkflowServiceServer) ListTaskQueuePartitions ¶
func (m *MockWorkflowServiceServer) ListTaskQueuePartitions(arg0 context.Context, arg1 *workflowservice.ListTaskQueuePartitionsRequest) (*workflowservice.ListTaskQueuePartitionsResponse, error)
ListTaskQueuePartitions mocks base method.
func (*MockWorkflowServiceServer) ListWorkflowExecutions ¶
func (m *MockWorkflowServiceServer) ListWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListWorkflowExecutionsRequest) (*workflowservice.ListWorkflowExecutionsResponse, error)
ListWorkflowExecutions mocks base method.
func (*MockWorkflowServiceServer) PatchSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) PatchSchedule(arg0 context.Context, arg1 *workflowservice.PatchScheduleRequest) (*workflowservice.PatchScheduleResponse, error)
PatchSchedule mocks base method.
func (*MockWorkflowServiceServer) PauseActivityById ¶ added in v1.41.0
func (m *MockWorkflowServiceServer) PauseActivityById(arg0 context.Context, arg1 *workflowservice.PauseActivityByIdRequest) (*workflowservice.PauseActivityByIdResponse, error)
PauseActivityById mocks base method.
func (*MockWorkflowServiceServer) PollActivityTaskQueue ¶
func (m *MockWorkflowServiceServer) PollActivityTaskQueue(arg0 context.Context, arg1 *workflowservice.PollActivityTaskQueueRequest) (*workflowservice.PollActivityTaskQueueResponse, error)
PollActivityTaskQueue mocks base method.
func (*MockWorkflowServiceServer) PollNexusTaskQueue ¶ added in v1.27.0
func (m *MockWorkflowServiceServer) PollNexusTaskQueue(arg0 context.Context, arg1 *workflowservice.PollNexusTaskQueueRequest) (*workflowservice.PollNexusTaskQueueResponse, error)
PollNexusTaskQueue mocks base method.
func (*MockWorkflowServiceServer) PollWorkflowExecutionUpdate ¶ added in v1.21.0
func (m *MockWorkflowServiceServer) PollWorkflowExecutionUpdate(arg0 context.Context, arg1 *workflowservice.PollWorkflowExecutionUpdateRequest) (*workflowservice.PollWorkflowExecutionUpdateResponse, error)
PollWorkflowExecutionUpdate mocks base method.
func (*MockWorkflowServiceServer) PollWorkflowTaskQueue ¶
func (m *MockWorkflowServiceServer) PollWorkflowTaskQueue(arg0 context.Context, arg1 *workflowservice.PollWorkflowTaskQueueRequest) (*workflowservice.PollWorkflowTaskQueueResponse, error)
PollWorkflowTaskQueue mocks base method.
func (*MockWorkflowServiceServer) QueryWorkflow ¶
func (m *MockWorkflowServiceServer) QueryWorkflow(arg0 context.Context, arg1 *workflowservice.QueryWorkflowRequest) (*workflowservice.QueryWorkflowResponse, error)
QueryWorkflow mocks base method.
func (*MockWorkflowServiceServer) RecordActivityTaskHeartbeat ¶
func (m *MockWorkflowServiceServer) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *workflowservice.RecordActivityTaskHeartbeatRequest) (*workflowservice.RecordActivityTaskHeartbeatResponse, error)
RecordActivityTaskHeartbeat mocks base method.
func (*MockWorkflowServiceServer) RecordActivityTaskHeartbeatById ¶
func (m *MockWorkflowServiceServer) RecordActivityTaskHeartbeatById(arg0 context.Context, arg1 *workflowservice.RecordActivityTaskHeartbeatByIdRequest) (*workflowservice.RecordActivityTaskHeartbeatByIdResponse, error)
RecordActivityTaskHeartbeatById mocks base method.
func (*MockWorkflowServiceServer) RegisterNamespace ¶
func (m *MockWorkflowServiceServer) RegisterNamespace(arg0 context.Context, arg1 *workflowservice.RegisterNamespaceRequest) (*workflowservice.RegisterNamespaceResponse, error)
RegisterNamespace mocks base method.
func (*MockWorkflowServiceServer) RequestCancelWorkflowExecution ¶
func (m *MockWorkflowServiceServer) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *workflowservice.RequestCancelWorkflowExecutionRequest) (*workflowservice.RequestCancelWorkflowExecutionResponse, error)
RequestCancelWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) ResetActivityById ¶ added in v1.41.0
func (m *MockWorkflowServiceServer) ResetActivityById(arg0 context.Context, arg1 *workflowservice.ResetActivityByIdRequest) (*workflowservice.ResetActivityByIdResponse, error)
ResetActivityById mocks base method.
func (*MockWorkflowServiceServer) ResetStickyTaskQueue ¶
func (m *MockWorkflowServiceServer) ResetStickyTaskQueue(arg0 context.Context, arg1 *workflowservice.ResetStickyTaskQueueRequest) (*workflowservice.ResetStickyTaskQueueResponse, error)
ResetStickyTaskQueue mocks base method.
func (*MockWorkflowServiceServer) ResetWorkflowExecution ¶
func (m *MockWorkflowServiceServer) ResetWorkflowExecution(arg0 context.Context, arg1 *workflowservice.ResetWorkflowExecutionRequest) (*workflowservice.ResetWorkflowExecutionResponse, error)
ResetWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) RespondActivityTaskCanceled ¶
func (m *MockWorkflowServiceServer) RespondActivityTaskCanceled(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCanceledRequest) (*workflowservice.RespondActivityTaskCanceledResponse, error)
RespondActivityTaskCanceled mocks base method.
func (*MockWorkflowServiceServer) RespondActivityTaskCanceledById ¶
func (m *MockWorkflowServiceServer) RespondActivityTaskCanceledById(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCanceledByIdRequest) (*workflowservice.RespondActivityTaskCanceledByIdResponse, error)
RespondActivityTaskCanceledById mocks base method.
func (*MockWorkflowServiceServer) RespondActivityTaskCompleted ¶
func (m *MockWorkflowServiceServer) RespondActivityTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCompletedRequest) (*workflowservice.RespondActivityTaskCompletedResponse, error)
RespondActivityTaskCompleted mocks base method.
func (*MockWorkflowServiceServer) RespondActivityTaskCompletedById ¶
func (m *MockWorkflowServiceServer) RespondActivityTaskCompletedById(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCompletedByIdRequest) (*workflowservice.RespondActivityTaskCompletedByIdResponse, error)
RespondActivityTaskCompletedById mocks base method.
func (*MockWorkflowServiceServer) RespondActivityTaskFailed ¶
func (m *MockWorkflowServiceServer) RespondActivityTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskFailedRequest) (*workflowservice.RespondActivityTaskFailedResponse, error)
RespondActivityTaskFailed mocks base method.
func (*MockWorkflowServiceServer) RespondActivityTaskFailedById ¶
func (m *MockWorkflowServiceServer) RespondActivityTaskFailedById(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskFailedByIdRequest) (*workflowservice.RespondActivityTaskFailedByIdResponse, error)
RespondActivityTaskFailedById mocks base method.
func (*MockWorkflowServiceServer) RespondNexusTaskCompleted ¶ added in v1.27.0
func (m *MockWorkflowServiceServer) RespondNexusTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondNexusTaskCompletedRequest) (*workflowservice.RespondNexusTaskCompletedResponse, error)
RespondNexusTaskCompleted mocks base method.
func (*MockWorkflowServiceServer) RespondNexusTaskFailed ¶ added in v1.27.0
func (m *MockWorkflowServiceServer) RespondNexusTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondNexusTaskFailedRequest) (*workflowservice.RespondNexusTaskFailedResponse, error)
RespondNexusTaskFailed mocks base method.
func (*MockWorkflowServiceServer) RespondQueryTaskCompleted ¶
func (m *MockWorkflowServiceServer) RespondQueryTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondQueryTaskCompletedRequest) (*workflowservice.RespondQueryTaskCompletedResponse, error)
RespondQueryTaskCompleted mocks base method.
func (*MockWorkflowServiceServer) RespondWorkflowTaskCompleted ¶
func (m *MockWorkflowServiceServer) RespondWorkflowTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondWorkflowTaskCompletedRequest) (*workflowservice.RespondWorkflowTaskCompletedResponse, error)
RespondWorkflowTaskCompleted mocks base method.
func (*MockWorkflowServiceServer) RespondWorkflowTaskFailed ¶
func (m *MockWorkflowServiceServer) RespondWorkflowTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondWorkflowTaskFailedRequest) (*workflowservice.RespondWorkflowTaskFailedResponse, error)
RespondWorkflowTaskFailed mocks base method.
func (*MockWorkflowServiceServer) ScanWorkflowExecutions ¶
func (m *MockWorkflowServiceServer) ScanWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ScanWorkflowExecutionsRequest) (*workflowservice.ScanWorkflowExecutionsResponse, error)
ScanWorkflowExecutions mocks base method.
func (*MockWorkflowServiceServer) SetCurrentDeployment ¶ added in v1.43.0
func (m *MockWorkflowServiceServer) SetCurrentDeployment(arg0 context.Context, arg1 *workflowservice.SetCurrentDeploymentRequest) (*workflowservice.SetCurrentDeploymentResponse, error)
SetCurrentDeployment mocks base method.
func (*MockWorkflowServiceServer) ShutdownWorker ¶ added in v1.39.0
func (m *MockWorkflowServiceServer) ShutdownWorker(arg0 context.Context, arg1 *workflowservice.ShutdownWorkerRequest) (*workflowservice.ShutdownWorkerResponse, error)
ShutdownWorker mocks base method.
func (*MockWorkflowServiceServer) SignalWithStartWorkflowExecution ¶
func (m *MockWorkflowServiceServer) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *workflowservice.SignalWithStartWorkflowExecutionRequest) (*workflowservice.SignalWithStartWorkflowExecutionResponse, error)
SignalWithStartWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) SignalWorkflowExecution ¶
func (m *MockWorkflowServiceServer) SignalWorkflowExecution(arg0 context.Context, arg1 *workflowservice.SignalWorkflowExecutionRequest) (*workflowservice.SignalWorkflowExecutionResponse, error)
SignalWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) StartBatchOperation ¶ added in v1.12.0
func (m *MockWorkflowServiceServer) StartBatchOperation(arg0 context.Context, arg1 *workflowservice.StartBatchOperationRequest) (*workflowservice.StartBatchOperationResponse, error)
StartBatchOperation mocks base method.
func (*MockWorkflowServiceServer) StartWorkflowExecution ¶
func (m *MockWorkflowServiceServer) StartWorkflowExecution(arg0 context.Context, arg1 *workflowservice.StartWorkflowExecutionRequest) (*workflowservice.StartWorkflowExecutionResponse, error)
StartWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) StopBatchOperation ¶ added in v1.12.0
func (m *MockWorkflowServiceServer) StopBatchOperation(arg0 context.Context, arg1 *workflowservice.StopBatchOperationRequest) (*workflowservice.StopBatchOperationResponse, error)
StopBatchOperation mocks base method.
func (*MockWorkflowServiceServer) TerminateWorkflowExecution ¶
func (m *MockWorkflowServiceServer) TerminateWorkflowExecution(arg0 context.Context, arg1 *workflowservice.TerminateWorkflowExecutionRequest) (*workflowservice.TerminateWorkflowExecutionResponse, error)
TerminateWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) UnpauseActivityById ¶ added in v1.41.0
func (m *MockWorkflowServiceServer) UnpauseActivityById(arg0 context.Context, arg1 *workflowservice.UnpauseActivityByIdRequest) (*workflowservice.UnpauseActivityByIdResponse, error)
UnpauseActivityById mocks base method.
func (*MockWorkflowServiceServer) UpdateActivityOptionsById ¶ added in v1.40.0
func (m *MockWorkflowServiceServer) UpdateActivityOptionsById(arg0 context.Context, arg1 *workflowservice.UpdateActivityOptionsByIdRequest) (*workflowservice.UpdateActivityOptionsByIdResponse, error)
UpdateActivityOptionsById mocks base method.
func (*MockWorkflowServiceServer) UpdateNamespace ¶
func (m *MockWorkflowServiceServer) UpdateNamespace(arg0 context.Context, arg1 *workflowservice.UpdateNamespaceRequest) (*workflowservice.UpdateNamespaceResponse, error)
UpdateNamespace mocks base method.
func (*MockWorkflowServiceServer) UpdateSchedule ¶ added in v1.8.0
func (m *MockWorkflowServiceServer) UpdateSchedule(arg0 context.Context, arg1 *workflowservice.UpdateScheduleRequest) (*workflowservice.UpdateScheduleResponse, error)
UpdateSchedule mocks base method.
func (*MockWorkflowServiceServer) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockWorkflowServiceServer) UpdateWorkerBuildIdCompatibility(arg0 context.Context, arg1 *workflowservice.UpdateWorkerBuildIdCompatibilityRequest) (*workflowservice.UpdateWorkerBuildIdCompatibilityResponse, error)
UpdateWorkerBuildIdCompatibility mocks base method.
func (*MockWorkflowServiceServer) UpdateWorkerVersioningRules ¶ added in v1.32.0
func (m *MockWorkflowServiceServer) UpdateWorkerVersioningRules(arg0 context.Context, arg1 *workflowservice.UpdateWorkerVersioningRulesRequest) (*workflowservice.UpdateWorkerVersioningRulesResponse, error)
UpdateWorkerVersioningRules mocks base method.
func (*MockWorkflowServiceServer) UpdateWorkflowExecution ¶ added in v1.16.0
func (m *MockWorkflowServiceServer) UpdateWorkflowExecution(arg0 context.Context, arg1 *workflowservice.UpdateWorkflowExecutionRequest) (*workflowservice.UpdateWorkflowExecutionResponse, error)
UpdateWorkflowExecution mocks base method.
func (*MockWorkflowServiceServer) UpdateWorkflowExecutionOptions ¶ added in v1.43.0
func (m *MockWorkflowServiceServer) UpdateWorkflowExecutionOptions(arg0 context.Context, arg1 *workflowservice.UpdateWorkflowExecutionOptionsRequest) (*workflowservice.UpdateWorkflowExecutionOptionsResponse, error)
UpdateWorkflowExecutionOptions mocks base method.
type MockWorkflowServiceServerMockRecorder ¶
type MockWorkflowServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockWorkflowServiceServerMockRecorder is the mock recorder for MockWorkflowServiceServer.
func (*MockWorkflowServiceServerMockRecorder) CountWorkflowExecutions ¶
func (mr *MockWorkflowServiceServerMockRecorder) CountWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.
func (*MockWorkflowServiceServerMockRecorder) CreateSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) CreateSchedule(arg0, arg1 interface{}) *gomock.Call
CreateSchedule indicates an expected call of CreateSchedule.
func (*MockWorkflowServiceServerMockRecorder) DeleteSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) DeleteSchedule(arg0, arg1 interface{}) *gomock.Call
DeleteSchedule indicates an expected call of DeleteSchedule.
func (*MockWorkflowServiceServerMockRecorder) DeleteWorkflowExecution ¶ added in v1.12.0
func (mr *MockWorkflowServiceServerMockRecorder) DeleteWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) DeprecateNamespace ¶
func (mr *MockWorkflowServiceServerMockRecorder) DeprecateNamespace(arg0, arg1 interface{}) *gomock.Call
DeprecateNamespace indicates an expected call of DeprecateNamespace.
func (*MockWorkflowServiceServerMockRecorder) DescribeBatchOperation ¶ added in v1.12.0
func (mr *MockWorkflowServiceServerMockRecorder) DescribeBatchOperation(arg0, arg1 interface{}) *gomock.Call
DescribeBatchOperation indicates an expected call of DescribeBatchOperation.
func (*MockWorkflowServiceServerMockRecorder) DescribeDeployment ¶ added in v1.43.0
func (mr *MockWorkflowServiceServerMockRecorder) DescribeDeployment(arg0, arg1 interface{}) *gomock.Call
DescribeDeployment indicates an expected call of DescribeDeployment.
func (*MockWorkflowServiceServerMockRecorder) DescribeNamespace ¶
func (mr *MockWorkflowServiceServerMockRecorder) DescribeNamespace(arg0, arg1 interface{}) *gomock.Call
DescribeNamespace indicates an expected call of DescribeNamespace.
func (*MockWorkflowServiceServerMockRecorder) DescribeSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) DescribeSchedule(arg0, arg1 interface{}) *gomock.Call
DescribeSchedule indicates an expected call of DescribeSchedule.
func (*MockWorkflowServiceServerMockRecorder) DescribeTaskQueue ¶
func (mr *MockWorkflowServiceServerMockRecorder) DescribeTaskQueue(arg0, arg1 interface{}) *gomock.Call
DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (*MockWorkflowServiceServerMockRecorder) DescribeWorkflowExecution ¶
func (mr *MockWorkflowServiceServerMockRecorder) DescribeWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) ExecuteMultiOperation ¶ added in v1.32.1
func (mr *MockWorkflowServiceServerMockRecorder) ExecuteMultiOperation(arg0, arg1 interface{}) *gomock.Call
ExecuteMultiOperation indicates an expected call of ExecuteMultiOperation.
func (*MockWorkflowServiceServerMockRecorder) GetClusterInfo ¶
func (mr *MockWorkflowServiceServerMockRecorder) GetClusterInfo(arg0, arg1 interface{}) *gomock.Call
GetClusterInfo indicates an expected call of GetClusterInfo.
func (*MockWorkflowServiceServerMockRecorder) GetCurrentDeployment ¶ added in v1.43.0
func (mr *MockWorkflowServiceServerMockRecorder) GetCurrentDeployment(arg0, arg1 interface{}) *gomock.Call
GetCurrentDeployment indicates an expected call of GetCurrentDeployment.
func (*MockWorkflowServiceServerMockRecorder) GetDeploymentReachability ¶ added in v1.43.0
func (mr *MockWorkflowServiceServerMockRecorder) GetDeploymentReachability(arg0, arg1 interface{}) *gomock.Call
GetDeploymentReachability indicates an expected call of GetDeploymentReachability.
func (*MockWorkflowServiceServerMockRecorder) GetSearchAttributes ¶
func (mr *MockWorkflowServiceServerMockRecorder) GetSearchAttributes(arg0, arg1 interface{}) *gomock.Call
GetSearchAttributes indicates an expected call of GetSearchAttributes.
func (*MockWorkflowServiceServerMockRecorder) GetSystemInfo ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) GetSystemInfo(arg0, arg1 interface{}) *gomock.Call
GetSystemInfo indicates an expected call of GetSystemInfo.
func (*MockWorkflowServiceServerMockRecorder) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockWorkflowServiceServerMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (*MockWorkflowServiceServerMockRecorder) GetWorkerTaskReachability ¶ added in v1.21.0
func (mr *MockWorkflowServiceServerMockRecorder) GetWorkerTaskReachability(arg0, arg1 interface{}) *gomock.Call
GetWorkerTaskReachability indicates an expected call of GetWorkerTaskReachability.
func (*MockWorkflowServiceServerMockRecorder) GetWorkerVersioningRules ¶ added in v1.32.0
func (mr *MockWorkflowServiceServerMockRecorder) GetWorkerVersioningRules(arg0, arg1 interface{}) *gomock.Call
GetWorkerVersioningRules indicates an expected call of GetWorkerVersioningRules.
func (*MockWorkflowServiceServerMockRecorder) GetWorkflowExecutionHistory ¶
func (mr *MockWorkflowServiceServerMockRecorder) GetWorkflowExecutionHistory(arg0, arg1 interface{}) *gomock.Call
GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory.
func (*MockWorkflowServiceServerMockRecorder) GetWorkflowExecutionHistoryReverse ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) GetWorkflowExecutionHistoryReverse(arg0, arg1 interface{}) *gomock.Call
GetWorkflowExecutionHistoryReverse indicates an expected call of GetWorkflowExecutionHistoryReverse.
func (*MockWorkflowServiceServerMockRecorder) ListArchivedWorkflowExecutions ¶
func (mr *MockWorkflowServiceServerMockRecorder) ListArchivedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions.
func (*MockWorkflowServiceServerMockRecorder) ListBatchOperations ¶ added in v1.12.0
func (mr *MockWorkflowServiceServerMockRecorder) ListBatchOperations(arg0, arg1 interface{}) *gomock.Call
ListBatchOperations indicates an expected call of ListBatchOperations.
func (*MockWorkflowServiceServerMockRecorder) ListClosedWorkflowExecutions ¶
func (mr *MockWorkflowServiceServerMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.
func (*MockWorkflowServiceServerMockRecorder) ListDeployments ¶ added in v1.43.0
func (mr *MockWorkflowServiceServerMockRecorder) ListDeployments(arg0, arg1 interface{}) *gomock.Call
ListDeployments indicates an expected call of ListDeployments.
func (*MockWorkflowServiceServerMockRecorder) ListNamespaces ¶
func (mr *MockWorkflowServiceServerMockRecorder) ListNamespaces(arg0, arg1 interface{}) *gomock.Call
ListNamespaces indicates an expected call of ListNamespaces.
func (*MockWorkflowServiceServerMockRecorder) ListOpenWorkflowExecutions ¶
func (mr *MockWorkflowServiceServerMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.
func (*MockWorkflowServiceServerMockRecorder) ListScheduleMatchingTimes ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) ListScheduleMatchingTimes(arg0, arg1 interface{}) *gomock.Call
ListScheduleMatchingTimes indicates an expected call of ListScheduleMatchingTimes.
func (*MockWorkflowServiceServerMockRecorder) ListSchedules ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) ListSchedules(arg0, arg1 interface{}) *gomock.Call
ListSchedules indicates an expected call of ListSchedules.
func (*MockWorkflowServiceServerMockRecorder) ListTaskQueuePartitions ¶
func (mr *MockWorkflowServiceServerMockRecorder) ListTaskQueuePartitions(arg0, arg1 interface{}) *gomock.Call
ListTaskQueuePartitions indicates an expected call of ListTaskQueuePartitions.
func (*MockWorkflowServiceServerMockRecorder) ListWorkflowExecutions ¶
func (mr *MockWorkflowServiceServerMockRecorder) ListWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.
func (*MockWorkflowServiceServerMockRecorder) PatchSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) PatchSchedule(arg0, arg1 interface{}) *gomock.Call
PatchSchedule indicates an expected call of PatchSchedule.
func (*MockWorkflowServiceServerMockRecorder) PauseActivityById ¶ added in v1.41.0
func (mr *MockWorkflowServiceServerMockRecorder) PauseActivityById(arg0, arg1 interface{}) *gomock.Call
PauseActivityById indicates an expected call of PauseActivityById.
func (*MockWorkflowServiceServerMockRecorder) PollActivityTaskQueue ¶
func (mr *MockWorkflowServiceServerMockRecorder) PollActivityTaskQueue(arg0, arg1 interface{}) *gomock.Call
PollActivityTaskQueue indicates an expected call of PollActivityTaskQueue.
func (*MockWorkflowServiceServerMockRecorder) PollNexusTaskQueue ¶ added in v1.27.0
func (mr *MockWorkflowServiceServerMockRecorder) PollNexusTaskQueue(arg0, arg1 interface{}) *gomock.Call
PollNexusTaskQueue indicates an expected call of PollNexusTaskQueue.
func (*MockWorkflowServiceServerMockRecorder) PollWorkflowExecutionUpdate ¶ added in v1.21.0
func (mr *MockWorkflowServiceServerMockRecorder) PollWorkflowExecutionUpdate(arg0, arg1 interface{}) *gomock.Call
PollWorkflowExecutionUpdate indicates an expected call of PollWorkflowExecutionUpdate.
func (*MockWorkflowServiceServerMockRecorder) PollWorkflowTaskQueue ¶
func (mr *MockWorkflowServiceServerMockRecorder) PollWorkflowTaskQueue(arg0, arg1 interface{}) *gomock.Call
PollWorkflowTaskQueue indicates an expected call of PollWorkflowTaskQueue.
func (*MockWorkflowServiceServerMockRecorder) QueryWorkflow ¶
func (mr *MockWorkflowServiceServerMockRecorder) QueryWorkflow(arg0, arg1 interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockWorkflowServiceServerMockRecorder) RecordActivityTaskHeartbeat ¶
func (mr *MockWorkflowServiceServerMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 interface{}) *gomock.Call
RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.
func (*MockWorkflowServiceServerMockRecorder) RecordActivityTaskHeartbeatById ¶
func (mr *MockWorkflowServiceServerMockRecorder) RecordActivityTaskHeartbeatById(arg0, arg1 interface{}) *gomock.Call
RecordActivityTaskHeartbeatById indicates an expected call of RecordActivityTaskHeartbeatById.
func (*MockWorkflowServiceServerMockRecorder) RegisterNamespace ¶
func (mr *MockWorkflowServiceServerMockRecorder) RegisterNamespace(arg0, arg1 interface{}) *gomock.Call
RegisterNamespace indicates an expected call of RegisterNamespace.
func (*MockWorkflowServiceServerMockRecorder) RequestCancelWorkflowExecution ¶
func (mr *MockWorkflowServiceServerMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) ResetActivityById ¶ added in v1.41.0
func (mr *MockWorkflowServiceServerMockRecorder) ResetActivityById(arg0, arg1 interface{}) *gomock.Call
ResetActivityById indicates an expected call of ResetActivityById.
func (*MockWorkflowServiceServerMockRecorder) ResetStickyTaskQueue ¶
func (mr *MockWorkflowServiceServerMockRecorder) ResetStickyTaskQueue(arg0, arg1 interface{}) *gomock.Call
ResetStickyTaskQueue indicates an expected call of ResetStickyTaskQueue.
func (*MockWorkflowServiceServerMockRecorder) ResetWorkflowExecution ¶
func (mr *MockWorkflowServiceServerMockRecorder) ResetWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) RespondActivityTaskCanceled ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskCanceled(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.
func (*MockWorkflowServiceServerMockRecorder) RespondActivityTaskCanceledById ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskCanceledById(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskCanceledById indicates an expected call of RespondActivityTaskCanceledById.
func (*MockWorkflowServiceServerMockRecorder) RespondActivityTaskCompleted ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskCompleted(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.
func (*MockWorkflowServiceServerMockRecorder) RespondActivityTaskCompletedById ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskCompletedById(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskCompletedById indicates an expected call of RespondActivityTaskCompletedById.
func (*MockWorkflowServiceServerMockRecorder) RespondActivityTaskFailed ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskFailed(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.
func (*MockWorkflowServiceServerMockRecorder) RespondActivityTaskFailedById ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondActivityTaskFailedById(arg0, arg1 interface{}) *gomock.Call
RespondActivityTaskFailedById indicates an expected call of RespondActivityTaskFailedById.
func (*MockWorkflowServiceServerMockRecorder) RespondNexusTaskCompleted ¶ added in v1.27.0
func (mr *MockWorkflowServiceServerMockRecorder) RespondNexusTaskCompleted(arg0, arg1 interface{}) *gomock.Call
RespondNexusTaskCompleted indicates an expected call of RespondNexusTaskCompleted.
func (*MockWorkflowServiceServerMockRecorder) RespondNexusTaskFailed ¶ added in v1.27.0
func (mr *MockWorkflowServiceServerMockRecorder) RespondNexusTaskFailed(arg0, arg1 interface{}) *gomock.Call
RespondNexusTaskFailed indicates an expected call of RespondNexusTaskFailed.
func (*MockWorkflowServiceServerMockRecorder) RespondQueryTaskCompleted ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondQueryTaskCompleted(arg0, arg1 interface{}) *gomock.Call
RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.
func (*MockWorkflowServiceServerMockRecorder) RespondWorkflowTaskCompleted ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondWorkflowTaskCompleted(arg0, arg1 interface{}) *gomock.Call
RespondWorkflowTaskCompleted indicates an expected call of RespondWorkflowTaskCompleted.
func (*MockWorkflowServiceServerMockRecorder) RespondWorkflowTaskFailed ¶
func (mr *MockWorkflowServiceServerMockRecorder) RespondWorkflowTaskFailed(arg0, arg1 interface{}) *gomock.Call
RespondWorkflowTaskFailed indicates an expected call of RespondWorkflowTaskFailed.
func (*MockWorkflowServiceServerMockRecorder) ScanWorkflowExecutions ¶
func (mr *MockWorkflowServiceServerMockRecorder) ScanWorkflowExecutions(arg0, arg1 interface{}) *gomock.Call
ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.
func (*MockWorkflowServiceServerMockRecorder) SetCurrentDeployment ¶ added in v1.43.0
func (mr *MockWorkflowServiceServerMockRecorder) SetCurrentDeployment(arg0, arg1 interface{}) *gomock.Call
SetCurrentDeployment indicates an expected call of SetCurrentDeployment.
func (*MockWorkflowServiceServerMockRecorder) ShutdownWorker ¶ added in v1.39.0
func (mr *MockWorkflowServiceServerMockRecorder) ShutdownWorker(arg0, arg1 interface{}) *gomock.Call
ShutdownWorker indicates an expected call of ShutdownWorker.
func (*MockWorkflowServiceServerMockRecorder) SignalWithStartWorkflowExecution ¶
func (mr *MockWorkflowServiceServerMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) SignalWorkflowExecution ¶
func (mr *MockWorkflowServiceServerMockRecorder) SignalWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) StartBatchOperation ¶ added in v1.12.0
func (mr *MockWorkflowServiceServerMockRecorder) StartBatchOperation(arg0, arg1 interface{}) *gomock.Call
StartBatchOperation indicates an expected call of StartBatchOperation.
func (*MockWorkflowServiceServerMockRecorder) StartWorkflowExecution ¶
func (mr *MockWorkflowServiceServerMockRecorder) StartWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
StartWorkflowExecution indicates an expected call of StartWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) StopBatchOperation ¶ added in v1.12.0
func (mr *MockWorkflowServiceServerMockRecorder) StopBatchOperation(arg0, arg1 interface{}) *gomock.Call
StopBatchOperation indicates an expected call of StopBatchOperation.
func (*MockWorkflowServiceServerMockRecorder) TerminateWorkflowExecution ¶
func (mr *MockWorkflowServiceServerMockRecorder) TerminateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) UnpauseActivityById ¶ added in v1.41.0
func (mr *MockWorkflowServiceServerMockRecorder) UnpauseActivityById(arg0, arg1 interface{}) *gomock.Call
UnpauseActivityById indicates an expected call of UnpauseActivityById.
func (*MockWorkflowServiceServerMockRecorder) UpdateActivityOptionsById ¶ added in v1.40.0
func (mr *MockWorkflowServiceServerMockRecorder) UpdateActivityOptionsById(arg0, arg1 interface{}) *gomock.Call
UpdateActivityOptionsById indicates an expected call of UpdateActivityOptionsById.
func (*MockWorkflowServiceServerMockRecorder) UpdateNamespace ¶
func (mr *MockWorkflowServiceServerMockRecorder) UpdateNamespace(arg0, arg1 interface{}) *gomock.Call
UpdateNamespace indicates an expected call of UpdateNamespace.
func (*MockWorkflowServiceServerMockRecorder) UpdateSchedule ¶ added in v1.8.0
func (mr *MockWorkflowServiceServerMockRecorder) UpdateSchedule(arg0, arg1 interface{}) *gomock.Call
UpdateSchedule indicates an expected call of UpdateSchedule.
func (*MockWorkflowServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockWorkflowServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.
func (*MockWorkflowServiceServerMockRecorder) UpdateWorkerVersioningRules ¶ added in v1.32.0
func (mr *MockWorkflowServiceServerMockRecorder) UpdateWorkerVersioningRules(arg0, arg1 interface{}) *gomock.Call
UpdateWorkerVersioningRules indicates an expected call of UpdateWorkerVersioningRules.
func (*MockWorkflowServiceServerMockRecorder) UpdateWorkflowExecution ¶ added in v1.16.0
func (mr *MockWorkflowServiceServerMockRecorder) UpdateWorkflowExecution(arg0, arg1 interface{}) *gomock.Call
UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
func (*MockWorkflowServiceServerMockRecorder) UpdateWorkflowExecutionOptions ¶ added in v1.43.0
func (mr *MockWorkflowServiceServerMockRecorder) UpdateWorkflowExecutionOptions(arg0, arg1 interface{}) *gomock.Call
UpdateWorkflowExecutionOptions indicates an expected call of UpdateWorkflowExecutionOptions.