@Test public void testGetTSDRLogRecords() throws SQLException { impl.getTSDRLogRecords("Test",0L,0L); Mockito.verify(store,Mockito.atLeastOnce()).getTSDRLogRecords("Test",0L,0L,1000); }
@Override public List<TSDRLogRecord> getTSDRLogRecords(String tsdrMetricKey, long startTime, long endTime) { try { return store.getTSDRLogRecords(tsdrMetricKey, startTime, endTime, TSDRConstants.MAX_RESULTS_FROM_LIST_METRICS_COMMAND); } catch (SQLException e) { LOG.error("Failed to get log Records", e); return null; } }
TsdrHsqlDBPersistenceServiceImpl implements TSDRMetricPersistenceService, TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public List<TSDRLogRecord> getTSDRLogRecords(String tsdrMetricKey, long startTime, long endTime) { try { return store.getTSDRLogRecords(tsdrMetricKey, startTime, endTime, TSDRConstants.MAX_RESULTS_FROM_LIST_METRICS_COMMAND); } catch (SQLException e) { LOG.error("Failed to get log Records", e); return null; } } }
TsdrHsqlDBPersistenceServiceImpl implements TSDRMetricPersistenceService, TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public List<TSDRLogRecord> getTSDRLogRecords(String tsdrMetricKey, long startTime, long endTime) { try { return store.getTSDRLogRecords(tsdrMetricKey, startTime, endTime, TSDRConstants.MAX_RESULTS_FROM_LIST_METRICS_COMMAND); } catch (SQLException e) { LOG.error("Failed to get log Records", e); return null; } } @Inject  TsdrHsqlDBPersistenceServiceImpl(HsqlDBStore store); }
TsdrHsqlDBPersistenceServiceImpl implements TSDRMetricPersistenceService, TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public List<TSDRLogRecord> getTSDRLogRecords(String tsdrMetricKey, long startTime, long endTime) { try { return store.getTSDRLogRecords(tsdrMetricKey, startTime, endTime, TSDRConstants.MAX_RESULTS_FROM_LIST_METRICS_COMMAND); } catch (SQLException e) { LOG.error("Failed to get log Records", e); return null; } } @Inject  TsdrHsqlDBPersistenceServiceImpl(HsqlDBStore store); @Override void storeMetric(TSDRMetricRecord metricRecord); @Override void storeMetric(List<TSDRMetricRecord> metricRecordList); @Override void storeLog(TSDRLogRecord logRecord); @Override void storeLog(List<TSDRLogRecord> logRecordList); @Override void purge(DataCategory category, long retentionTime); @Override void purge(long retentionTime); @Override List<TSDRMetricRecord> getTSDRMetricRecords(String tsdrMetricKey, long startDateTime, long endDateTime); @Override List<TSDRLogRecord> getTSDRLogRecords(String tsdrMetricKey, long startTime, long endTime); @Override List<TSDRBinaryRecord> getTSDRBinaryRecords(String tsdrMetricKey, long startDateTime, long endDateTime); @Override void storeBinary(TSDRBinaryRecord binaryRecord); @Override void storeBinary(List<TSDRBinaryRecord> recordList); }
TsdrHsqlDBPersistenceServiceImpl implements TSDRMetricPersistenceService, TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public List<TSDRLogRecord> getTSDRLogRecords(String tsdrMetricKey, long startTime, long endTime) { try { return store.getTSDRLogRecords(tsdrMetricKey, startTime, endTime, TSDRConstants.MAX_RESULTS_FROM_LIST_METRICS_COMMAND); } catch (SQLException e) { LOG.error("Failed to get log Records", e); return null; } } @Inject  TsdrHsqlDBPersistenceServiceImpl(HsqlDBStore store); @Override void storeMetric(TSDRMetricRecord metricRecord); @Override void storeMetric(List<TSDRMetricRecord> metricRecordList); @Override void storeLog(TSDRLogRecord logRecord); @Override void storeLog(List<TSDRLogRecord> logRecordList); @Override void purge(DataCategory category, long retentionTime); @Override void purge(long retentionTime); @Override List<TSDRMetricRecord> getTSDRMetricRecords(String tsdrMetricKey, long startDateTime, long endDateTime); @Override List<TSDRLogRecord> getTSDRLogRecords(String tsdrMetricKey, long startTime, long endTime); @Override List<TSDRBinaryRecord> getTSDRBinaryRecords(String tsdrMetricKey, long startDateTime, long endDateTime); @Override void storeBinary(TSDRBinaryRecord binaryRecord); @Override void storeBinary(List<TSDRBinaryRecord> recordList);  }