144
145
// CancelOutstandingWorkerPollsPartition mocks base method.
146
>
func (m *MockMatchingServiceClient) CancelOutstandingWorkerPollsPartition(ctx context.Context, in *matchingservice.CancelOutstandingWorkerPollsPartitionRequest, opts ...grpc.CallOption) (*matchingservice.CancelOutstandingWorkerPollsPartitionResponse, error) {
service_grpc.pb.mock.go
147
>
m.ctrl.T.Helper()
148
>
varargs := []any{ctx, in}
149
>
for _, a := range opts {
150
varargs = append(varargs, a)
151
}
152
>
ret := m.ctrl.Call(m, "CancelOutstandingWorkerPollsPartition", varargs...)
service_grpc.pb.mock.go
153
>
ret0, _ := ret[0].(*matchingservice.CancelOutstandingWorkerPollsPartitionResponse)
154
>
ret1, _ := ret[1].(error)
155
>
return ret0, ret1
156
}
157
158
// CancelOutstandingWorkerPollsPartition indicates an expected call of CancelOutstandingWorkerPollsPartition.
159
>
func (mr *MockMatchingServiceClientMockRecorder) CancelOutstandingWorkerPollsPartition(ctx, in any, opts ...any) *gomock.Call {
service_grpc.pb.mock.go
160
>
mr.mock.ctrl.T.Helper()
161
>
varargs := append([]any{ctx, in}, opts...)
162
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CancelOutstandingWorkerPollsPartition", reflect.TypeOf((*MockMatchingServiceClient)(nil).CancelOutstandingWorkerPollsPartition), varargs...)
163
>
}
164
165
// CheckTaskQueueUserDataPropagation mocks base method.