Documentation ¶
Overview ¶
Package matchingservicemock is a generated GoMock package.
Package matchingservicemock is a generated GoMock package.
Index ¶
- type MockMatchingServiceClient
- func (m *MockMatchingServiceClient) AddActivityTask(ctx context.Context, in *matchingservice.AddActivityTaskRequest, ...) (*matchingservice.AddActivityTaskResponse, error)
- func (m *MockMatchingServiceClient) AddWorkflowTask(ctx context.Context, in *matchingservice.AddWorkflowTaskRequest, ...) (*matchingservice.AddWorkflowTaskResponse, error)
- func (m *MockMatchingServiceClient) ApplyTaskQueueUserDataReplicationEvent(ctx context.Context, ...) (*matchingservice.ApplyTaskQueueUserDataReplicationEventResponse, error)
- func (m *MockMatchingServiceClient) CancelOutstandingPoll(ctx context.Context, in *matchingservice.CancelOutstandingPollRequest, ...) (*matchingservice.CancelOutstandingPollResponse, error)
- func (m *MockMatchingServiceClient) CreateNexusEndpoint(ctx context.Context, in *matchingservice.CreateNexusEndpointRequest, ...) (*matchingservice.CreateNexusEndpointResponse, error)
- func (m *MockMatchingServiceClient) DeleteNexusEndpoint(ctx context.Context, in *matchingservice.DeleteNexusEndpointRequest, ...) (*matchingservice.DeleteNexusEndpointResponse, error)
- func (m *MockMatchingServiceClient) DescribeTaskQueue(ctx context.Context, in *matchingservice.DescribeTaskQueueRequest, ...) (*matchingservice.DescribeTaskQueueResponse, error)
- func (m *MockMatchingServiceClient) DescribeTaskQueuePartition(ctx context.Context, in *matchingservice.DescribeTaskQueuePartitionRequest, ...) (*matchingservice.DescribeTaskQueuePartitionResponse, error)
- func (m *MockMatchingServiceClient) DispatchNexusTask(ctx context.Context, in *matchingservice.DispatchNexusTaskRequest, ...) (*matchingservice.DispatchNexusTaskResponse, error)
- func (m *MockMatchingServiceClient) EXPECT() *MockMatchingServiceClientMockRecorder
- func (m *MockMatchingServiceClient) ForceLoadTaskQueuePartition(ctx context.Context, in *matchingservice.ForceLoadTaskQueuePartitionRequest, ...) (*matchingservice.ForceLoadTaskQueuePartitionResponse, error)
- func (m *MockMatchingServiceClient) ForceUnloadTaskQueue(ctx context.Context, in *matchingservice.ForceUnloadTaskQueueRequest, ...) (*matchingservice.ForceUnloadTaskQueueResponse, error)
- func (m *MockMatchingServiceClient) ForceUnloadTaskQueuePartition(ctx context.Context, in *matchingservice.ForceUnloadTaskQueuePartitionRequest, ...) (*matchingservice.ForceUnloadTaskQueuePartitionResponse, error)
- func (m *MockMatchingServiceClient) GetBuildIdTaskQueueMapping(ctx context.Context, in *matchingservice.GetBuildIdTaskQueueMappingRequest, ...) (*matchingservice.GetBuildIdTaskQueueMappingResponse, error)
- func (m *MockMatchingServiceClient) GetTaskQueueUserData(ctx context.Context, in *matchingservice.GetTaskQueueUserDataRequest, ...) (*matchingservice.GetTaskQueueUserDataResponse, error)
- func (m *MockMatchingServiceClient) GetWorkerBuildIdCompatibility(ctx context.Context, in *matchingservice.GetWorkerBuildIdCompatibilityRequest, ...) (*matchingservice.GetWorkerBuildIdCompatibilityResponse, error)
- func (m *MockMatchingServiceClient) GetWorkerVersioningRules(ctx context.Context, in *matchingservice.GetWorkerVersioningRulesRequest, ...) (*matchingservice.GetWorkerVersioningRulesResponse, error)
- func (m *MockMatchingServiceClient) ListNexusEndpoints(ctx context.Context, in *matchingservice.ListNexusEndpointsRequest, ...) (*matchingservice.ListNexusEndpointsResponse, error)
- func (m *MockMatchingServiceClient) ListTaskQueuePartitions(ctx context.Context, in *matchingservice.ListTaskQueuePartitionsRequest, ...) (*matchingservice.ListTaskQueuePartitionsResponse, error)
- func (m *MockMatchingServiceClient) PollActivityTaskQueue(ctx context.Context, in *matchingservice.PollActivityTaskQueueRequest, ...) (*matchingservice.PollActivityTaskQueueResponse, error)
- func (m *MockMatchingServiceClient) PollNexusTaskQueue(ctx context.Context, in *matchingservice.PollNexusTaskQueueRequest, ...) (*matchingservice.PollNexusTaskQueueResponse, error)
- func (m *MockMatchingServiceClient) PollWorkflowTaskQueue(ctx context.Context, in *matchingservice.PollWorkflowTaskQueueRequest, ...) (*matchingservice.PollWorkflowTaskQueueResponse, error)
- func (m *MockMatchingServiceClient) QueryWorkflow(ctx context.Context, in *matchingservice.QueryWorkflowRequest, ...) (*matchingservice.QueryWorkflowResponse, error)
- func (m *MockMatchingServiceClient) ReplicateTaskQueueUserData(ctx context.Context, in *matchingservice.ReplicateTaskQueueUserDataRequest, ...) (*matchingservice.ReplicateTaskQueueUserDataResponse, error)
- func (m *MockMatchingServiceClient) RespondNexusTaskCompleted(ctx context.Context, in *matchingservice.RespondNexusTaskCompletedRequest, ...) (*matchingservice.RespondNexusTaskCompletedResponse, error)
- func (m *MockMatchingServiceClient) RespondNexusTaskFailed(ctx context.Context, in *matchingservice.RespondNexusTaskFailedRequest, ...) (*matchingservice.RespondNexusTaskFailedResponse, error)
- func (m *MockMatchingServiceClient) RespondQueryTaskCompleted(ctx context.Context, in *matchingservice.RespondQueryTaskCompletedRequest, ...) (*matchingservice.RespondQueryTaskCompletedResponse, error)
- func (m *MockMatchingServiceClient) SyncDeploymentUserData(ctx context.Context, in *matchingservice.SyncDeploymentUserDataRequest, ...) (*matchingservice.SyncDeploymentUserDataResponse, error)
- func (m *MockMatchingServiceClient) UpdateNexusEndpoint(ctx context.Context, in *matchingservice.UpdateNexusEndpointRequest, ...) (*matchingservice.UpdateNexusEndpointResponse, error)
- func (m *MockMatchingServiceClient) UpdateTaskQueueUserData(ctx context.Context, in *matchingservice.UpdateTaskQueueUserDataRequest, ...) (*matchingservice.UpdateTaskQueueUserDataResponse, error)
- func (m *MockMatchingServiceClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, ...) (*matchingservice.UpdateWorkerBuildIdCompatibilityResponse, error)
- func (m *MockMatchingServiceClient) UpdateWorkerVersioningRules(ctx context.Context, in *matchingservice.UpdateWorkerVersioningRulesRequest, ...) (*matchingservice.UpdateWorkerVersioningRulesResponse, error)
- type MockMatchingServiceClientMockRecorder
- func (mr *MockMatchingServiceClientMockRecorder) AddActivityTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) AddWorkflowTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ApplyTaskQueueUserDataReplicationEvent(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) CancelOutstandingPoll(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) CreateNexusEndpoint(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) DeleteNexusEndpoint(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) DescribeTaskQueue(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) DescribeTaskQueuePartition(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) DispatchNexusTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ForceLoadTaskQueuePartition(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueue(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueuePartition(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) GetBuildIdTaskQueueMapping(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) GetTaskQueueUserData(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) GetWorkerVersioningRules(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ListNexusEndpoints(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ListTaskQueuePartitions(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) PollActivityTaskQueue(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) PollNexusTaskQueue(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) PollWorkflowTaskQueue(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) QueryWorkflow(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ReplicateTaskQueueUserData(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) RespondNexusTaskCompleted(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) RespondNexusTaskFailed(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) RespondQueryTaskCompleted(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) SyncDeploymentUserData(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) UpdateNexusEndpoint(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) UpdateTaskQueueUserData(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) UpdateWorkerVersioningRules(ctx, in any, opts ...any) *gomock.Call
- type MockMatchingServiceServer
- func (m *MockMatchingServiceServer) AddActivityTask(arg0 context.Context, arg1 *matchingservice.AddActivityTaskRequest) (*matchingservice.AddActivityTaskResponse, error)
- func (m *MockMatchingServiceServer) AddWorkflowTask(arg0 context.Context, arg1 *matchingservice.AddWorkflowTaskRequest) (*matchingservice.AddWorkflowTaskResponse, error)
- func (m *MockMatchingServiceServer) ApplyTaskQueueUserDataReplicationEvent(arg0 context.Context, ...) (*matchingservice.ApplyTaskQueueUserDataReplicationEventResponse, error)
- func (m *MockMatchingServiceServer) CancelOutstandingPoll(arg0 context.Context, arg1 *matchingservice.CancelOutstandingPollRequest) (*matchingservice.CancelOutstandingPollResponse, error)
- func (m *MockMatchingServiceServer) CreateNexusEndpoint(arg0 context.Context, arg1 *matchingservice.CreateNexusEndpointRequest) (*matchingservice.CreateNexusEndpointResponse, error)
- func (m *MockMatchingServiceServer) DeleteNexusEndpoint(arg0 context.Context, arg1 *matchingservice.DeleteNexusEndpointRequest) (*matchingservice.DeleteNexusEndpointResponse, error)
- func (m *MockMatchingServiceServer) DescribeTaskQueue(arg0 context.Context, arg1 *matchingservice.DescribeTaskQueueRequest) (*matchingservice.DescribeTaskQueueResponse, error)
- func (m *MockMatchingServiceServer) DescribeTaskQueuePartition(arg0 context.Context, arg1 *matchingservice.DescribeTaskQueuePartitionRequest) (*matchingservice.DescribeTaskQueuePartitionResponse, error)
- func (m *MockMatchingServiceServer) DispatchNexusTask(arg0 context.Context, arg1 *matchingservice.DispatchNexusTaskRequest) (*matchingservice.DispatchNexusTaskResponse, error)
- func (m *MockMatchingServiceServer) EXPECT() *MockMatchingServiceServerMockRecorder
- func (m *MockMatchingServiceServer) ForceLoadTaskQueuePartition(arg0 context.Context, arg1 *matchingservice.ForceLoadTaskQueuePartitionRequest) (*matchingservice.ForceLoadTaskQueuePartitionResponse, error)
- func (m *MockMatchingServiceServer) ForceUnloadTaskQueue(arg0 context.Context, arg1 *matchingservice.ForceUnloadTaskQueueRequest) (*matchingservice.ForceUnloadTaskQueueResponse, error)
- func (m *MockMatchingServiceServer) ForceUnloadTaskQueuePartition(arg0 context.Context, ...) (*matchingservice.ForceUnloadTaskQueuePartitionResponse, error)
- func (m *MockMatchingServiceServer) GetBuildIdTaskQueueMapping(arg0 context.Context, arg1 *matchingservice.GetBuildIdTaskQueueMappingRequest) (*matchingservice.GetBuildIdTaskQueueMappingResponse, error)
- func (m *MockMatchingServiceServer) GetTaskQueueUserData(arg0 context.Context, arg1 *matchingservice.GetTaskQueueUserDataRequest) (*matchingservice.GetTaskQueueUserDataResponse, error)
- func (m *MockMatchingServiceServer) GetWorkerBuildIdCompatibility(arg0 context.Context, ...) (*matchingservice.GetWorkerBuildIdCompatibilityResponse, error)
- func (m *MockMatchingServiceServer) GetWorkerVersioningRules(arg0 context.Context, arg1 *matchingservice.GetWorkerVersioningRulesRequest) (*matchingservice.GetWorkerVersioningRulesResponse, error)
- func (m *MockMatchingServiceServer) ListNexusEndpoints(arg0 context.Context, arg1 *matchingservice.ListNexusEndpointsRequest) (*matchingservice.ListNexusEndpointsResponse, error)
- func (m *MockMatchingServiceServer) ListTaskQueuePartitions(arg0 context.Context, arg1 *matchingservice.ListTaskQueuePartitionsRequest) (*matchingservice.ListTaskQueuePartitionsResponse, error)
- func (m *MockMatchingServiceServer) PollActivityTaskQueue(arg0 context.Context, arg1 *matchingservice.PollActivityTaskQueueRequest) (*matchingservice.PollActivityTaskQueueResponse, error)
- func (m *MockMatchingServiceServer) PollNexusTaskQueue(arg0 context.Context, arg1 *matchingservice.PollNexusTaskQueueRequest) (*matchingservice.PollNexusTaskQueueResponse, error)
- func (m *MockMatchingServiceServer) PollWorkflowTaskQueue(arg0 context.Context, arg1 *matchingservice.PollWorkflowTaskQueueRequest) (*matchingservice.PollWorkflowTaskQueueResponse, error)
- func (m *MockMatchingServiceServer) QueryWorkflow(arg0 context.Context, arg1 *matchingservice.QueryWorkflowRequest) (*matchingservice.QueryWorkflowResponse, error)
- func (m *MockMatchingServiceServer) ReplicateTaskQueueUserData(arg0 context.Context, arg1 *matchingservice.ReplicateTaskQueueUserDataRequest) (*matchingservice.ReplicateTaskQueueUserDataResponse, error)
- func (m *MockMatchingServiceServer) RespondNexusTaskCompleted(arg0 context.Context, arg1 *matchingservice.RespondNexusTaskCompletedRequest) (*matchingservice.RespondNexusTaskCompletedResponse, error)
- func (m *MockMatchingServiceServer) RespondNexusTaskFailed(arg0 context.Context, arg1 *matchingservice.RespondNexusTaskFailedRequest) (*matchingservice.RespondNexusTaskFailedResponse, error)
- func (m *MockMatchingServiceServer) RespondQueryTaskCompleted(arg0 context.Context, arg1 *matchingservice.RespondQueryTaskCompletedRequest) (*matchingservice.RespondQueryTaskCompletedResponse, error)
- func (m *MockMatchingServiceServer) SyncDeploymentUserData(arg0 context.Context, arg1 *matchingservice.SyncDeploymentUserDataRequest) (*matchingservice.SyncDeploymentUserDataResponse, error)
- func (m *MockMatchingServiceServer) UpdateNexusEndpoint(arg0 context.Context, arg1 *matchingservice.UpdateNexusEndpointRequest) (*matchingservice.UpdateNexusEndpointResponse, error)
- func (m *MockMatchingServiceServer) UpdateTaskQueueUserData(arg0 context.Context, arg1 *matchingservice.UpdateTaskQueueUserDataRequest) (*matchingservice.UpdateTaskQueueUserDataResponse, error)
- func (m *MockMatchingServiceServer) UpdateWorkerBuildIdCompatibility(arg0 context.Context, ...) (*matchingservice.UpdateWorkerBuildIdCompatibilityResponse, error)
- func (m *MockMatchingServiceServer) UpdateWorkerVersioningRules(arg0 context.Context, arg1 *matchingservice.UpdateWorkerVersioningRulesRequest) (*matchingservice.UpdateWorkerVersioningRulesResponse, error)
- type MockMatchingServiceServerMockRecorder
- func (mr *MockMatchingServiceServerMockRecorder) AddActivityTask(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) AddWorkflowTask(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ApplyTaskQueueUserDataReplicationEvent(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) CancelOutstandingPoll(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) CreateNexusEndpoint(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) DeleteNexusEndpoint(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) DescribeTaskQueue(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) DescribeTaskQueuePartition(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) DispatchNexusTask(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ForceLoadTaskQueuePartition(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueue(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueuePartition(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) GetBuildIdTaskQueueMapping(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) GetTaskQueueUserData(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) GetWorkerVersioningRules(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ListNexusEndpoints(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ListTaskQueuePartitions(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) PollActivityTaskQueue(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) PollNexusTaskQueue(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) PollWorkflowTaskQueue(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) QueryWorkflow(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ReplicateTaskQueueUserData(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) RespondNexusTaskCompleted(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) RespondNexusTaskFailed(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) RespondQueryTaskCompleted(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) SyncDeploymentUserData(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) UpdateNexusEndpoint(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) UpdateTaskQueueUserData(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 any) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) UpdateWorkerVersioningRules(arg0, arg1 any) *gomock.Call
- type MockUnsafeMatchingServiceServer
- type MockUnsafeMatchingServiceServerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockMatchingServiceClient ¶
type MockMatchingServiceClient struct {
// contains filtered or unexported fields
}
MockMatchingServiceClient is a mock of MatchingServiceClient interface.
func NewMockMatchingServiceClient ¶
func NewMockMatchingServiceClient(ctrl *gomock.Controller) *MockMatchingServiceClient
NewMockMatchingServiceClient creates a new mock instance.
func (*MockMatchingServiceClient) AddActivityTask ¶
func (m *MockMatchingServiceClient) AddActivityTask(ctx context.Context, in *matchingservice.AddActivityTaskRequest, opts ...grpc.CallOption) (*matchingservice.AddActivityTaskResponse, error)
AddActivityTask mocks base method.
func (*MockMatchingServiceClient) AddWorkflowTask ¶
func (m *MockMatchingServiceClient) AddWorkflowTask(ctx context.Context, in *matchingservice.AddWorkflowTaskRequest, opts ...grpc.CallOption) (*matchingservice.AddWorkflowTaskResponse, error)
AddWorkflowTask mocks base method.
func (*MockMatchingServiceClient) ApplyTaskQueueUserDataReplicationEvent ¶ added in v1.21.0
func (m *MockMatchingServiceClient) ApplyTaskQueueUserDataReplicationEvent(ctx context.Context, in *matchingservice.ApplyTaskQueueUserDataReplicationEventRequest, opts ...grpc.CallOption) (*matchingservice.ApplyTaskQueueUserDataReplicationEventResponse, error)
ApplyTaskQueueUserDataReplicationEvent mocks base method.
func (*MockMatchingServiceClient) CancelOutstandingPoll ¶
func (m *MockMatchingServiceClient) CancelOutstandingPoll(ctx context.Context, in *matchingservice.CancelOutstandingPollRequest, opts ...grpc.CallOption) (*matchingservice.CancelOutstandingPollResponse, error)
CancelOutstandingPoll mocks base method.
func (*MockMatchingServiceClient) CreateNexusEndpoint ¶ added in v1.25.0
func (m *MockMatchingServiceClient) CreateNexusEndpoint(ctx context.Context, in *matchingservice.CreateNexusEndpointRequest, opts ...grpc.CallOption) (*matchingservice.CreateNexusEndpointResponse, error)
CreateNexusEndpoint mocks base method.
func (*MockMatchingServiceClient) DeleteNexusEndpoint ¶ added in v1.25.0
func (m *MockMatchingServiceClient) DeleteNexusEndpoint(ctx context.Context, in *matchingservice.DeleteNexusEndpointRequest, opts ...grpc.CallOption) (*matchingservice.DeleteNexusEndpointResponse, error)
DeleteNexusEndpoint mocks base method.
func (*MockMatchingServiceClient) DescribeTaskQueue ¶
func (m *MockMatchingServiceClient) DescribeTaskQueue(ctx context.Context, in *matchingservice.DescribeTaskQueueRequest, opts ...grpc.CallOption) (*matchingservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue mocks base method.
func (*MockMatchingServiceClient) DescribeTaskQueuePartition ¶ added in v1.24.0
func (m *MockMatchingServiceClient) DescribeTaskQueuePartition(ctx context.Context, in *matchingservice.DescribeTaskQueuePartitionRequest, opts ...grpc.CallOption) (*matchingservice.DescribeTaskQueuePartitionResponse, error)
DescribeTaskQueuePartition mocks base method.
func (*MockMatchingServiceClient) DispatchNexusTask ¶ added in v1.24.0
func (m *MockMatchingServiceClient) DispatchNexusTask(ctx context.Context, in *matchingservice.DispatchNexusTaskRequest, opts ...grpc.CallOption) (*matchingservice.DispatchNexusTaskResponse, error)
DispatchNexusTask mocks base method.
func (*MockMatchingServiceClient) EXPECT ¶
func (m *MockMatchingServiceClient) EXPECT() *MockMatchingServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMatchingServiceClient) ForceLoadTaskQueuePartition ¶ added in v1.26.0
func (m *MockMatchingServiceClient) ForceLoadTaskQueuePartition(ctx context.Context, in *matchingservice.ForceLoadTaskQueuePartitionRequest, opts ...grpc.CallOption) (*matchingservice.ForceLoadTaskQueuePartitionResponse, error)
ForceLoadTaskQueuePartition mocks base method.
func (*MockMatchingServiceClient) ForceUnloadTaskQueue ¶ added in v1.21.0
func (m *MockMatchingServiceClient) ForceUnloadTaskQueue(ctx context.Context, in *matchingservice.ForceUnloadTaskQueueRequest, opts ...grpc.CallOption) (*matchingservice.ForceUnloadTaskQueueResponse, error)
ForceUnloadTaskQueue mocks base method.
func (*MockMatchingServiceClient) ForceUnloadTaskQueuePartition ¶
func (m *MockMatchingServiceClient) ForceUnloadTaskQueuePartition(ctx context.Context, in *matchingservice.ForceUnloadTaskQueuePartitionRequest, opts ...grpc.CallOption) (*matchingservice.ForceUnloadTaskQueuePartitionResponse, error)
ForceUnloadTaskQueuePartition mocks base method.
func (*MockMatchingServiceClient) GetBuildIdTaskQueueMapping ¶ added in v1.21.0
func (m *MockMatchingServiceClient) GetBuildIdTaskQueueMapping(ctx context.Context, in *matchingservice.GetBuildIdTaskQueueMappingRequest, opts ...grpc.CallOption) (*matchingservice.GetBuildIdTaskQueueMappingResponse, error)
GetBuildIdTaskQueueMapping mocks base method.
func (*MockMatchingServiceClient) GetTaskQueueUserData ¶ added in v1.21.0
func (m *MockMatchingServiceClient) GetTaskQueueUserData(ctx context.Context, in *matchingservice.GetTaskQueueUserDataRequest, opts ...grpc.CallOption) (*matchingservice.GetTaskQueueUserDataResponse, error)
GetTaskQueueUserData mocks base method.
func (*MockMatchingServiceClient) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockMatchingServiceClient) GetWorkerBuildIdCompatibility(ctx context.Context, in *matchingservice.GetWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption) (*matchingservice.GetWorkerBuildIdCompatibilityResponse, error)
GetWorkerBuildIdCompatibility mocks base method.
func (*MockMatchingServiceClient) GetWorkerVersioningRules ¶ added in v1.24.0
func (m *MockMatchingServiceClient) GetWorkerVersioningRules(ctx context.Context, in *matchingservice.GetWorkerVersioningRulesRequest, opts ...grpc.CallOption) (*matchingservice.GetWorkerVersioningRulesResponse, error)
GetWorkerVersioningRules mocks base method.
func (*MockMatchingServiceClient) ListNexusEndpoints ¶ added in v1.25.0
func (m *MockMatchingServiceClient) ListNexusEndpoints(ctx context.Context, in *matchingservice.ListNexusEndpointsRequest, opts ...grpc.CallOption) (*matchingservice.ListNexusEndpointsResponse, error)
ListNexusEndpoints mocks base method.
func (*MockMatchingServiceClient) ListTaskQueuePartitions ¶
func (m *MockMatchingServiceClient) ListTaskQueuePartitions(ctx context.Context, in *matchingservice.ListTaskQueuePartitionsRequest, opts ...grpc.CallOption) (*matchingservice.ListTaskQueuePartitionsResponse, error)
ListTaskQueuePartitions mocks base method.
func (*MockMatchingServiceClient) PollActivityTaskQueue ¶
func (m *MockMatchingServiceClient) PollActivityTaskQueue(ctx context.Context, in *matchingservice.PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*matchingservice.PollActivityTaskQueueResponse, error)
PollActivityTaskQueue mocks base method.
func (*MockMatchingServiceClient) PollNexusTaskQueue ¶ added in v1.24.0
func (m *MockMatchingServiceClient) PollNexusTaskQueue(ctx context.Context, in *matchingservice.PollNexusTaskQueueRequest, opts ...grpc.CallOption) (*matchingservice.PollNexusTaskQueueResponse, error)
PollNexusTaskQueue mocks base method.
func (*MockMatchingServiceClient) PollWorkflowTaskQueue ¶
func (m *MockMatchingServiceClient) PollWorkflowTaskQueue(ctx context.Context, in *matchingservice.PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*matchingservice.PollWorkflowTaskQueueResponse, error)
PollWorkflowTaskQueue mocks base method.
func (*MockMatchingServiceClient) QueryWorkflow ¶
func (m *MockMatchingServiceClient) QueryWorkflow(ctx context.Context, in *matchingservice.QueryWorkflowRequest, opts ...grpc.CallOption) (*matchingservice.QueryWorkflowResponse, error)
QueryWorkflow mocks base method.
func (*MockMatchingServiceClient) ReplicateTaskQueueUserData ¶ added in v1.21.0
func (m *MockMatchingServiceClient) ReplicateTaskQueueUserData(ctx context.Context, in *matchingservice.ReplicateTaskQueueUserDataRequest, opts ...grpc.CallOption) (*matchingservice.ReplicateTaskQueueUserDataResponse, error)
ReplicateTaskQueueUserData mocks base method.
func (*MockMatchingServiceClient) RespondNexusTaskCompleted ¶ added in v1.24.0
func (m *MockMatchingServiceClient) RespondNexusTaskCompleted(ctx context.Context, in *matchingservice.RespondNexusTaskCompletedRequest, opts ...grpc.CallOption) (*matchingservice.RespondNexusTaskCompletedResponse, error)
RespondNexusTaskCompleted mocks base method.
func (*MockMatchingServiceClient) RespondNexusTaskFailed ¶ added in v1.24.0
func (m *MockMatchingServiceClient) RespondNexusTaskFailed(ctx context.Context, in *matchingservice.RespondNexusTaskFailedRequest, opts ...grpc.CallOption) (*matchingservice.RespondNexusTaskFailedResponse, error)
RespondNexusTaskFailed mocks base method.
func (*MockMatchingServiceClient) RespondQueryTaskCompleted ¶
func (m *MockMatchingServiceClient) RespondQueryTaskCompleted(ctx context.Context, in *matchingservice.RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*matchingservice.RespondQueryTaskCompletedResponse, error)
RespondQueryTaskCompleted mocks base method.
func (*MockMatchingServiceClient) SyncDeploymentUserData ¶
func (m *MockMatchingServiceClient) SyncDeploymentUserData(ctx context.Context, in *matchingservice.SyncDeploymentUserDataRequest, opts ...grpc.CallOption) (*matchingservice.SyncDeploymentUserDataResponse, error)
SyncDeploymentUserData mocks base method.
func (*MockMatchingServiceClient) UpdateNexusEndpoint ¶ added in v1.25.0
func (m *MockMatchingServiceClient) UpdateNexusEndpoint(ctx context.Context, in *matchingservice.UpdateNexusEndpointRequest, opts ...grpc.CallOption) (*matchingservice.UpdateNexusEndpointResponse, error)
UpdateNexusEndpoint mocks base method.
func (*MockMatchingServiceClient) UpdateTaskQueueUserData ¶ added in v1.21.0
func (m *MockMatchingServiceClient) UpdateTaskQueueUserData(ctx context.Context, in *matchingservice.UpdateTaskQueueUserDataRequest, opts ...grpc.CallOption) (*matchingservice.UpdateTaskQueueUserDataResponse, error)
UpdateTaskQueueUserData mocks base method.
func (*MockMatchingServiceClient) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockMatchingServiceClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, in *matchingservice.UpdateWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption) (*matchingservice.UpdateWorkerBuildIdCompatibilityResponse, error)
UpdateWorkerBuildIdCompatibility mocks base method.
func (*MockMatchingServiceClient) UpdateWorkerVersioningRules ¶ added in v1.24.0
func (m *MockMatchingServiceClient) UpdateWorkerVersioningRules(ctx context.Context, in *matchingservice.UpdateWorkerVersioningRulesRequest, opts ...grpc.CallOption) (*matchingservice.UpdateWorkerVersioningRulesResponse, error)
UpdateWorkerVersioningRules mocks base method.
type MockMatchingServiceClientMockRecorder ¶
type MockMatchingServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockMatchingServiceClientMockRecorder is the mock recorder for MockMatchingServiceClient.
func (*MockMatchingServiceClientMockRecorder) AddActivityTask ¶
func (mr *MockMatchingServiceClientMockRecorder) AddActivityTask(ctx, in any, opts ...any) *gomock.Call
AddActivityTask indicates an expected call of AddActivityTask.
func (*MockMatchingServiceClientMockRecorder) AddWorkflowTask ¶
func (mr *MockMatchingServiceClientMockRecorder) AddWorkflowTask(ctx, in any, opts ...any) *gomock.Call
AddWorkflowTask indicates an expected call of AddWorkflowTask.
func (*MockMatchingServiceClientMockRecorder) ApplyTaskQueueUserDataReplicationEvent ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) ApplyTaskQueueUserDataReplicationEvent(ctx, in any, opts ...any) *gomock.Call
ApplyTaskQueueUserDataReplicationEvent indicates an expected call of ApplyTaskQueueUserDataReplicationEvent.
func (*MockMatchingServiceClientMockRecorder) CancelOutstandingPoll ¶
func (mr *MockMatchingServiceClientMockRecorder) CancelOutstandingPoll(ctx, in any, opts ...any) *gomock.Call
CancelOutstandingPoll indicates an expected call of CancelOutstandingPoll.
func (*MockMatchingServiceClientMockRecorder) CreateNexusEndpoint ¶ added in v1.25.0
func (mr *MockMatchingServiceClientMockRecorder) CreateNexusEndpoint(ctx, in any, opts ...any) *gomock.Call
CreateNexusEndpoint indicates an expected call of CreateNexusEndpoint.
func (*MockMatchingServiceClientMockRecorder) DeleteNexusEndpoint ¶ added in v1.25.0
func (mr *MockMatchingServiceClientMockRecorder) DeleteNexusEndpoint(ctx, in any, opts ...any) *gomock.Call
DeleteNexusEndpoint indicates an expected call of DeleteNexusEndpoint.
func (*MockMatchingServiceClientMockRecorder) DescribeTaskQueue ¶
func (mr *MockMatchingServiceClientMockRecorder) DescribeTaskQueue(ctx, in any, opts ...any) *gomock.Call
DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (*MockMatchingServiceClientMockRecorder) DescribeTaskQueuePartition ¶ added in v1.24.0
func (mr *MockMatchingServiceClientMockRecorder) DescribeTaskQueuePartition(ctx, in any, opts ...any) *gomock.Call
DescribeTaskQueuePartition indicates an expected call of DescribeTaskQueuePartition.
func (*MockMatchingServiceClientMockRecorder) DispatchNexusTask ¶ added in v1.24.0
func (mr *MockMatchingServiceClientMockRecorder) DispatchNexusTask(ctx, in any, opts ...any) *gomock.Call
DispatchNexusTask indicates an expected call of DispatchNexusTask.
func (*MockMatchingServiceClientMockRecorder) ForceLoadTaskQueuePartition ¶ added in v1.26.0
func (mr *MockMatchingServiceClientMockRecorder) ForceLoadTaskQueuePartition(ctx, in any, opts ...any) *gomock.Call
ForceLoadTaskQueuePartition indicates an expected call of ForceLoadTaskQueuePartition.
func (*MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueue ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueue(ctx, in any, opts ...any) *gomock.Call
ForceUnloadTaskQueue indicates an expected call of ForceUnloadTaskQueue.
func (*MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueuePartition ¶
func (mr *MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueuePartition(ctx, in any, opts ...any) *gomock.Call
ForceUnloadTaskQueuePartition indicates an expected call of ForceUnloadTaskQueuePartition.
func (*MockMatchingServiceClientMockRecorder) GetBuildIdTaskQueueMapping ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) GetBuildIdTaskQueueMapping(ctx, in any, opts ...any) *gomock.Call
GetBuildIdTaskQueueMapping indicates an expected call of GetBuildIdTaskQueueMapping.
func (*MockMatchingServiceClientMockRecorder) GetTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) GetTaskQueueUserData(ctx, in any, opts ...any) *gomock.Call
GetTaskQueueUserData indicates an expected call of GetTaskQueueUserData.
func (*MockMatchingServiceClientMockRecorder) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, in any, opts ...any) *gomock.Call
GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (*MockMatchingServiceClientMockRecorder) GetWorkerVersioningRules ¶ added in v1.24.0
func (mr *MockMatchingServiceClientMockRecorder) GetWorkerVersioningRules(ctx, in any, opts ...any) *gomock.Call
GetWorkerVersioningRules indicates an expected call of GetWorkerVersioningRules.
func (*MockMatchingServiceClientMockRecorder) ListNexusEndpoints ¶ added in v1.25.0
func (mr *MockMatchingServiceClientMockRecorder) ListNexusEndpoints(ctx, in any, opts ...any) *gomock.Call
ListNexusEndpoints indicates an expected call of ListNexusEndpoints.
func (*MockMatchingServiceClientMockRecorder) ListTaskQueuePartitions ¶
func (mr *MockMatchingServiceClientMockRecorder) ListTaskQueuePartitions(ctx, in any, opts ...any) *gomock.Call
ListTaskQueuePartitions indicates an expected call of ListTaskQueuePartitions.
func (*MockMatchingServiceClientMockRecorder) PollActivityTaskQueue ¶
func (mr *MockMatchingServiceClientMockRecorder) PollActivityTaskQueue(ctx, in any, opts ...any) *gomock.Call
PollActivityTaskQueue indicates an expected call of PollActivityTaskQueue.
func (*MockMatchingServiceClientMockRecorder) PollNexusTaskQueue ¶ added in v1.24.0
func (mr *MockMatchingServiceClientMockRecorder) PollNexusTaskQueue(ctx, in any, opts ...any) *gomock.Call
PollNexusTaskQueue indicates an expected call of PollNexusTaskQueue.
func (*MockMatchingServiceClientMockRecorder) PollWorkflowTaskQueue ¶
func (mr *MockMatchingServiceClientMockRecorder) PollWorkflowTaskQueue(ctx, in any, opts ...any) *gomock.Call
PollWorkflowTaskQueue indicates an expected call of PollWorkflowTaskQueue.
func (*MockMatchingServiceClientMockRecorder) QueryWorkflow ¶
func (mr *MockMatchingServiceClientMockRecorder) QueryWorkflow(ctx, in any, opts ...any) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockMatchingServiceClientMockRecorder) ReplicateTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) ReplicateTaskQueueUserData(ctx, in any, opts ...any) *gomock.Call
ReplicateTaskQueueUserData indicates an expected call of ReplicateTaskQueueUserData.
func (*MockMatchingServiceClientMockRecorder) RespondNexusTaskCompleted ¶ added in v1.24.0
func (mr *MockMatchingServiceClientMockRecorder) RespondNexusTaskCompleted(ctx, in any, opts ...any) *gomock.Call
RespondNexusTaskCompleted indicates an expected call of RespondNexusTaskCompleted.
func (*MockMatchingServiceClientMockRecorder) RespondNexusTaskFailed ¶ added in v1.24.0
func (mr *MockMatchingServiceClientMockRecorder) RespondNexusTaskFailed(ctx, in any, opts ...any) *gomock.Call
RespondNexusTaskFailed indicates an expected call of RespondNexusTaskFailed.
func (*MockMatchingServiceClientMockRecorder) RespondQueryTaskCompleted ¶
func (mr *MockMatchingServiceClientMockRecorder) RespondQueryTaskCompleted(ctx, in any, opts ...any) *gomock.Call
RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.
func (*MockMatchingServiceClientMockRecorder) SyncDeploymentUserData ¶
func (mr *MockMatchingServiceClientMockRecorder) SyncDeploymentUserData(ctx, in any, opts ...any) *gomock.Call
SyncDeploymentUserData indicates an expected call of SyncDeploymentUserData.
func (*MockMatchingServiceClientMockRecorder) UpdateNexusEndpoint ¶ added in v1.25.0
func (mr *MockMatchingServiceClientMockRecorder) UpdateNexusEndpoint(ctx, in any, opts ...any) *gomock.Call
UpdateNexusEndpoint indicates an expected call of UpdateNexusEndpoint.
func (*MockMatchingServiceClientMockRecorder) UpdateTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) UpdateTaskQueueUserData(ctx, in any, opts ...any) *gomock.Call
UpdateTaskQueueUserData indicates an expected call of UpdateTaskQueueUserData.
func (*MockMatchingServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, in any, opts ...any) *gomock.Call
UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.
func (*MockMatchingServiceClientMockRecorder) UpdateWorkerVersioningRules ¶ added in v1.24.0
func (mr *MockMatchingServiceClientMockRecorder) UpdateWorkerVersioningRules(ctx, in any, opts ...any) *gomock.Call
UpdateWorkerVersioningRules indicates an expected call of UpdateWorkerVersioningRules.
type MockMatchingServiceServer ¶
type MockMatchingServiceServer struct {
// contains filtered or unexported fields
}
MockMatchingServiceServer is a mock of MatchingServiceServer interface.
func NewMockMatchingServiceServer ¶
func NewMockMatchingServiceServer(ctrl *gomock.Controller) *MockMatchingServiceServer
NewMockMatchingServiceServer creates a new mock instance.
func (*MockMatchingServiceServer) AddActivityTask ¶
func (m *MockMatchingServiceServer) AddActivityTask(arg0 context.Context, arg1 *matchingservice.AddActivityTaskRequest) (*matchingservice.AddActivityTaskResponse, error)
AddActivityTask mocks base method.
func (*MockMatchingServiceServer) AddWorkflowTask ¶
func (m *MockMatchingServiceServer) AddWorkflowTask(arg0 context.Context, arg1 *matchingservice.AddWorkflowTaskRequest) (*matchingservice.AddWorkflowTaskResponse, error)
AddWorkflowTask mocks base method.
func (*MockMatchingServiceServer) ApplyTaskQueueUserDataReplicationEvent ¶ added in v1.21.0
func (m *MockMatchingServiceServer) ApplyTaskQueueUserDataReplicationEvent(arg0 context.Context, arg1 *matchingservice.ApplyTaskQueueUserDataReplicationEventRequest) (*matchingservice.ApplyTaskQueueUserDataReplicationEventResponse, error)
ApplyTaskQueueUserDataReplicationEvent mocks base method.
func (*MockMatchingServiceServer) CancelOutstandingPoll ¶
func (m *MockMatchingServiceServer) CancelOutstandingPoll(arg0 context.Context, arg1 *matchingservice.CancelOutstandingPollRequest) (*matchingservice.CancelOutstandingPollResponse, error)
CancelOutstandingPoll mocks base method.
func (*MockMatchingServiceServer) CreateNexusEndpoint ¶ added in v1.25.0
func (m *MockMatchingServiceServer) CreateNexusEndpoint(arg0 context.Context, arg1 *matchingservice.CreateNexusEndpointRequest) (*matchingservice.CreateNexusEndpointResponse, error)
CreateNexusEndpoint mocks base method.
func (*MockMatchingServiceServer) DeleteNexusEndpoint ¶ added in v1.25.0
func (m *MockMatchingServiceServer) DeleteNexusEndpoint(arg0 context.Context, arg1 *matchingservice.DeleteNexusEndpointRequest) (*matchingservice.DeleteNexusEndpointResponse, error)
DeleteNexusEndpoint mocks base method.
func (*MockMatchingServiceServer) DescribeTaskQueue ¶
func (m *MockMatchingServiceServer) DescribeTaskQueue(arg0 context.Context, arg1 *matchingservice.DescribeTaskQueueRequest) (*matchingservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue mocks base method.
func (*MockMatchingServiceServer) DescribeTaskQueuePartition ¶ added in v1.24.0
func (m *MockMatchingServiceServer) DescribeTaskQueuePartition(arg0 context.Context, arg1 *matchingservice.DescribeTaskQueuePartitionRequest) (*matchingservice.DescribeTaskQueuePartitionResponse, error)
DescribeTaskQueuePartition mocks base method.
func (*MockMatchingServiceServer) DispatchNexusTask ¶ added in v1.24.0
func (m *MockMatchingServiceServer) DispatchNexusTask(arg0 context.Context, arg1 *matchingservice.DispatchNexusTaskRequest) (*matchingservice.DispatchNexusTaskResponse, error)
DispatchNexusTask mocks base method.
func (*MockMatchingServiceServer) EXPECT ¶
func (m *MockMatchingServiceServer) EXPECT() *MockMatchingServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMatchingServiceServer) ForceLoadTaskQueuePartition ¶ added in v1.26.0
func (m *MockMatchingServiceServer) ForceLoadTaskQueuePartition(arg0 context.Context, arg1 *matchingservice.ForceLoadTaskQueuePartitionRequest) (*matchingservice.ForceLoadTaskQueuePartitionResponse, error)
ForceLoadTaskQueuePartition mocks base method.
func (*MockMatchingServiceServer) ForceUnloadTaskQueue ¶ added in v1.21.0
func (m *MockMatchingServiceServer) ForceUnloadTaskQueue(arg0 context.Context, arg1 *matchingservice.ForceUnloadTaskQueueRequest) (*matchingservice.ForceUnloadTaskQueueResponse, error)
ForceUnloadTaskQueue mocks base method.
func (*MockMatchingServiceServer) ForceUnloadTaskQueuePartition ¶
func (m *MockMatchingServiceServer) ForceUnloadTaskQueuePartition(arg0 context.Context, arg1 *matchingservice.ForceUnloadTaskQueuePartitionRequest) (*matchingservice.ForceUnloadTaskQueuePartitionResponse, error)
ForceUnloadTaskQueuePartition mocks base method.
func (*MockMatchingServiceServer) GetBuildIdTaskQueueMapping ¶ added in v1.21.0
func (m *MockMatchingServiceServer) GetBuildIdTaskQueueMapping(arg0 context.Context, arg1 *matchingservice.GetBuildIdTaskQueueMappingRequest) (*matchingservice.GetBuildIdTaskQueueMappingResponse, error)
GetBuildIdTaskQueueMapping mocks base method.
func (*MockMatchingServiceServer) GetTaskQueueUserData ¶ added in v1.21.0
func (m *MockMatchingServiceServer) GetTaskQueueUserData(arg0 context.Context, arg1 *matchingservice.GetTaskQueueUserDataRequest) (*matchingservice.GetTaskQueueUserDataResponse, error)
GetTaskQueueUserData mocks base method.
func (*MockMatchingServiceServer) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockMatchingServiceServer) GetWorkerBuildIdCompatibility(arg0 context.Context, arg1 *matchingservice.GetWorkerBuildIdCompatibilityRequest) (*matchingservice.GetWorkerBuildIdCompatibilityResponse, error)
GetWorkerBuildIdCompatibility mocks base method.
func (*MockMatchingServiceServer) GetWorkerVersioningRules ¶ added in v1.24.0
func (m *MockMatchingServiceServer) GetWorkerVersioningRules(arg0 context.Context, arg1 *matchingservice.GetWorkerVersioningRulesRequest) (*matchingservice.GetWorkerVersioningRulesResponse, error)
GetWorkerVersioningRules mocks base method.
func (*MockMatchingServiceServer) ListNexusEndpoints ¶ added in v1.25.0
func (m *MockMatchingServiceServer) ListNexusEndpoints(arg0 context.Context, arg1 *matchingservice.ListNexusEndpointsRequest) (*matchingservice.ListNexusEndpointsResponse, error)
ListNexusEndpoints mocks base method.
func (*MockMatchingServiceServer) ListTaskQueuePartitions ¶
func (m *MockMatchingServiceServer) ListTaskQueuePartitions(arg0 context.Context, arg1 *matchingservice.ListTaskQueuePartitionsRequest) (*matchingservice.ListTaskQueuePartitionsResponse, error)
ListTaskQueuePartitions mocks base method.
func (*MockMatchingServiceServer) PollActivityTaskQueue ¶
func (m *MockMatchingServiceServer) PollActivityTaskQueue(arg0 context.Context, arg1 *matchingservice.PollActivityTaskQueueRequest) (*matchingservice.PollActivityTaskQueueResponse, error)
PollActivityTaskQueue mocks base method.
func (*MockMatchingServiceServer) PollNexusTaskQueue ¶ added in v1.24.0
func (m *MockMatchingServiceServer) PollNexusTaskQueue(arg0 context.Context, arg1 *matchingservice.PollNexusTaskQueueRequest) (*matchingservice.PollNexusTaskQueueResponse, error)
PollNexusTaskQueue mocks base method.
func (*MockMatchingServiceServer) PollWorkflowTaskQueue ¶
func (m *MockMatchingServiceServer) PollWorkflowTaskQueue(arg0 context.Context, arg1 *matchingservice.PollWorkflowTaskQueueRequest) (*matchingservice.PollWorkflowTaskQueueResponse, error)
PollWorkflowTaskQueue mocks base method.
func (*MockMatchingServiceServer) QueryWorkflow ¶
func (m *MockMatchingServiceServer) QueryWorkflow(arg0 context.Context, arg1 *matchingservice.QueryWorkflowRequest) (*matchingservice.QueryWorkflowResponse, error)
QueryWorkflow mocks base method.
func (*MockMatchingServiceServer) ReplicateTaskQueueUserData ¶ added in v1.21.0
func (m *MockMatchingServiceServer) ReplicateTaskQueueUserData(arg0 context.Context, arg1 *matchingservice.ReplicateTaskQueueUserDataRequest) (*matchingservice.ReplicateTaskQueueUserDataResponse, error)
ReplicateTaskQueueUserData mocks base method.
func (*MockMatchingServiceServer) RespondNexusTaskCompleted ¶ added in v1.24.0
func (m *MockMatchingServiceServer) RespondNexusTaskCompleted(arg0 context.Context, arg1 *matchingservice.RespondNexusTaskCompletedRequest) (*matchingservice.RespondNexusTaskCompletedResponse, error)
RespondNexusTaskCompleted mocks base method.
func (*MockMatchingServiceServer) RespondNexusTaskFailed ¶ added in v1.24.0
func (m *MockMatchingServiceServer) RespondNexusTaskFailed(arg0 context.Context, arg1 *matchingservice.RespondNexusTaskFailedRequest) (*matchingservice.RespondNexusTaskFailedResponse, error)
RespondNexusTaskFailed mocks base method.
func (*MockMatchingServiceServer) RespondQueryTaskCompleted ¶
func (m *MockMatchingServiceServer) RespondQueryTaskCompleted(arg0 context.Context, arg1 *matchingservice.RespondQueryTaskCompletedRequest) (*matchingservice.RespondQueryTaskCompletedResponse, error)
RespondQueryTaskCompleted mocks base method.
func (*MockMatchingServiceServer) SyncDeploymentUserData ¶
func (m *MockMatchingServiceServer) SyncDeploymentUserData(arg0 context.Context, arg1 *matchingservice.SyncDeploymentUserDataRequest) (*matchingservice.SyncDeploymentUserDataResponse, error)
SyncDeploymentUserData mocks base method.
func (*MockMatchingServiceServer) UpdateNexusEndpoint ¶ added in v1.25.0
func (m *MockMatchingServiceServer) UpdateNexusEndpoint(arg0 context.Context, arg1 *matchingservice.UpdateNexusEndpointRequest) (*matchingservice.UpdateNexusEndpointResponse, error)
UpdateNexusEndpoint mocks base method.
func (*MockMatchingServiceServer) UpdateTaskQueueUserData ¶ added in v1.21.0
func (m *MockMatchingServiceServer) UpdateTaskQueueUserData(arg0 context.Context, arg1 *matchingservice.UpdateTaskQueueUserDataRequest) (*matchingservice.UpdateTaskQueueUserDataResponse, error)
UpdateTaskQueueUserData mocks base method.
func (*MockMatchingServiceServer) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (m *MockMatchingServiceServer) UpdateWorkerBuildIdCompatibility(arg0 context.Context, arg1 *matchingservice.UpdateWorkerBuildIdCompatibilityRequest) (*matchingservice.UpdateWorkerBuildIdCompatibilityResponse, error)
UpdateWorkerBuildIdCompatibility mocks base method.
func (*MockMatchingServiceServer) UpdateWorkerVersioningRules ¶ added in v1.24.0
func (m *MockMatchingServiceServer) UpdateWorkerVersioningRules(arg0 context.Context, arg1 *matchingservice.UpdateWorkerVersioningRulesRequest) (*matchingservice.UpdateWorkerVersioningRulesResponse, error)
UpdateWorkerVersioningRules mocks base method.
type MockMatchingServiceServerMockRecorder ¶
type MockMatchingServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockMatchingServiceServerMockRecorder is the mock recorder for MockMatchingServiceServer.
func (*MockMatchingServiceServerMockRecorder) AddActivityTask ¶
func (mr *MockMatchingServiceServerMockRecorder) AddActivityTask(arg0, arg1 any) *gomock.Call
AddActivityTask indicates an expected call of AddActivityTask.
func (*MockMatchingServiceServerMockRecorder) AddWorkflowTask ¶
func (mr *MockMatchingServiceServerMockRecorder) AddWorkflowTask(arg0, arg1 any) *gomock.Call
AddWorkflowTask indicates an expected call of AddWorkflowTask.
func (*MockMatchingServiceServerMockRecorder) ApplyTaskQueueUserDataReplicationEvent ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) ApplyTaskQueueUserDataReplicationEvent(arg0, arg1 any) *gomock.Call
ApplyTaskQueueUserDataReplicationEvent indicates an expected call of ApplyTaskQueueUserDataReplicationEvent.
func (*MockMatchingServiceServerMockRecorder) CancelOutstandingPoll ¶
func (mr *MockMatchingServiceServerMockRecorder) CancelOutstandingPoll(arg0, arg1 any) *gomock.Call
CancelOutstandingPoll indicates an expected call of CancelOutstandingPoll.
func (*MockMatchingServiceServerMockRecorder) CreateNexusEndpoint ¶ added in v1.25.0
func (mr *MockMatchingServiceServerMockRecorder) CreateNexusEndpoint(arg0, arg1 any) *gomock.Call
CreateNexusEndpoint indicates an expected call of CreateNexusEndpoint.
func (*MockMatchingServiceServerMockRecorder) DeleteNexusEndpoint ¶ added in v1.25.0
func (mr *MockMatchingServiceServerMockRecorder) DeleteNexusEndpoint(arg0, arg1 any) *gomock.Call
DeleteNexusEndpoint indicates an expected call of DeleteNexusEndpoint.
func (*MockMatchingServiceServerMockRecorder) DescribeTaskQueue ¶
func (mr *MockMatchingServiceServerMockRecorder) DescribeTaskQueue(arg0, arg1 any) *gomock.Call
DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (*MockMatchingServiceServerMockRecorder) DescribeTaskQueuePartition ¶ added in v1.24.0
func (mr *MockMatchingServiceServerMockRecorder) DescribeTaskQueuePartition(arg0, arg1 any) *gomock.Call
DescribeTaskQueuePartition indicates an expected call of DescribeTaskQueuePartition.
func (*MockMatchingServiceServerMockRecorder) DispatchNexusTask ¶ added in v1.24.0
func (mr *MockMatchingServiceServerMockRecorder) DispatchNexusTask(arg0, arg1 any) *gomock.Call
DispatchNexusTask indicates an expected call of DispatchNexusTask.
func (*MockMatchingServiceServerMockRecorder) ForceLoadTaskQueuePartition ¶ added in v1.26.0
func (mr *MockMatchingServiceServerMockRecorder) ForceLoadTaskQueuePartition(arg0, arg1 any) *gomock.Call
ForceLoadTaskQueuePartition indicates an expected call of ForceLoadTaskQueuePartition.
func (*MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueue ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueue(arg0, arg1 any) *gomock.Call
ForceUnloadTaskQueue indicates an expected call of ForceUnloadTaskQueue.
func (*MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueuePartition ¶
func (mr *MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueuePartition(arg0, arg1 any) *gomock.Call
ForceUnloadTaskQueuePartition indicates an expected call of ForceUnloadTaskQueuePartition.
func (*MockMatchingServiceServerMockRecorder) GetBuildIdTaskQueueMapping ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) GetBuildIdTaskQueueMapping(arg0, arg1 any) *gomock.Call
GetBuildIdTaskQueueMapping indicates an expected call of GetBuildIdTaskQueueMapping.
func (*MockMatchingServiceServerMockRecorder) GetTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) GetTaskQueueUserData(arg0, arg1 any) *gomock.Call
GetTaskQueueUserData indicates an expected call of GetTaskQueueUserData.
func (*MockMatchingServiceServerMockRecorder) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 any) *gomock.Call
GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (*MockMatchingServiceServerMockRecorder) GetWorkerVersioningRules ¶ added in v1.24.0
func (mr *MockMatchingServiceServerMockRecorder) GetWorkerVersioningRules(arg0, arg1 any) *gomock.Call
GetWorkerVersioningRules indicates an expected call of GetWorkerVersioningRules.
func (*MockMatchingServiceServerMockRecorder) ListNexusEndpoints ¶ added in v1.25.0
func (mr *MockMatchingServiceServerMockRecorder) ListNexusEndpoints(arg0, arg1 any) *gomock.Call
ListNexusEndpoints indicates an expected call of ListNexusEndpoints.
func (*MockMatchingServiceServerMockRecorder) ListTaskQueuePartitions ¶
func (mr *MockMatchingServiceServerMockRecorder) ListTaskQueuePartitions(arg0, arg1 any) *gomock.Call
ListTaskQueuePartitions indicates an expected call of ListTaskQueuePartitions.
func (*MockMatchingServiceServerMockRecorder) PollActivityTaskQueue ¶
func (mr *MockMatchingServiceServerMockRecorder) PollActivityTaskQueue(arg0, arg1 any) *gomock.Call
PollActivityTaskQueue indicates an expected call of PollActivityTaskQueue.
func (*MockMatchingServiceServerMockRecorder) PollNexusTaskQueue ¶ added in v1.24.0
func (mr *MockMatchingServiceServerMockRecorder) PollNexusTaskQueue(arg0, arg1 any) *gomock.Call
PollNexusTaskQueue indicates an expected call of PollNexusTaskQueue.
func (*MockMatchingServiceServerMockRecorder) PollWorkflowTaskQueue ¶
func (mr *MockMatchingServiceServerMockRecorder) PollWorkflowTaskQueue(arg0, arg1 any) *gomock.Call
PollWorkflowTaskQueue indicates an expected call of PollWorkflowTaskQueue.
func (*MockMatchingServiceServerMockRecorder) QueryWorkflow ¶
func (mr *MockMatchingServiceServerMockRecorder) QueryWorkflow(arg0, arg1 any) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockMatchingServiceServerMockRecorder) ReplicateTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) ReplicateTaskQueueUserData(arg0, arg1 any) *gomock.Call
ReplicateTaskQueueUserData indicates an expected call of ReplicateTaskQueueUserData.
func (*MockMatchingServiceServerMockRecorder) RespondNexusTaskCompleted ¶ added in v1.24.0
func (mr *MockMatchingServiceServerMockRecorder) RespondNexusTaskCompleted(arg0, arg1 any) *gomock.Call
RespondNexusTaskCompleted indicates an expected call of RespondNexusTaskCompleted.
func (*MockMatchingServiceServerMockRecorder) RespondNexusTaskFailed ¶ added in v1.24.0
func (mr *MockMatchingServiceServerMockRecorder) RespondNexusTaskFailed(arg0, arg1 any) *gomock.Call
RespondNexusTaskFailed indicates an expected call of RespondNexusTaskFailed.
func (*MockMatchingServiceServerMockRecorder) RespondQueryTaskCompleted ¶
func (mr *MockMatchingServiceServerMockRecorder) RespondQueryTaskCompleted(arg0, arg1 any) *gomock.Call
RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.
func (*MockMatchingServiceServerMockRecorder) SyncDeploymentUserData ¶
func (mr *MockMatchingServiceServerMockRecorder) SyncDeploymentUserData(arg0, arg1 any) *gomock.Call
SyncDeploymentUserData indicates an expected call of SyncDeploymentUserData.
func (*MockMatchingServiceServerMockRecorder) UpdateNexusEndpoint ¶ added in v1.25.0
func (mr *MockMatchingServiceServerMockRecorder) UpdateNexusEndpoint(arg0, arg1 any) *gomock.Call
UpdateNexusEndpoint indicates an expected call of UpdateNexusEndpoint.
func (*MockMatchingServiceServerMockRecorder) UpdateTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) UpdateTaskQueueUserData(arg0, arg1 any) *gomock.Call
UpdateTaskQueueUserData indicates an expected call of UpdateTaskQueueUserData.
func (*MockMatchingServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 any) *gomock.Call
UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.
func (*MockMatchingServiceServerMockRecorder) UpdateWorkerVersioningRules ¶ added in v1.24.0
func (mr *MockMatchingServiceServerMockRecorder) UpdateWorkerVersioningRules(arg0, arg1 any) *gomock.Call
UpdateWorkerVersioningRules indicates an expected call of UpdateWorkerVersioningRules.
type MockUnsafeMatchingServiceServer ¶ added in v1.23.0
type MockUnsafeMatchingServiceServer struct {
// contains filtered or unexported fields
}
MockUnsafeMatchingServiceServer is a mock of UnsafeMatchingServiceServer interface.
func NewMockUnsafeMatchingServiceServer ¶ added in v1.23.0
func NewMockUnsafeMatchingServiceServer(ctrl *gomock.Controller) *MockUnsafeMatchingServiceServer
NewMockUnsafeMatchingServiceServer creates a new mock instance.
func (*MockUnsafeMatchingServiceServer) EXPECT ¶ added in v1.23.0
func (m *MockUnsafeMatchingServiceServer) EXPECT() *MockUnsafeMatchingServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeMatchingServiceServerMockRecorder ¶ added in v1.23.0
type MockUnsafeMatchingServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeMatchingServiceServerMockRecorder is the mock recorder for MockUnsafeMatchingServiceServer.