Files
tasks/common/testing/mockapi/workflowservicemock/v1/service_grpc.pb.mock.go

1707 lines
82 KiB
Go

// The MIT License
//
// Copyright (c) 2020 Temporal Technologies Inc. All rights reserved.
//
// Copyright (c) 2020 Uber Technologies, Inc.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
// Code generated by MockGen. DO NOT EDIT.
// Source: go.temporal.io/api/workflowservice/v1 (interfaces: WorkflowServiceClient)
//
// Generated by this command:
//
// mockgen -copyright_file ../../../LICENSE -package workflowservicemock -destination workflowservicemock/v1/service_grpc.pb.mock.go go.temporal.io/api/workflowservice/v1 WorkflowServiceClient
//
// Package workflowservicemock is a generated GoMock package.
package workflowservicemock
import (
context "context"
reflect "reflect"
workflowservice "go.temporal.io/api/workflowservice/v1"
gomock "go.uber.org/mock/gomock"
grpc "google.golang.org/grpc"
)
// MockWorkflowServiceClient is a mock of WorkflowServiceClient interface.
type MockWorkflowServiceClient struct {
ctrl *gomock.Controller
recorder *MockWorkflowServiceClientMockRecorder
}
// MockWorkflowServiceClientMockRecorder is the mock recorder for MockWorkflowServiceClient.
type MockWorkflowServiceClientMockRecorder struct {
mock *MockWorkflowServiceClient
}
// NewMockWorkflowServiceClient creates a new mock instance.
func NewMockWorkflowServiceClient(ctrl *gomock.Controller) *MockWorkflowServiceClient {
mock := &MockWorkflowServiceClient{ctrl: ctrl}
mock.recorder = &MockWorkflowServiceClientMockRecorder{mock}
return mock
}
// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockWorkflowServiceClient) EXPECT() *MockWorkflowServiceClientMockRecorder {
return m.recorder
}
// CountWorkflowExecutions mocks base method.
func (m *MockWorkflowServiceClient) CountWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.CountWorkflowExecutionsRequest, arg2 ...grpc.CallOption) (*workflowservice.CountWorkflowExecutionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "CountWorkflowExecutions", varargs...)
ret0, _ := ret[0].(*workflowservice.CountWorkflowExecutionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.
func (mr *MockWorkflowServiceClientMockRecorder) CountWorkflowExecutions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CountWorkflowExecutions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).CountWorkflowExecutions), varargs...)
}
// CreateSchedule mocks base method.
func (m *MockWorkflowServiceClient) CreateSchedule(arg0 context.Context, arg1 *workflowservice.CreateScheduleRequest, arg2 ...grpc.CallOption) (*workflowservice.CreateScheduleResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "CreateSchedule", varargs...)
ret0, _ := ret[0].(*workflowservice.CreateScheduleResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// CreateSchedule indicates an expected call of CreateSchedule.
func (mr *MockWorkflowServiceClientMockRecorder) CreateSchedule(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreateSchedule", reflect.TypeOf((*MockWorkflowServiceClient)(nil).CreateSchedule), varargs...)
}
// DeleteSchedule mocks base method.
func (m *MockWorkflowServiceClient) DeleteSchedule(arg0 context.Context, arg1 *workflowservice.DeleteScheduleRequest, arg2 ...grpc.CallOption) (*workflowservice.DeleteScheduleResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DeleteSchedule", varargs...)
ret0, _ := ret[0].(*workflowservice.DeleteScheduleResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeleteSchedule indicates an expected call of DeleteSchedule.
func (mr *MockWorkflowServiceClientMockRecorder) DeleteSchedule(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteSchedule", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DeleteSchedule), varargs...)
}
// DeleteWorkerDeployment mocks base method.
func (m *MockWorkflowServiceClient) DeleteWorkerDeployment(arg0 context.Context, arg1 *workflowservice.DeleteWorkerDeploymentRequest, arg2 ...grpc.CallOption) (*workflowservice.DeleteWorkerDeploymentResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DeleteWorkerDeployment", varargs...)
ret0, _ := ret[0].(*workflowservice.DeleteWorkerDeploymentResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeleteWorkerDeployment indicates an expected call of DeleteWorkerDeployment.
func (mr *MockWorkflowServiceClientMockRecorder) DeleteWorkerDeployment(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteWorkerDeployment", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DeleteWorkerDeployment), varargs...)
}
// DeleteWorkerDeploymentVersion mocks base method.
func (m *MockWorkflowServiceClient) DeleteWorkerDeploymentVersion(arg0 context.Context, arg1 *workflowservice.DeleteWorkerDeploymentVersionRequest, arg2 ...grpc.CallOption) (*workflowservice.DeleteWorkerDeploymentVersionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DeleteWorkerDeploymentVersion", varargs...)
ret0, _ := ret[0].(*workflowservice.DeleteWorkerDeploymentVersionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeleteWorkerDeploymentVersion indicates an expected call of DeleteWorkerDeploymentVersion.
func (mr *MockWorkflowServiceClientMockRecorder) DeleteWorkerDeploymentVersion(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteWorkerDeploymentVersion", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DeleteWorkerDeploymentVersion), varargs...)
}
// DeleteWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) DeleteWorkflowExecution(arg0 context.Context, arg1 *workflowservice.DeleteWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.DeleteWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DeleteWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.DeleteWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) DeleteWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DeleteWorkflowExecution), varargs...)
}
// DeprecateNamespace mocks base method.
func (m *MockWorkflowServiceClient) DeprecateNamespace(arg0 context.Context, arg1 *workflowservice.DeprecateNamespaceRequest, arg2 ...grpc.CallOption) (*workflowservice.DeprecateNamespaceResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DeprecateNamespace", varargs...)
ret0, _ := ret[0].(*workflowservice.DeprecateNamespaceResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DeprecateNamespace indicates an expected call of DeprecateNamespace.
func (mr *MockWorkflowServiceClientMockRecorder) DeprecateNamespace(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeprecateNamespace", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DeprecateNamespace), varargs...)
}
// DescribeBatchOperation mocks base method.
func (m *MockWorkflowServiceClient) DescribeBatchOperation(arg0 context.Context, arg1 *workflowservice.DescribeBatchOperationRequest, arg2 ...grpc.CallOption) (*workflowservice.DescribeBatchOperationResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DescribeBatchOperation", varargs...)
ret0, _ := ret[0].(*workflowservice.DescribeBatchOperationResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DescribeBatchOperation indicates an expected call of DescribeBatchOperation.
func (mr *MockWorkflowServiceClientMockRecorder) DescribeBatchOperation(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeBatchOperation", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DescribeBatchOperation), varargs...)
}
// DescribeDeployment mocks base method.
func (m *MockWorkflowServiceClient) DescribeDeployment(arg0 context.Context, arg1 *workflowservice.DescribeDeploymentRequest, arg2 ...grpc.CallOption) (*workflowservice.DescribeDeploymentResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DescribeDeployment", varargs...)
ret0, _ := ret[0].(*workflowservice.DescribeDeploymentResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DescribeDeployment indicates an expected call of DescribeDeployment.
func (mr *MockWorkflowServiceClientMockRecorder) DescribeDeployment(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeDeployment", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DescribeDeployment), varargs...)
}
// DescribeNamespace mocks base method.
func (m *MockWorkflowServiceClient) DescribeNamespace(arg0 context.Context, arg1 *workflowservice.DescribeNamespaceRequest, arg2 ...grpc.CallOption) (*workflowservice.DescribeNamespaceResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DescribeNamespace", varargs...)
ret0, _ := ret[0].(*workflowservice.DescribeNamespaceResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DescribeNamespace indicates an expected call of DescribeNamespace.
func (mr *MockWorkflowServiceClientMockRecorder) DescribeNamespace(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeNamespace", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DescribeNamespace), varargs...)
}
// DescribeSchedule mocks base method.
func (m *MockWorkflowServiceClient) DescribeSchedule(arg0 context.Context, arg1 *workflowservice.DescribeScheduleRequest, arg2 ...grpc.CallOption) (*workflowservice.DescribeScheduleResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DescribeSchedule", varargs...)
ret0, _ := ret[0].(*workflowservice.DescribeScheduleResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DescribeSchedule indicates an expected call of DescribeSchedule.
func (mr *MockWorkflowServiceClientMockRecorder) DescribeSchedule(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeSchedule", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DescribeSchedule), varargs...)
}
// DescribeTaskQueue mocks base method.
func (m *MockWorkflowServiceClient) DescribeTaskQueue(arg0 context.Context, arg1 *workflowservice.DescribeTaskQueueRequest, arg2 ...grpc.CallOption) (*workflowservice.DescribeTaskQueueResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DescribeTaskQueue", varargs...)
ret0, _ := ret[0].(*workflowservice.DescribeTaskQueueResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (mr *MockWorkflowServiceClientMockRecorder) DescribeTaskQueue(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeTaskQueue", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DescribeTaskQueue), varargs...)
}
// DescribeWorkerDeployment mocks base method.
func (m *MockWorkflowServiceClient) DescribeWorkerDeployment(arg0 context.Context, arg1 *workflowservice.DescribeWorkerDeploymentRequest, arg2 ...grpc.CallOption) (*workflowservice.DescribeWorkerDeploymentResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DescribeWorkerDeployment", varargs...)
ret0, _ := ret[0].(*workflowservice.DescribeWorkerDeploymentResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DescribeWorkerDeployment indicates an expected call of DescribeWorkerDeployment.
func (mr *MockWorkflowServiceClientMockRecorder) DescribeWorkerDeployment(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeWorkerDeployment", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DescribeWorkerDeployment), varargs...)
}
// DescribeWorkerDeploymentVersion mocks base method.
func (m *MockWorkflowServiceClient) DescribeWorkerDeploymentVersion(arg0 context.Context, arg1 *workflowservice.DescribeWorkerDeploymentVersionRequest, arg2 ...grpc.CallOption) (*workflowservice.DescribeWorkerDeploymentVersionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DescribeWorkerDeploymentVersion", varargs...)
ret0, _ := ret[0].(*workflowservice.DescribeWorkerDeploymentVersionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DescribeWorkerDeploymentVersion indicates an expected call of DescribeWorkerDeploymentVersion.
func (mr *MockWorkflowServiceClientMockRecorder) DescribeWorkerDeploymentVersion(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeWorkerDeploymentVersion", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DescribeWorkerDeploymentVersion), varargs...)
}
// DescribeWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) DescribeWorkflowExecution(arg0 context.Context, arg1 *workflowservice.DescribeWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.DescribeWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "DescribeWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.DescribeWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// DescribeWorkflowExecution indicates an expected call of DescribeWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) DescribeWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).DescribeWorkflowExecution), varargs...)
}
// ExecuteMultiOperation mocks base method.
func (m *MockWorkflowServiceClient) ExecuteMultiOperation(arg0 context.Context, arg1 *workflowservice.ExecuteMultiOperationRequest, arg2 ...grpc.CallOption) (*workflowservice.ExecuteMultiOperationResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ExecuteMultiOperation", varargs...)
ret0, _ := ret[0].(*workflowservice.ExecuteMultiOperationResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ExecuteMultiOperation indicates an expected call of ExecuteMultiOperation.
func (mr *MockWorkflowServiceClientMockRecorder) ExecuteMultiOperation(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ExecuteMultiOperation", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ExecuteMultiOperation), varargs...)
}
// GetClusterInfo mocks base method.
func (m *MockWorkflowServiceClient) GetClusterInfo(arg0 context.Context, arg1 *workflowservice.GetClusterInfoRequest, arg2 ...grpc.CallOption) (*workflowservice.GetClusterInfoResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetClusterInfo", varargs...)
ret0, _ := ret[0].(*workflowservice.GetClusterInfoResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetClusterInfo indicates an expected call of GetClusterInfo.
func (mr *MockWorkflowServiceClientMockRecorder) GetClusterInfo(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetClusterInfo", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetClusterInfo), varargs...)
}
// GetCurrentDeployment mocks base method.
func (m *MockWorkflowServiceClient) GetCurrentDeployment(arg0 context.Context, arg1 *workflowservice.GetCurrentDeploymentRequest, arg2 ...grpc.CallOption) (*workflowservice.GetCurrentDeploymentResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetCurrentDeployment", varargs...)
ret0, _ := ret[0].(*workflowservice.GetCurrentDeploymentResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetCurrentDeployment indicates an expected call of GetCurrentDeployment.
func (mr *MockWorkflowServiceClientMockRecorder) GetCurrentDeployment(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetCurrentDeployment", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetCurrentDeployment), varargs...)
}
// GetDeploymentReachability mocks base method.
func (m *MockWorkflowServiceClient) GetDeploymentReachability(arg0 context.Context, arg1 *workflowservice.GetDeploymentReachabilityRequest, arg2 ...grpc.CallOption) (*workflowservice.GetDeploymentReachabilityResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetDeploymentReachability", varargs...)
ret0, _ := ret[0].(*workflowservice.GetDeploymentReachabilityResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetDeploymentReachability indicates an expected call of GetDeploymentReachability.
func (mr *MockWorkflowServiceClientMockRecorder) GetDeploymentReachability(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetDeploymentReachability", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetDeploymentReachability), varargs...)
}
// GetSearchAttributes mocks base method.
func (m *MockWorkflowServiceClient) GetSearchAttributes(arg0 context.Context, arg1 *workflowservice.GetSearchAttributesRequest, arg2 ...grpc.CallOption) (*workflowservice.GetSearchAttributesResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetSearchAttributes", varargs...)
ret0, _ := ret[0].(*workflowservice.GetSearchAttributesResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetSearchAttributes indicates an expected call of GetSearchAttributes.
func (mr *MockWorkflowServiceClientMockRecorder) GetSearchAttributes(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetSearchAttributes", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetSearchAttributes), varargs...)
}
// GetSystemInfo mocks base method.
func (m *MockWorkflowServiceClient) GetSystemInfo(arg0 context.Context, arg1 *workflowservice.GetSystemInfoRequest, arg2 ...grpc.CallOption) (*workflowservice.GetSystemInfoResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetSystemInfo", varargs...)
ret0, _ := ret[0].(*workflowservice.GetSystemInfoResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetSystemInfo indicates an expected call of GetSystemInfo.
func (mr *MockWorkflowServiceClientMockRecorder) GetSystemInfo(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetSystemInfo", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetSystemInfo), varargs...)
}
// GetWorkerBuildIdCompatibility mocks base method.
func (m *MockWorkflowServiceClient) GetWorkerBuildIdCompatibility(arg0 context.Context, arg1 *workflowservice.GetWorkerBuildIdCompatibilityRequest, arg2 ...grpc.CallOption) (*workflowservice.GetWorkerBuildIdCompatibilityResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetWorkerBuildIdCompatibility", varargs...)
ret0, _ := ret[0].(*workflowservice.GetWorkerBuildIdCompatibilityResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkerBuildIdCompatibility", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetWorkerBuildIdCompatibility), varargs...)
}
// GetWorkerTaskReachability mocks base method.
func (m *MockWorkflowServiceClient) GetWorkerTaskReachability(arg0 context.Context, arg1 *workflowservice.GetWorkerTaskReachabilityRequest, arg2 ...grpc.CallOption) (*workflowservice.GetWorkerTaskReachabilityResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetWorkerTaskReachability", varargs...)
ret0, _ := ret[0].(*workflowservice.GetWorkerTaskReachabilityResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetWorkerTaskReachability indicates an expected call of GetWorkerTaskReachability.
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerTaskReachability(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkerTaskReachability", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetWorkerTaskReachability), varargs...)
}
// GetWorkerVersioningRules mocks base method.
func (m *MockWorkflowServiceClient) GetWorkerVersioningRules(arg0 context.Context, arg1 *workflowservice.GetWorkerVersioningRulesRequest, arg2 ...grpc.CallOption) (*workflowservice.GetWorkerVersioningRulesResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetWorkerVersioningRules", varargs...)
ret0, _ := ret[0].(*workflowservice.GetWorkerVersioningRulesResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetWorkerVersioningRules indicates an expected call of GetWorkerVersioningRules.
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkerVersioningRules(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkerVersioningRules", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetWorkerVersioningRules), varargs...)
}
// GetWorkflowExecutionHistory mocks base method.
func (m *MockWorkflowServiceClient) GetWorkflowExecutionHistory(arg0 context.Context, arg1 *workflowservice.GetWorkflowExecutionHistoryRequest, arg2 ...grpc.CallOption) (*workflowservice.GetWorkflowExecutionHistoryResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetWorkflowExecutionHistory", varargs...)
ret0, _ := ret[0].(*workflowservice.GetWorkflowExecutionHistoryResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetWorkflowExecutionHistory indicates an expected call of GetWorkflowExecutionHistory.
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkflowExecutionHistory(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowExecutionHistory", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetWorkflowExecutionHistory), varargs...)
}
// GetWorkflowExecutionHistoryReverse mocks base method.
func (m *MockWorkflowServiceClient) GetWorkflowExecutionHistoryReverse(arg0 context.Context, arg1 *workflowservice.GetWorkflowExecutionHistoryReverseRequest, arg2 ...grpc.CallOption) (*workflowservice.GetWorkflowExecutionHistoryReverseResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "GetWorkflowExecutionHistoryReverse", varargs...)
ret0, _ := ret[0].(*workflowservice.GetWorkflowExecutionHistoryReverseResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetWorkflowExecutionHistoryReverse indicates an expected call of GetWorkflowExecutionHistoryReverse.
func (mr *MockWorkflowServiceClientMockRecorder) GetWorkflowExecutionHistoryReverse(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowExecutionHistoryReverse", reflect.TypeOf((*MockWorkflowServiceClient)(nil).GetWorkflowExecutionHistoryReverse), varargs...)
}
// ListArchivedWorkflowExecutions mocks base method.
func (m *MockWorkflowServiceClient) ListArchivedWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListArchivedWorkflowExecutionsRequest, arg2 ...grpc.CallOption) (*workflowservice.ListArchivedWorkflowExecutionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListArchivedWorkflowExecutions", varargs...)
ret0, _ := ret[0].(*workflowservice.ListArchivedWorkflowExecutionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListArchivedWorkflowExecutions indicates an expected call of ListArchivedWorkflowExecutions.
func (mr *MockWorkflowServiceClientMockRecorder) ListArchivedWorkflowExecutions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListArchivedWorkflowExecutions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListArchivedWorkflowExecutions), varargs...)
}
// ListBatchOperations mocks base method.
func (m *MockWorkflowServiceClient) ListBatchOperations(arg0 context.Context, arg1 *workflowservice.ListBatchOperationsRequest, arg2 ...grpc.CallOption) (*workflowservice.ListBatchOperationsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListBatchOperations", varargs...)
ret0, _ := ret[0].(*workflowservice.ListBatchOperationsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListBatchOperations indicates an expected call of ListBatchOperations.
func (mr *MockWorkflowServiceClientMockRecorder) ListBatchOperations(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListBatchOperations", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListBatchOperations), varargs...)
}
// ListClosedWorkflowExecutions mocks base method.
func (m *MockWorkflowServiceClient) ListClosedWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListClosedWorkflowExecutionsRequest, arg2 ...grpc.CallOption) (*workflowservice.ListClosedWorkflowExecutionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListClosedWorkflowExecutions", varargs...)
ret0, _ := ret[0].(*workflowservice.ListClosedWorkflowExecutionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.
func (mr *MockWorkflowServiceClientMockRecorder) ListClosedWorkflowExecutions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListClosedWorkflowExecutions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListClosedWorkflowExecutions), varargs...)
}
// ListDeployments mocks base method.
func (m *MockWorkflowServiceClient) ListDeployments(arg0 context.Context, arg1 *workflowservice.ListDeploymentsRequest, arg2 ...grpc.CallOption) (*workflowservice.ListDeploymentsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListDeployments", varargs...)
ret0, _ := ret[0].(*workflowservice.ListDeploymentsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListDeployments indicates an expected call of ListDeployments.
func (mr *MockWorkflowServiceClientMockRecorder) ListDeployments(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListDeployments", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListDeployments), varargs...)
}
// ListNamespaces mocks base method.
func (m *MockWorkflowServiceClient) ListNamespaces(arg0 context.Context, arg1 *workflowservice.ListNamespacesRequest, arg2 ...grpc.CallOption) (*workflowservice.ListNamespacesResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListNamespaces", varargs...)
ret0, _ := ret[0].(*workflowservice.ListNamespacesResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListNamespaces indicates an expected call of ListNamespaces.
func (mr *MockWorkflowServiceClientMockRecorder) ListNamespaces(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListNamespaces", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListNamespaces), varargs...)
}
// ListOpenWorkflowExecutions mocks base method.
func (m *MockWorkflowServiceClient) ListOpenWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListOpenWorkflowExecutionsRequest, arg2 ...grpc.CallOption) (*workflowservice.ListOpenWorkflowExecutionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListOpenWorkflowExecutions", varargs...)
ret0, _ := ret[0].(*workflowservice.ListOpenWorkflowExecutionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.
func (mr *MockWorkflowServiceClientMockRecorder) ListOpenWorkflowExecutions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListOpenWorkflowExecutions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListOpenWorkflowExecutions), varargs...)
}
// ListScheduleMatchingTimes mocks base method.
func (m *MockWorkflowServiceClient) ListScheduleMatchingTimes(arg0 context.Context, arg1 *workflowservice.ListScheduleMatchingTimesRequest, arg2 ...grpc.CallOption) (*workflowservice.ListScheduleMatchingTimesResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListScheduleMatchingTimes", varargs...)
ret0, _ := ret[0].(*workflowservice.ListScheduleMatchingTimesResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListScheduleMatchingTimes indicates an expected call of ListScheduleMatchingTimes.
func (mr *MockWorkflowServiceClientMockRecorder) ListScheduleMatchingTimes(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListScheduleMatchingTimes", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListScheduleMatchingTimes), varargs...)
}
// ListSchedules mocks base method.
func (m *MockWorkflowServiceClient) ListSchedules(arg0 context.Context, arg1 *workflowservice.ListSchedulesRequest, arg2 ...grpc.CallOption) (*workflowservice.ListSchedulesResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListSchedules", varargs...)
ret0, _ := ret[0].(*workflowservice.ListSchedulesResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListSchedules indicates an expected call of ListSchedules.
func (mr *MockWorkflowServiceClientMockRecorder) ListSchedules(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListSchedules", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListSchedules), varargs...)
}
// ListTaskQueuePartitions mocks base method.
func (m *MockWorkflowServiceClient) ListTaskQueuePartitions(arg0 context.Context, arg1 *workflowservice.ListTaskQueuePartitionsRequest, arg2 ...grpc.CallOption) (*workflowservice.ListTaskQueuePartitionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListTaskQueuePartitions", varargs...)
ret0, _ := ret[0].(*workflowservice.ListTaskQueuePartitionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListTaskQueuePartitions indicates an expected call of ListTaskQueuePartitions.
func (mr *MockWorkflowServiceClientMockRecorder) ListTaskQueuePartitions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListTaskQueuePartitions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListTaskQueuePartitions), varargs...)
}
// ListWorkerDeployments mocks base method.
func (m *MockWorkflowServiceClient) ListWorkerDeployments(arg0 context.Context, arg1 *workflowservice.ListWorkerDeploymentsRequest, arg2 ...grpc.CallOption) (*workflowservice.ListWorkerDeploymentsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListWorkerDeployments", varargs...)
ret0, _ := ret[0].(*workflowservice.ListWorkerDeploymentsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListWorkerDeployments indicates an expected call of ListWorkerDeployments.
func (mr *MockWorkflowServiceClientMockRecorder) ListWorkerDeployments(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListWorkerDeployments", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListWorkerDeployments), varargs...)
}
// ListWorkflowExecutions mocks base method.
func (m *MockWorkflowServiceClient) ListWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ListWorkflowExecutionsRequest, arg2 ...grpc.CallOption) (*workflowservice.ListWorkflowExecutionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ListWorkflowExecutions", varargs...)
ret0, _ := ret[0].(*workflowservice.ListWorkflowExecutionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.
func (mr *MockWorkflowServiceClientMockRecorder) ListWorkflowExecutions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListWorkflowExecutions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ListWorkflowExecutions), varargs...)
}
// PatchSchedule mocks base method.
func (m *MockWorkflowServiceClient) PatchSchedule(arg0 context.Context, arg1 *workflowservice.PatchScheduleRequest, arg2 ...grpc.CallOption) (*workflowservice.PatchScheduleResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "PatchSchedule", varargs...)
ret0, _ := ret[0].(*workflowservice.PatchScheduleResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// PatchSchedule indicates an expected call of PatchSchedule.
func (mr *MockWorkflowServiceClientMockRecorder) PatchSchedule(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PatchSchedule", reflect.TypeOf((*MockWorkflowServiceClient)(nil).PatchSchedule), varargs...)
}
// PauseActivity mocks base method.
func (m *MockWorkflowServiceClient) PauseActivity(arg0 context.Context, arg1 *workflowservice.PauseActivityRequest, arg2 ...grpc.CallOption) (*workflowservice.PauseActivityResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "PauseActivity", varargs...)
ret0, _ := ret[0].(*workflowservice.PauseActivityResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// PauseActivity indicates an expected call of PauseActivity.
func (mr *MockWorkflowServiceClientMockRecorder) PauseActivity(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PauseActivity", reflect.TypeOf((*MockWorkflowServiceClient)(nil).PauseActivity), varargs...)
}
// PollActivityTaskQueue mocks base method.
func (m *MockWorkflowServiceClient) PollActivityTaskQueue(arg0 context.Context, arg1 *workflowservice.PollActivityTaskQueueRequest, arg2 ...grpc.CallOption) (*workflowservice.PollActivityTaskQueueResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "PollActivityTaskQueue", varargs...)
ret0, _ := ret[0].(*workflowservice.PollActivityTaskQueueResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// PollActivityTaskQueue indicates an expected call of PollActivityTaskQueue.
func (mr *MockWorkflowServiceClientMockRecorder) PollActivityTaskQueue(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PollActivityTaskQueue", reflect.TypeOf((*MockWorkflowServiceClient)(nil).PollActivityTaskQueue), varargs...)
}
// PollNexusTaskQueue mocks base method.
func (m *MockWorkflowServiceClient) PollNexusTaskQueue(arg0 context.Context, arg1 *workflowservice.PollNexusTaskQueueRequest, arg2 ...grpc.CallOption) (*workflowservice.PollNexusTaskQueueResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "PollNexusTaskQueue", varargs...)
ret0, _ := ret[0].(*workflowservice.PollNexusTaskQueueResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// PollNexusTaskQueue indicates an expected call of PollNexusTaskQueue.
func (mr *MockWorkflowServiceClientMockRecorder) PollNexusTaskQueue(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PollNexusTaskQueue", reflect.TypeOf((*MockWorkflowServiceClient)(nil).PollNexusTaskQueue), varargs...)
}
// PollWorkflowExecutionUpdate mocks base method.
func (m *MockWorkflowServiceClient) PollWorkflowExecutionUpdate(arg0 context.Context, arg1 *workflowservice.PollWorkflowExecutionUpdateRequest, arg2 ...grpc.CallOption) (*workflowservice.PollWorkflowExecutionUpdateResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "PollWorkflowExecutionUpdate", varargs...)
ret0, _ := ret[0].(*workflowservice.PollWorkflowExecutionUpdateResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// PollWorkflowExecutionUpdate indicates an expected call of PollWorkflowExecutionUpdate.
func (mr *MockWorkflowServiceClientMockRecorder) PollWorkflowExecutionUpdate(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PollWorkflowExecutionUpdate", reflect.TypeOf((*MockWorkflowServiceClient)(nil).PollWorkflowExecutionUpdate), varargs...)
}
// PollWorkflowTaskQueue mocks base method.
func (m *MockWorkflowServiceClient) PollWorkflowTaskQueue(arg0 context.Context, arg1 *workflowservice.PollWorkflowTaskQueueRequest, arg2 ...grpc.CallOption) (*workflowservice.PollWorkflowTaskQueueResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "PollWorkflowTaskQueue", varargs...)
ret0, _ := ret[0].(*workflowservice.PollWorkflowTaskQueueResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// PollWorkflowTaskQueue indicates an expected call of PollWorkflowTaskQueue.
func (mr *MockWorkflowServiceClientMockRecorder) PollWorkflowTaskQueue(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PollWorkflowTaskQueue", reflect.TypeOf((*MockWorkflowServiceClient)(nil).PollWorkflowTaskQueue), varargs...)
}
// QueryWorkflow mocks base method.
func (m *MockWorkflowServiceClient) QueryWorkflow(arg0 context.Context, arg1 *workflowservice.QueryWorkflowRequest, arg2 ...grpc.CallOption) (*workflowservice.QueryWorkflowResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "QueryWorkflow", varargs...)
ret0, _ := ret[0].(*workflowservice.QueryWorkflowResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// QueryWorkflow indicates an expected call of QueryWorkflow.
func (mr *MockWorkflowServiceClientMockRecorder) QueryWorkflow(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryWorkflow", reflect.TypeOf((*MockWorkflowServiceClient)(nil).QueryWorkflow), varargs...)
}
// RecordActivityTaskHeartbeat mocks base method.
func (m *MockWorkflowServiceClient) RecordActivityTaskHeartbeat(arg0 context.Context, arg1 *workflowservice.RecordActivityTaskHeartbeatRequest, arg2 ...grpc.CallOption) (*workflowservice.RecordActivityTaskHeartbeatResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RecordActivityTaskHeartbeat", varargs...)
ret0, _ := ret[0].(*workflowservice.RecordActivityTaskHeartbeatResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RecordActivityTaskHeartbeat indicates an expected call of RecordActivityTaskHeartbeat.
func (mr *MockWorkflowServiceClientMockRecorder) RecordActivityTaskHeartbeat(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RecordActivityTaskHeartbeat", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RecordActivityTaskHeartbeat), varargs...)
}
// RecordActivityTaskHeartbeatById mocks base method.
func (m *MockWorkflowServiceClient) RecordActivityTaskHeartbeatById(arg0 context.Context, arg1 *workflowservice.RecordActivityTaskHeartbeatByIdRequest, arg2 ...grpc.CallOption) (*workflowservice.RecordActivityTaskHeartbeatByIdResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RecordActivityTaskHeartbeatById", varargs...)
ret0, _ := ret[0].(*workflowservice.RecordActivityTaskHeartbeatByIdResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RecordActivityTaskHeartbeatById indicates an expected call of RecordActivityTaskHeartbeatById.
func (mr *MockWorkflowServiceClientMockRecorder) RecordActivityTaskHeartbeatById(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RecordActivityTaskHeartbeatById", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RecordActivityTaskHeartbeatById), varargs...)
}
// RegisterNamespace mocks base method.
func (m *MockWorkflowServiceClient) RegisterNamespace(arg0 context.Context, arg1 *workflowservice.RegisterNamespaceRequest, arg2 ...grpc.CallOption) (*workflowservice.RegisterNamespaceResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RegisterNamespace", varargs...)
ret0, _ := ret[0].(*workflowservice.RegisterNamespaceResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RegisterNamespace indicates an expected call of RegisterNamespace.
func (mr *MockWorkflowServiceClientMockRecorder) RegisterNamespace(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RegisterNamespace", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RegisterNamespace), varargs...)
}
// RequestCancelWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) RequestCancelWorkflowExecution(arg0 context.Context, arg1 *workflowservice.RequestCancelWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.RequestCancelWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RequestCancelWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.RequestCancelWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RequestCancelWorkflowExecution indicates an expected call of RequestCancelWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) RequestCancelWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RequestCancelWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RequestCancelWorkflowExecution), varargs...)
}
// ResetActivity mocks base method.
func (m *MockWorkflowServiceClient) ResetActivity(arg0 context.Context, arg1 *workflowservice.ResetActivityRequest, arg2 ...grpc.CallOption) (*workflowservice.ResetActivityResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ResetActivity", varargs...)
ret0, _ := ret[0].(*workflowservice.ResetActivityResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ResetActivity indicates an expected call of ResetActivity.
func (mr *MockWorkflowServiceClientMockRecorder) ResetActivity(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResetActivity", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ResetActivity), varargs...)
}
// ResetStickyTaskQueue mocks base method.
func (m *MockWorkflowServiceClient) ResetStickyTaskQueue(arg0 context.Context, arg1 *workflowservice.ResetStickyTaskQueueRequest, arg2 ...grpc.CallOption) (*workflowservice.ResetStickyTaskQueueResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ResetStickyTaskQueue", varargs...)
ret0, _ := ret[0].(*workflowservice.ResetStickyTaskQueueResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ResetStickyTaskQueue indicates an expected call of ResetStickyTaskQueue.
func (mr *MockWorkflowServiceClientMockRecorder) ResetStickyTaskQueue(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResetStickyTaskQueue", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ResetStickyTaskQueue), varargs...)
}
// ResetWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) ResetWorkflowExecution(arg0 context.Context, arg1 *workflowservice.ResetWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.ResetWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ResetWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.ResetWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ResetWorkflowExecution indicates an expected call of ResetWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) ResetWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResetWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ResetWorkflowExecution), varargs...)
}
// RespondActivityTaskCanceled mocks base method.
func (m *MockWorkflowServiceClient) RespondActivityTaskCanceled(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCanceledRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondActivityTaskCanceledResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondActivityTaskCanceled", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondActivityTaskCanceledResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondActivityTaskCanceled indicates an expected call of RespondActivityTaskCanceled.
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCanceled(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondActivityTaskCanceled", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondActivityTaskCanceled), varargs...)
}
// RespondActivityTaskCanceledById mocks base method.
func (m *MockWorkflowServiceClient) RespondActivityTaskCanceledById(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCanceledByIdRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondActivityTaskCanceledByIdResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondActivityTaskCanceledById", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondActivityTaskCanceledByIdResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondActivityTaskCanceledById indicates an expected call of RespondActivityTaskCanceledById.
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCanceledById(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondActivityTaskCanceledById", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondActivityTaskCanceledById), varargs...)
}
// RespondActivityTaskCompleted mocks base method.
func (m *MockWorkflowServiceClient) RespondActivityTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCompletedRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondActivityTaskCompletedResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondActivityTaskCompleted", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondActivityTaskCompletedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondActivityTaskCompleted indicates an expected call of RespondActivityTaskCompleted.
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCompleted(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondActivityTaskCompleted", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondActivityTaskCompleted), varargs...)
}
// RespondActivityTaskCompletedById mocks base method.
func (m *MockWorkflowServiceClient) RespondActivityTaskCompletedById(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskCompletedByIdRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondActivityTaskCompletedByIdResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondActivityTaskCompletedById", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondActivityTaskCompletedByIdResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondActivityTaskCompletedById indicates an expected call of RespondActivityTaskCompletedById.
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskCompletedById(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondActivityTaskCompletedById", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondActivityTaskCompletedById), varargs...)
}
// RespondActivityTaskFailed mocks base method.
func (m *MockWorkflowServiceClient) RespondActivityTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskFailedRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondActivityTaskFailedResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondActivityTaskFailed", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondActivityTaskFailedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondActivityTaskFailed indicates an expected call of RespondActivityTaskFailed.
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskFailed(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondActivityTaskFailed", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondActivityTaskFailed), varargs...)
}
// RespondActivityTaskFailedById mocks base method.
func (m *MockWorkflowServiceClient) RespondActivityTaskFailedById(arg0 context.Context, arg1 *workflowservice.RespondActivityTaskFailedByIdRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondActivityTaskFailedByIdResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondActivityTaskFailedById", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondActivityTaskFailedByIdResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondActivityTaskFailedById indicates an expected call of RespondActivityTaskFailedById.
func (mr *MockWorkflowServiceClientMockRecorder) RespondActivityTaskFailedById(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondActivityTaskFailedById", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondActivityTaskFailedById), varargs...)
}
// RespondNexusTaskCompleted mocks base method.
func (m *MockWorkflowServiceClient) RespondNexusTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondNexusTaskCompletedRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondNexusTaskCompletedResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondNexusTaskCompleted", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondNexusTaskCompletedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondNexusTaskCompleted indicates an expected call of RespondNexusTaskCompleted.
func (mr *MockWorkflowServiceClientMockRecorder) RespondNexusTaskCompleted(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondNexusTaskCompleted", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondNexusTaskCompleted), varargs...)
}
// RespondNexusTaskFailed mocks base method.
func (m *MockWorkflowServiceClient) RespondNexusTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondNexusTaskFailedRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondNexusTaskFailedResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondNexusTaskFailed", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondNexusTaskFailedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondNexusTaskFailed indicates an expected call of RespondNexusTaskFailed.
func (mr *MockWorkflowServiceClientMockRecorder) RespondNexusTaskFailed(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondNexusTaskFailed", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondNexusTaskFailed), varargs...)
}
// RespondQueryTaskCompleted mocks base method.
func (m *MockWorkflowServiceClient) RespondQueryTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondQueryTaskCompletedRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondQueryTaskCompletedResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondQueryTaskCompleted", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondQueryTaskCompletedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.
func (mr *MockWorkflowServiceClientMockRecorder) RespondQueryTaskCompleted(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondQueryTaskCompleted", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondQueryTaskCompleted), varargs...)
}
// RespondWorkflowTaskCompleted mocks base method.
func (m *MockWorkflowServiceClient) RespondWorkflowTaskCompleted(arg0 context.Context, arg1 *workflowservice.RespondWorkflowTaskCompletedRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondWorkflowTaskCompletedResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondWorkflowTaskCompleted", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondWorkflowTaskCompletedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondWorkflowTaskCompleted indicates an expected call of RespondWorkflowTaskCompleted.
func (mr *MockWorkflowServiceClientMockRecorder) RespondWorkflowTaskCompleted(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondWorkflowTaskCompleted", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondWorkflowTaskCompleted), varargs...)
}
// RespondWorkflowTaskFailed mocks base method.
func (m *MockWorkflowServiceClient) RespondWorkflowTaskFailed(arg0 context.Context, arg1 *workflowservice.RespondWorkflowTaskFailedRequest, arg2 ...grpc.CallOption) (*workflowservice.RespondWorkflowTaskFailedResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "RespondWorkflowTaskFailed", varargs...)
ret0, _ := ret[0].(*workflowservice.RespondWorkflowTaskFailedResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// RespondWorkflowTaskFailed indicates an expected call of RespondWorkflowTaskFailed.
func (mr *MockWorkflowServiceClientMockRecorder) RespondWorkflowTaskFailed(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RespondWorkflowTaskFailed", reflect.TypeOf((*MockWorkflowServiceClient)(nil).RespondWorkflowTaskFailed), varargs...)
}
// ScanWorkflowExecutions mocks base method.
func (m *MockWorkflowServiceClient) ScanWorkflowExecutions(arg0 context.Context, arg1 *workflowservice.ScanWorkflowExecutionsRequest, arg2 ...grpc.CallOption) (*workflowservice.ScanWorkflowExecutionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ScanWorkflowExecutions", varargs...)
ret0, _ := ret[0].(*workflowservice.ScanWorkflowExecutionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.
func (mr *MockWorkflowServiceClientMockRecorder) ScanWorkflowExecutions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ScanWorkflowExecutions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ScanWorkflowExecutions), varargs...)
}
// SetCurrentDeployment mocks base method.
func (m *MockWorkflowServiceClient) SetCurrentDeployment(arg0 context.Context, arg1 *workflowservice.SetCurrentDeploymentRequest, arg2 ...grpc.CallOption) (*workflowservice.SetCurrentDeploymentResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "SetCurrentDeployment", varargs...)
ret0, _ := ret[0].(*workflowservice.SetCurrentDeploymentResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SetCurrentDeployment indicates an expected call of SetCurrentDeployment.
func (mr *MockWorkflowServiceClientMockRecorder) SetCurrentDeployment(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetCurrentDeployment", reflect.TypeOf((*MockWorkflowServiceClient)(nil).SetCurrentDeployment), varargs...)
}
// SetWorkerDeploymentCurrentVersion mocks base method.
func (m *MockWorkflowServiceClient) SetWorkerDeploymentCurrentVersion(arg0 context.Context, arg1 *workflowservice.SetWorkerDeploymentCurrentVersionRequest, arg2 ...grpc.CallOption) (*workflowservice.SetWorkerDeploymentCurrentVersionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "SetWorkerDeploymentCurrentVersion", varargs...)
ret0, _ := ret[0].(*workflowservice.SetWorkerDeploymentCurrentVersionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SetWorkerDeploymentCurrentVersion indicates an expected call of SetWorkerDeploymentCurrentVersion.
func (mr *MockWorkflowServiceClientMockRecorder) SetWorkerDeploymentCurrentVersion(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetWorkerDeploymentCurrentVersion", reflect.TypeOf((*MockWorkflowServiceClient)(nil).SetWorkerDeploymentCurrentVersion), varargs...)
}
// SetWorkerDeploymentRampingVersion mocks base method.
func (m *MockWorkflowServiceClient) SetWorkerDeploymentRampingVersion(arg0 context.Context, arg1 *workflowservice.SetWorkerDeploymentRampingVersionRequest, arg2 ...grpc.CallOption) (*workflowservice.SetWorkerDeploymentRampingVersionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "SetWorkerDeploymentRampingVersion", varargs...)
ret0, _ := ret[0].(*workflowservice.SetWorkerDeploymentRampingVersionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SetWorkerDeploymentRampingVersion indicates an expected call of SetWorkerDeploymentRampingVersion.
func (mr *MockWorkflowServiceClientMockRecorder) SetWorkerDeploymentRampingVersion(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetWorkerDeploymentRampingVersion", reflect.TypeOf((*MockWorkflowServiceClient)(nil).SetWorkerDeploymentRampingVersion), varargs...)
}
// ShutdownWorker mocks base method.
func (m *MockWorkflowServiceClient) ShutdownWorker(arg0 context.Context, arg1 *workflowservice.ShutdownWorkerRequest, arg2 ...grpc.CallOption) (*workflowservice.ShutdownWorkerResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "ShutdownWorker", varargs...)
ret0, _ := ret[0].(*workflowservice.ShutdownWorkerResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// ShutdownWorker indicates an expected call of ShutdownWorker.
func (mr *MockWorkflowServiceClientMockRecorder) ShutdownWorker(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ShutdownWorker", reflect.TypeOf((*MockWorkflowServiceClient)(nil).ShutdownWorker), varargs...)
}
// SignalWithStartWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) SignalWithStartWorkflowExecution(arg0 context.Context, arg1 *workflowservice.SignalWithStartWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.SignalWithStartWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "SignalWithStartWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.SignalWithStartWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SignalWithStartWorkflowExecution indicates an expected call of SignalWithStartWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) SignalWithStartWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SignalWithStartWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).SignalWithStartWorkflowExecution), varargs...)
}
// SignalWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) SignalWorkflowExecution(arg0 context.Context, arg1 *workflowservice.SignalWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.SignalWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "SignalWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.SignalWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// SignalWorkflowExecution indicates an expected call of SignalWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) SignalWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SignalWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).SignalWorkflowExecution), varargs...)
}
// StartBatchOperation mocks base method.
func (m *MockWorkflowServiceClient) StartBatchOperation(arg0 context.Context, arg1 *workflowservice.StartBatchOperationRequest, arg2 ...grpc.CallOption) (*workflowservice.StartBatchOperationResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "StartBatchOperation", varargs...)
ret0, _ := ret[0].(*workflowservice.StartBatchOperationResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// StartBatchOperation indicates an expected call of StartBatchOperation.
func (mr *MockWorkflowServiceClientMockRecorder) StartBatchOperation(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StartBatchOperation", reflect.TypeOf((*MockWorkflowServiceClient)(nil).StartBatchOperation), varargs...)
}
// StartWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) StartWorkflowExecution(arg0 context.Context, arg1 *workflowservice.StartWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.StartWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "StartWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.StartWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// StartWorkflowExecution indicates an expected call of StartWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) StartWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StartWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).StartWorkflowExecution), varargs...)
}
// StopBatchOperation mocks base method.
func (m *MockWorkflowServiceClient) StopBatchOperation(arg0 context.Context, arg1 *workflowservice.StopBatchOperationRequest, arg2 ...grpc.CallOption) (*workflowservice.StopBatchOperationResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "StopBatchOperation", varargs...)
ret0, _ := ret[0].(*workflowservice.StopBatchOperationResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// StopBatchOperation indicates an expected call of StopBatchOperation.
func (mr *MockWorkflowServiceClientMockRecorder) StopBatchOperation(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StopBatchOperation", reflect.TypeOf((*MockWorkflowServiceClient)(nil).StopBatchOperation), varargs...)
}
// TerminateWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) TerminateWorkflowExecution(arg0 context.Context, arg1 *workflowservice.TerminateWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.TerminateWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "TerminateWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.TerminateWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// TerminateWorkflowExecution indicates an expected call of TerminateWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) TerminateWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "TerminateWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).TerminateWorkflowExecution), varargs...)
}
// UnpauseActivity mocks base method.
func (m *MockWorkflowServiceClient) UnpauseActivity(arg0 context.Context, arg1 *workflowservice.UnpauseActivityRequest, arg2 ...grpc.CallOption) (*workflowservice.UnpauseActivityResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UnpauseActivity", varargs...)
ret0, _ := ret[0].(*workflowservice.UnpauseActivityResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UnpauseActivity indicates an expected call of UnpauseActivity.
func (mr *MockWorkflowServiceClientMockRecorder) UnpauseActivity(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UnpauseActivity", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UnpauseActivity), varargs...)
}
// UpdateActivityOptions mocks base method.
func (m *MockWorkflowServiceClient) UpdateActivityOptions(arg0 context.Context, arg1 *workflowservice.UpdateActivityOptionsRequest, arg2 ...grpc.CallOption) (*workflowservice.UpdateActivityOptionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UpdateActivityOptions", varargs...)
ret0, _ := ret[0].(*workflowservice.UpdateActivityOptionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UpdateActivityOptions indicates an expected call of UpdateActivityOptions.
func (mr *MockWorkflowServiceClientMockRecorder) UpdateActivityOptions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateActivityOptions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UpdateActivityOptions), varargs...)
}
// UpdateNamespace mocks base method.
func (m *MockWorkflowServiceClient) UpdateNamespace(arg0 context.Context, arg1 *workflowservice.UpdateNamespaceRequest, arg2 ...grpc.CallOption) (*workflowservice.UpdateNamespaceResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UpdateNamespace", varargs...)
ret0, _ := ret[0].(*workflowservice.UpdateNamespaceResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UpdateNamespace indicates an expected call of UpdateNamespace.
func (mr *MockWorkflowServiceClientMockRecorder) UpdateNamespace(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateNamespace", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UpdateNamespace), varargs...)
}
// UpdateSchedule mocks base method.
func (m *MockWorkflowServiceClient) UpdateSchedule(arg0 context.Context, arg1 *workflowservice.UpdateScheduleRequest, arg2 ...grpc.CallOption) (*workflowservice.UpdateScheduleResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UpdateSchedule", varargs...)
ret0, _ := ret[0].(*workflowservice.UpdateScheduleResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UpdateSchedule indicates an expected call of UpdateSchedule.
func (mr *MockWorkflowServiceClientMockRecorder) UpdateSchedule(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateSchedule", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UpdateSchedule), varargs...)
}
// UpdateWorkerBuildIdCompatibility mocks base method.
func (m *MockWorkflowServiceClient) UpdateWorkerBuildIdCompatibility(arg0 context.Context, arg1 *workflowservice.UpdateWorkerBuildIdCompatibilityRequest, arg2 ...grpc.CallOption) (*workflowservice.UpdateWorkerBuildIdCompatibilityResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UpdateWorkerBuildIdCompatibility", varargs...)
ret0, _ := ret[0].(*workflowservice.UpdateWorkerBuildIdCompatibilityResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkerBuildIdCompatibility", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UpdateWorkerBuildIdCompatibility), varargs...)
}
// UpdateWorkerDeploymentVersionMetadata mocks base method.
func (m *MockWorkflowServiceClient) UpdateWorkerDeploymentVersionMetadata(arg0 context.Context, arg1 *workflowservice.UpdateWorkerDeploymentVersionMetadataRequest, arg2 ...grpc.CallOption) (*workflowservice.UpdateWorkerDeploymentVersionMetadataResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UpdateWorkerDeploymentVersionMetadata", varargs...)
ret0, _ := ret[0].(*workflowservice.UpdateWorkerDeploymentVersionMetadataResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UpdateWorkerDeploymentVersionMetadata indicates an expected call of UpdateWorkerDeploymentVersionMetadata.
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkerDeploymentVersionMetadata(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkerDeploymentVersionMetadata", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UpdateWorkerDeploymentVersionMetadata), varargs...)
}
// UpdateWorkerVersioningRules mocks base method.
func (m *MockWorkflowServiceClient) UpdateWorkerVersioningRules(arg0 context.Context, arg1 *workflowservice.UpdateWorkerVersioningRulesRequest, arg2 ...grpc.CallOption) (*workflowservice.UpdateWorkerVersioningRulesResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UpdateWorkerVersioningRules", varargs...)
ret0, _ := ret[0].(*workflowservice.UpdateWorkerVersioningRulesResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UpdateWorkerVersioningRules indicates an expected call of UpdateWorkerVersioningRules.
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkerVersioningRules(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkerVersioningRules", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UpdateWorkerVersioningRules), varargs...)
}
// UpdateWorkflowExecution mocks base method.
func (m *MockWorkflowServiceClient) UpdateWorkflowExecution(arg0 context.Context, arg1 *workflowservice.UpdateWorkflowExecutionRequest, arg2 ...grpc.CallOption) (*workflowservice.UpdateWorkflowExecutionResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UpdateWorkflowExecution", varargs...)
ret0, _ := ret[0].(*workflowservice.UpdateWorkflowExecutionResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UpdateWorkflowExecution indicates an expected call of UpdateWorkflowExecution.
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkflowExecution(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkflowExecution", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UpdateWorkflowExecution), varargs...)
}
// UpdateWorkflowExecutionOptions mocks base method.
func (m *MockWorkflowServiceClient) UpdateWorkflowExecutionOptions(arg0 context.Context, arg1 *workflowservice.UpdateWorkflowExecutionOptionsRequest, arg2 ...grpc.CallOption) (*workflowservice.UpdateWorkflowExecutionOptionsResponse, error) {
m.ctrl.T.Helper()
varargs := []any{arg0, arg1}
for _, a := range arg2 {
varargs = append(varargs, a)
}
ret := m.ctrl.Call(m, "UpdateWorkflowExecutionOptions", varargs...)
ret0, _ := ret[0].(*workflowservice.UpdateWorkflowExecutionOptionsResponse)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// UpdateWorkflowExecutionOptions indicates an expected call of UpdateWorkflowExecutionOptions.
func (mr *MockWorkflowServiceClientMockRecorder) UpdateWorkflowExecutionOptions(arg0, arg1 any, arg2 ...any) *gomock.Call {
mr.mock.ctrl.T.Helper()
varargs := append([]any{arg0, arg1}, arg2...)
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkflowExecutionOptions", reflect.TypeOf((*MockWorkflowServiceClient)(nil).UpdateWorkflowExecutionOptions), varargs...)
}