Package io.permazen.kv.test

Class KVTestSupport

java.lang.Object

io.permazen.test.TestSupport

io.permazen.kv.test.KVTestSupport

Direct Known Subclasses:

AtomicKVStoreTest, KVDatabaseTest

public abstract class KVTestSupport
extends TestSupport

Base class for key/value unit tests.

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicInteger	numTransactionAttempts
protected final AtomicInteger	numTransactionRetries

Fields inherited from class io.permazen.test.TestSupport

log, random, validator

Constructor Summary

Constructors

Constructor	Description
KVTestSupport()

Method Summary

Modifier and Type	Method	Description
protected static ByteData	b(String string)
protected KVTransaction	createKVTransaction(KVDatabase kvdb)
protected KVTransaction	doCreateTransaction(KVDatabase kvdb)
protected int	getNumTries()
protected static KVPair	kv(String... key)
protected String	mapRetryExceptionMessage(String message)
protected static String	s(KVPair pair)
protected static String	s(ByteData data)
void	setupTransactionAttemptCounters()
protected RuntimeException	showKV(KVStore kv, String label)	Dump KV contents to the log.
protected RuntimeException	showKV(KVStore kv, String label, ByteData minKey, ByteData maxKey)	Dump KV portion to the log.
static NavigableMap<String,String>	stringView(NavigableMap<ByteData,ByteData> byteMap)
static NavigableSet<String>	stringView(NavigableSet<ByteData> byteSet)
void	teardownTransactionAttemptCounters()
protected String	toXmlString(KVStore kv)
protected String	toXmlString(KVStore kv, ByteData minKey, ByteData maxKey)
protected void	tryNtimes(KVDatabase kvdb, Consumer<KVTransaction> consumer)
protected <R> R	tryNtimesWithResult(KVDatabase kvdb, Function<KVTransaction,R> function)
protected void	updateRetryStats(RetryKVTransactionException e)

Methods inherited from class io.permazen.test.TestSupport

assertEquals, assertEquals, assertSameOrDiff, buildList, buildMap, buildSet, buildSortedMap, buildSortedSet, checkMap, checkSet, checkValid, createTempDirectory, deleteDirectoryHierarchy, diff, getRandom, readResource, readResource, readResource, seedRandom, setUpValidator, show

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

numTransactionAttempts

protected final AtomicInteger numTransactionAttempts

numTransactionRetries

protected final AtomicInteger numTransactionRetries

Constructor Details

KVTestSupport

public KVTestSupport()

Method Details

setupTransactionAttemptCounters

@BeforeClass
public void setupTransactionAttemptCounters()
                                     throws Exception

Throws:

Exception

teardownTransactionAttemptCounters

@AfterClass
public void teardownTransactionAttemptCounters()
                                        throws Exception

Throws:

Exception

showKV

protected RuntimeException showKV(KVStore kv,
 String label)

Dump KV contents to the log.

Parameters:

kv - k/v store

label - descriptive label

Returns:

exception thrown during query, or null if successful

showKV

protected RuntimeException showKV(KVStore kv,
 String label,
 ByteData minKey,
 ByteData maxKey)

Dump KV portion to the log.

Parameters:

kv - k/v store

label - descriptive label

minKey - minimum key

maxKey - maximum key

Returns:

exception thrown during query, or null if successful

toXmlString

protected String toXmlString(KVStore kv)

toXmlString

protected String toXmlString(KVStore kv,
 ByteData minKey,
 ByteData maxKey)

s

protected static String s(ByteData data)

b

protected static ByteData b(String string)

s

protected static String s(KVPair pair)

kv

protected static KVPair kv(String... key)

stringView

public static NavigableMap<String,String> stringView(NavigableMap<ByteData,ByteData> byteMap)

stringView

public static NavigableSet<String> stringView(NavigableSet<ByteData> byteSet)

tryNtimes

protected void tryNtimes(KVDatabase kvdb,
 Consumer<KVTransaction> consumer)

tryNtimesWithResult

protected <R> R tryNtimesWithResult(KVDatabase kvdb,
 Function<KVTransaction,R> function)

getNumTries

protected int getNumTries()

createKVTransaction

protected KVTransaction createKVTransaction(KVDatabase kvdb)

doCreateTransaction

protected KVTransaction doCreateTransaction(KVDatabase kvdb)

updateRetryStats

protected void updateRetryStats(RetryKVTransactionException e)

mapRetryExceptionMessage

protected String mapRetryExceptionMessage(String message)