Documentation ¶
Overview ¶
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) DescribeTaskQueue(ctx context.Context, in *matchingservice.DescribeTaskQueueRequest, ...) (*matchingservice.DescribeTaskQueueResponse, error)
- func (m *MockMatchingServiceClient) EXPECT() *MockMatchingServiceClientMockRecorder
- func (m *MockMatchingServiceClient) ForceUnloadTaskQueue(ctx context.Context, in *matchingservice.ForceUnloadTaskQueueRequest, ...) (*matchingservice.ForceUnloadTaskQueueResponse, 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) 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) 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) RespondQueryTaskCompleted(ctx context.Context, in *matchingservice.RespondQueryTaskCompletedRequest, ...) (*matchingservice.RespondQueryTaskCompletedResponse, error)
- func (m *MockMatchingServiceClient) UpdateTaskQueueUserData(ctx context.Context, in *matchingservice.UpdateTaskQueueUserDataRequest, ...) (*matchingservice.UpdateTaskQueueUserDataResponse, error)
- func (m *MockMatchingServiceClient) UpdateWorkerBuildIdCompatibility(ctx context.Context, ...) (*matchingservice.UpdateWorkerBuildIdCompatibilityResponse, error)
- type MockMatchingServiceClientMockRecorder
- func (mr *MockMatchingServiceClientMockRecorder) AddActivityTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) AddWorkflowTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ApplyTaskQueueUserDataReplicationEvent(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) CancelOutstandingPoll(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) DescribeTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) GetBuildIdTaskQueueMapping(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) GetTaskQueueUserData(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ListTaskQueuePartitions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) PollActivityTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) PollWorkflowTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) QueryWorkflow(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) ReplicateTaskQueueUserData(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) RespondQueryTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) UpdateTaskQueueUserData(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockMatchingServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, in interface{}, opts ...interface{}) *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) DescribeTaskQueue(arg0 context.Context, arg1 *matchingservice.DescribeTaskQueueRequest) (*matchingservice.DescribeTaskQueueResponse, error)
- func (m *MockMatchingServiceServer) EXPECT() *MockMatchingServiceServerMockRecorder
- func (m *MockMatchingServiceServer) ForceUnloadTaskQueue(arg0 context.Context, arg1 *matchingservice.ForceUnloadTaskQueueRequest) (*matchingservice.ForceUnloadTaskQueueResponse, 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) 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) 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) RespondQueryTaskCompleted(arg0 context.Context, arg1 *matchingservice.RespondQueryTaskCompletedRequest) (*matchingservice.RespondQueryTaskCompletedResponse, error)
- func (m *MockMatchingServiceServer) UpdateTaskQueueUserData(arg0 context.Context, arg1 *matchingservice.UpdateTaskQueueUserDataRequest) (*matchingservice.UpdateTaskQueueUserDataResponse, error)
- func (m *MockMatchingServiceServer) UpdateWorkerBuildIdCompatibility(arg0 context.Context, ...) (*matchingservice.UpdateWorkerBuildIdCompatibilityResponse, error)
- type MockMatchingServiceServerMockRecorder
- func (mr *MockMatchingServiceServerMockRecorder) AddActivityTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) AddWorkflowTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ApplyTaskQueueUserDataReplicationEvent(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) CancelOutstandingPoll(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) DescribeTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) GetBuildIdTaskQueueMapping(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) GetTaskQueueUserData(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ListTaskQueuePartitions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) PollActivityTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) PollWorkflowTaskQueue(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) QueryWorkflow(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) ReplicateTaskQueueUserData(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) RespondQueryTaskCompleted(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) UpdateTaskQueueUserData(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockMatchingServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
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) DescribeTaskQueue ¶
func (m *MockMatchingServiceClient) DescribeTaskQueue(ctx context.Context, in *matchingservice.DescribeTaskQueueRequest, opts ...grpc.CallOption) (*matchingservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue 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) 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) 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) 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) RespondQueryTaskCompleted ¶
func (m *MockMatchingServiceClient) RespondQueryTaskCompleted(ctx context.Context, in *matchingservice.RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*matchingservice.RespondQueryTaskCompletedResponse, error)
RespondQueryTaskCompleted 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.
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 interface{}, opts ...interface{}) *gomock.Call
AddActivityTask indicates an expected call of AddActivityTask.
func (*MockMatchingServiceClientMockRecorder) AddWorkflowTask ¶
func (mr *MockMatchingServiceClientMockRecorder) AddWorkflowTask(ctx, in interface{}, opts ...interface{}) *gomock.Call
AddWorkflowTask indicates an expected call of AddWorkflowTask.
func (*MockMatchingServiceClientMockRecorder) ApplyTaskQueueUserDataReplicationEvent ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) ApplyTaskQueueUserDataReplicationEvent(ctx, in interface{}, opts ...interface{}) *gomock.Call
ApplyTaskQueueUserDataReplicationEvent indicates an expected call of ApplyTaskQueueUserDataReplicationEvent.
func (*MockMatchingServiceClientMockRecorder) CancelOutstandingPoll ¶
func (mr *MockMatchingServiceClientMockRecorder) CancelOutstandingPoll(ctx, in interface{}, opts ...interface{}) *gomock.Call
CancelOutstandingPoll indicates an expected call of CancelOutstandingPoll.
func (*MockMatchingServiceClientMockRecorder) DescribeTaskQueue ¶
func (mr *MockMatchingServiceClientMockRecorder) DescribeTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (*MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueue ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) ForceUnloadTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
ForceUnloadTaskQueue indicates an expected call of ForceUnloadTaskQueue.
func (*MockMatchingServiceClientMockRecorder) GetBuildIdTaskQueueMapping ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) GetBuildIdTaskQueueMapping(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetBuildIdTaskQueueMapping indicates an expected call of GetBuildIdTaskQueueMapping.
func (*MockMatchingServiceClientMockRecorder) GetTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) GetTaskQueueUserData(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetTaskQueueUserData indicates an expected call of GetTaskQueueUserData.
func (*MockMatchingServiceClientMockRecorder) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) GetWorkerBuildIdCompatibility(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (*MockMatchingServiceClientMockRecorder) ListTaskQueuePartitions ¶
func (mr *MockMatchingServiceClientMockRecorder) ListTaskQueuePartitions(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListTaskQueuePartitions indicates an expected call of ListTaskQueuePartitions.
func (*MockMatchingServiceClientMockRecorder) PollActivityTaskQueue ¶
func (mr *MockMatchingServiceClientMockRecorder) PollActivityTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
PollActivityTaskQueue indicates an expected call of PollActivityTaskQueue.
func (*MockMatchingServiceClientMockRecorder) PollWorkflowTaskQueue ¶
func (mr *MockMatchingServiceClientMockRecorder) PollWorkflowTaskQueue(ctx, in interface{}, opts ...interface{}) *gomock.Call
PollWorkflowTaskQueue indicates an expected call of PollWorkflowTaskQueue.
func (*MockMatchingServiceClientMockRecorder) QueryWorkflow ¶
func (mr *MockMatchingServiceClientMockRecorder) QueryWorkflow(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockMatchingServiceClientMockRecorder) ReplicateTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) ReplicateTaskQueueUserData(ctx, in interface{}, opts ...interface{}) *gomock.Call
ReplicateTaskQueueUserData indicates an expected call of ReplicateTaskQueueUserData.
func (*MockMatchingServiceClientMockRecorder) RespondQueryTaskCompleted ¶
func (mr *MockMatchingServiceClientMockRecorder) RespondQueryTaskCompleted(ctx, in interface{}, opts ...interface{}) *gomock.Call
RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.
func (*MockMatchingServiceClientMockRecorder) UpdateTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) UpdateTaskQueueUserData(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateTaskQueueUserData indicates an expected call of UpdateTaskQueueUserData.
func (*MockMatchingServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockMatchingServiceClientMockRecorder) UpdateWorkerBuildIdCompatibility(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.
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) DescribeTaskQueue ¶
func (m *MockMatchingServiceServer) DescribeTaskQueue(arg0 context.Context, arg1 *matchingservice.DescribeTaskQueueRequest) (*matchingservice.DescribeTaskQueueResponse, error)
DescribeTaskQueue 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) 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) 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) 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) RespondQueryTaskCompleted ¶
func (m *MockMatchingServiceServer) RespondQueryTaskCompleted(arg0 context.Context, arg1 *matchingservice.RespondQueryTaskCompletedRequest) (*matchingservice.RespondQueryTaskCompletedResponse, error)
RespondQueryTaskCompleted 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.
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 interface{}) *gomock.Call
AddActivityTask indicates an expected call of AddActivityTask.
func (*MockMatchingServiceServerMockRecorder) AddWorkflowTask ¶
func (mr *MockMatchingServiceServerMockRecorder) AddWorkflowTask(arg0, arg1 interface{}) *gomock.Call
AddWorkflowTask indicates an expected call of AddWorkflowTask.
func (*MockMatchingServiceServerMockRecorder) ApplyTaskQueueUserDataReplicationEvent ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) ApplyTaskQueueUserDataReplicationEvent(arg0, arg1 interface{}) *gomock.Call
ApplyTaskQueueUserDataReplicationEvent indicates an expected call of ApplyTaskQueueUserDataReplicationEvent.
func (*MockMatchingServiceServerMockRecorder) CancelOutstandingPoll ¶
func (mr *MockMatchingServiceServerMockRecorder) CancelOutstandingPoll(arg0, arg1 interface{}) *gomock.Call
CancelOutstandingPoll indicates an expected call of CancelOutstandingPoll.
func (*MockMatchingServiceServerMockRecorder) DescribeTaskQueue ¶
func (mr *MockMatchingServiceServerMockRecorder) DescribeTaskQueue(arg0, arg1 interface{}) *gomock.Call
DescribeTaskQueue indicates an expected call of DescribeTaskQueue.
func (*MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueue ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) ForceUnloadTaskQueue(arg0, arg1 interface{}) *gomock.Call
ForceUnloadTaskQueue indicates an expected call of ForceUnloadTaskQueue.
func (*MockMatchingServiceServerMockRecorder) GetBuildIdTaskQueueMapping ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) GetBuildIdTaskQueueMapping(arg0, arg1 interface{}) *gomock.Call
GetBuildIdTaskQueueMapping indicates an expected call of GetBuildIdTaskQueueMapping.
func (*MockMatchingServiceServerMockRecorder) GetTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) GetTaskQueueUserData(arg0, arg1 interface{}) *gomock.Call
GetTaskQueueUserData indicates an expected call of GetTaskQueueUserData.
func (*MockMatchingServiceServerMockRecorder) GetWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) GetWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
GetWorkerBuildIdCompatibility indicates an expected call of GetWorkerBuildIdCompatibility.
func (*MockMatchingServiceServerMockRecorder) ListTaskQueuePartitions ¶
func (mr *MockMatchingServiceServerMockRecorder) ListTaskQueuePartitions(arg0, arg1 interface{}) *gomock.Call
ListTaskQueuePartitions indicates an expected call of ListTaskQueuePartitions.
func (*MockMatchingServiceServerMockRecorder) PollActivityTaskQueue ¶
func (mr *MockMatchingServiceServerMockRecorder) PollActivityTaskQueue(arg0, arg1 interface{}) *gomock.Call
PollActivityTaskQueue indicates an expected call of PollActivityTaskQueue.
func (*MockMatchingServiceServerMockRecorder) PollWorkflowTaskQueue ¶
func (mr *MockMatchingServiceServerMockRecorder) PollWorkflowTaskQueue(arg0, arg1 interface{}) *gomock.Call
PollWorkflowTaskQueue indicates an expected call of PollWorkflowTaskQueue.
func (*MockMatchingServiceServerMockRecorder) QueryWorkflow ¶
func (mr *MockMatchingServiceServerMockRecorder) QueryWorkflow(arg0, arg1 interface{}) *gomock.Call
QueryWorkflow indicates an expected call of QueryWorkflow.
func (*MockMatchingServiceServerMockRecorder) ReplicateTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) ReplicateTaskQueueUserData(arg0, arg1 interface{}) *gomock.Call
ReplicateTaskQueueUserData indicates an expected call of ReplicateTaskQueueUserData.
func (*MockMatchingServiceServerMockRecorder) RespondQueryTaskCompleted ¶
func (mr *MockMatchingServiceServerMockRecorder) RespondQueryTaskCompleted(arg0, arg1 interface{}) *gomock.Call
RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.
func (*MockMatchingServiceServerMockRecorder) UpdateTaskQueueUserData ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) UpdateTaskQueueUserData(arg0, arg1 interface{}) *gomock.Call
UpdateTaskQueueUserData indicates an expected call of UpdateTaskQueueUserData.
func (*MockMatchingServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility ¶ added in v1.21.0
func (mr *MockMatchingServiceServerMockRecorder) UpdateWorkerBuildIdCompatibility(arg0, arg1 interface{}) *gomock.Call
UpdateWorkerBuildIdCompatibility indicates an expected call of UpdateWorkerBuildIdCompatibility.