@Test public void testStoreLog() { TSDRLogRecord logRecord = CassandraStoreTest.createLogRecord(); impl.storeLog(logRecord); Mockito.verify(store, Mockito.atLeast(1)).store(logRecord); }
@Override public void storeLog(TSDRLogRecord logRecord) { store.startBatch(); store.store(logRecord); store.executeBatch(); }
TSDRCassandraPersistenceServiceImpl implements TSDRMetricPersistenceService,TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void storeLog(TSDRLogRecord logRecord) { store.startBatch(); store.store(logRecord); store.executeBatch(); } }
TSDRCassandraPersistenceServiceImpl implements TSDRMetricPersistenceService,TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void storeLog(TSDRLogRecord logRecord) { store.startBatch(); store.store(logRecord); store.executeBatch(); } @Inject  TSDRCassandraPersistenceServiceImpl(CassandraStore store); }
TSDRCassandraPersistenceServiceImpl implements TSDRMetricPersistenceService,TSDRLogPersistenceService,
        TSDRBinaryPersistenceService { @Override public void storeLog(TSDRLogRecord logRecord) { store.startBatch(); store.store(logRecord); store.executeBatch(); } @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 storeLog(TSDRLogRecord logRecord) { store.startBatch(); store.store(logRecord); store.executeBatch(); } @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);  }