-
Notifications
You must be signed in to change notification settings - Fork 613
/
RocksDBReaderTest.java
37 lines (30 loc) · 1.67 KB
/
RocksDBReaderTest.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
package org.infinispan.tools.store.migrator.rocksdb;
import static org.infinispan.tools.store.migrator.Element.LOCATION;
import static org.infinispan.tools.store.migrator.Element.SOURCE;
import static org.infinispan.tools.store.migrator.Element.TYPE;
import static org.infinispan.tools.store.migrator.TestUtil.propKey;
import java.util.Properties;
import org.infinispan.configuration.cache.Configuration;
import org.infinispan.configuration.cache.ConfigurationBuilder;
import org.infinispan.persistence.rocksdb.configuration.RocksDBStoreConfigurationBuilder;
import org.infinispan.tools.store.migrator.AbstractReaderTest;
import org.infinispan.tools.store.migrator.Element;
import org.infinispan.tools.store.migrator.StoreType;
import org.testng.annotations.Test;
@Test(testName = "tools.store.migrator.rocksdb.RocksDBReaderTest", groups = "functional")
public class RocksDBReaderTest extends AbstractReaderTest {
private static final String SOURCE_DIR = "target/test-classes/leveldbstore/";
private static final String TARGET_DIR = SOURCE_DIR + "/rocksdbstore/";
public Configuration getTargetCacheConfig() {
return new ConfigurationBuilder().persistence()
.addStore(RocksDBStoreConfigurationBuilder.class).location(TARGET_DIR).expiredLocation(TARGET_DIR + "-expired-")
.preload(true).ignoreModifications(true)
.build();
}
@Override
protected void configureStoreProperties(Properties properties, Element type) {
super.configureStoreProperties(properties, type);
properties.put(propKey(type, TYPE), StoreType.ROCKSDB.toString());
properties.put(propKey(type, LOCATION), type == SOURCE ? SOURCE_DIR : TARGET_DIR);
}
}