matchingservicemock

package
v1.26.2-121.0 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package matchingservicemock is a generated GoMock package.

Package matchingservicemock is a generated GoMock package.

Index

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) 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) 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) 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) 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) 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) 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) 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) 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.