@Test public void purgeAll() throws Exception { long until = 0L; service.purge(until); for (DataCategory category : DataCategory.values()) { Mockito.verify(store, Mockito.atLeastOnce()).delete(category, until); } }
@Override public void purge(long timestamp) { for (DataCategory category : DataCategory.values()) { purge(category, timestamp); } }
TsdrElasticSearchPersistenceServiceImpl implements TSDRMetricPersistenceService, TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void purge(long timestamp) { for (DataCategory category : DataCategory.values()) { purge(category, timestamp); } } }
TsdrElasticSearchPersistenceServiceImpl implements TSDRMetricPersistenceService, TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void purge(long timestamp) { for (DataCategory category : DataCategory.values()) { purge(category, timestamp); } } @Inject  TsdrElasticSearchPersistenceServiceImpl(ElasticSearchStore store); }
TsdrElasticSearchPersistenceServiceImpl implements TSDRMetricPersistenceService, TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void purge(long timestamp) { for (DataCategory category : DataCategory.values()) { purge(category, timestamp); } } @Inject  TsdrElasticSearchPersistenceServiceImpl(ElasticSearchStore store); @Override void storeMetric(TSDRMetricRecord metricRecord); @Override void storeMetric(List<TSDRMetricRecord> recordList); @Override List<TSDRMetricRecord> getTSDRMetricRecords(String key, long start, long end); @Override void storeLog(TSDRLogRecord logRecord); @Override void storeLog(List<TSDRLogRecord> recordList); @Override List<TSDRLogRecord> getTSDRLogRecords(String key, long start, long end); @Override void storeBinary(TSDRBinaryRecord binaryRecord); @Override void storeBinary(List<TSDRBinaryRecord> recordList); @Override List<TSDRBinaryRecord> getTSDRBinaryRecords(String key, long start, long end); @Override void purge(long timestamp); @Override void purge(DataCategory category, long timestamp); }
TsdrElasticSearchPersistenceServiceImpl implements TSDRMetricPersistenceService, TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void purge(long timestamp) { for (DataCategory category : DataCategory.values()) { purge(category, timestamp); } } @Inject  TsdrElasticSearchPersistenceServiceImpl(ElasticSearchStore store); @Override void storeMetric(TSDRMetricRecord metricRecord); @Override void storeMetric(List<TSDRMetricRecord> recordList); @Override List<TSDRMetricRecord> getTSDRMetricRecords(String key, long start, long end); @Override void storeLog(TSDRLogRecord logRecord); @Override void storeLog(List<TSDRLogRecord> recordList); @Override List<TSDRLogRecord> getTSDRLogRecords(String key, long start, long end); @Override void storeBinary(TSDRBinaryRecord binaryRecord); @Override void storeBinary(List<TSDRBinaryRecord> recordList); @Override List<TSDRBinaryRecord> getTSDRBinaryRecords(String key, long start, long end); @Override void purge(long timestamp); @Override void purge(DataCategory category, long timestamp);  }