@Test public void testPurgeTSDRRecords() { impl.purge(DataCategory.QUEUESTATS,0L); Mockito.verify(store,Mockito.atLeast(1)).purge(DataCategory.QUEUESTATS,0L); }
@Override public void purge(DataCategory category, long retentionTime) { LOG.info("Execute Purge with Category {} and earlier than {}.",category.name(),new Date(retentionTime)); store.purge(category,retentionTime); }
TSDRCassandraPersistenceServiceImpl implements TSDRMetricPersistenceService,TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void purge(DataCategory category, long retentionTime) { LOG.info("Execute Purge with Category {} and earlier than {}.",category.name(),new Date(retentionTime)); store.purge(category,retentionTime); } }
TSDRCassandraPersistenceServiceImpl implements TSDRMetricPersistenceService,TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void purge(DataCategory category, long retentionTime) { LOG.info("Execute Purge with Category {} and earlier than {}.",category.name(),new Date(retentionTime)); store.purge(category,retentionTime); } @Inject  TSDRCassandraPersistenceServiceImpl(CassandraStore store); }
TSDRCassandraPersistenceServiceImpl implements TSDRMetricPersistenceService,TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void purge(DataCategory category, long retentionTime) { LOG.info("Execute Purge with Category {} and earlier than {}.",category.name(),new Date(retentionTime)); store.purge(category,retentionTime); } @Inject  TSDRCassandraPersistenceServiceImpl(CassandraStore store); @Override void storeMetric(TSDRMetricRecord metricRecord); @Override void storeMetric(List<TSDRMetricRecord> metricRecordList); @Override void storeLog(TSDRLogRecord logRecord); @Override void storeLog(List<TSDRLogRecord> metricRecordList); @Override void storeBinary(TSDRBinaryRecord binaryRecord); @Override void storeBinary(List<TSDRBinaryRecord> recordList); @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 tsdrBinaryKey, long startTime, long endTime); }
TSDRCassandraPersistenceServiceImpl implements TSDRMetricPersistenceService,TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void purge(DataCategory category, long retentionTime) { LOG.info("Execute Purge with Category {} and earlier than {}.",category.name(),new Date(retentionTime)); store.purge(category,retentionTime); } @Inject  TSDRCassandraPersistenceServiceImpl(CassandraStore store); @Override void storeMetric(TSDRMetricRecord metricRecord); @Override void storeMetric(List<TSDRMetricRecord> metricRecordList); @Override void storeLog(TSDRLogRecord logRecord); @Override void storeLog(List<TSDRLogRecord> metricRecordList); @Override void storeBinary(TSDRBinaryRecord binaryRecord); @Override void storeBinary(List<TSDRBinaryRecord> recordList); @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 tsdrBinaryKey, long startTime, long endTime);  }