345
346
// GenerateLastHistoryReplicationTasks mocks base method.
347
>
func (m *MockHistoryServiceClient) GenerateLastHistoryReplicationTasks(ctx context.Context, in *historyservice.GenerateLastHistoryReplicationTasksRequest, opts ...grpc.CallOption) (*historyservice.GenerateLastHistoryReplicationTasksResponse, error) {
service_grpc.pb.mock.go
348
>
m.ctrl.T.Helper()
349
>
varargs := []any{ctx, in}
350
>
for _, a := range opts {
351
varargs = append(varargs, a)
352
}
353
>
ret := m.ctrl.Call(m, "GenerateLastHistoryReplicationTasks", varargs...)
service_grpc.pb.mock.go
354
>
ret0, _ := ret[0].(*historyservice.GenerateLastHistoryReplicationTasksResponse)
355
>
ret1, _ := ret[1].(error)
356
>
return ret0, ret1
357
}
358
359
// GenerateLastHistoryReplicationTasks indicates an expected call of GenerateLastHistoryReplicationTasks.
360
>
func (mr *MockHistoryServiceClientMockRecorder) GenerateLastHistoryReplicationTasks(ctx, in any, opts ...any) *gomock.Call {
service_grpc.pb.mock.go
361
>
mr.mock.ctrl.T.Helper()
362
>
varargs := append([]any{ctx, in}, opts...)
363
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GenerateLastHistoryReplicationTasks", reflect.TypeOf((*MockHistoryServiceClient)(nil).GenerateLastHistoryReplicationTasks), varargs...)
364
>
}
365
366
// GetDLQMessages mocks base method.