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 and Description
protected AtomicInteger	numTransactionAttempts
protected AtomicInteger	numTransactionRetries

Fields inherited from class io.permazen.test.TestSupport

log, random, validator

Constructor Summary

Constructors

Constructor and Description
KVTestSupport()

Method Summary

Modifier and Type	Method and Description
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 String	s(KVPair pair)
void	setupTransactionAttemptCounters()
protected RuntimeException	showKV(KVStore kv, String label) Dump KV contents to the log.
protected RuntimeException	showKV(KVStore kv, String label, byte[] minKey, byte[] maxKey) Dump KV portion to the log.
static NavigableMap<String,String>	stringView(NavigableMap<byte[],byte[]> byteMap)
static NavigableSet<String>	stringView(NavigableSet<byte[]> byteSet)
void	teardownTransactionAttemptCounters()
protected String	toXmlString(KVStore kv)
protected String	toXmlString(KVStore kv, byte[] minKey, byte[] maxKey)
protected void	tryNtimes(KVDatabase kvdb, Consumer<KVTransaction> consumer)
protected <R> R	tryNtimesWithResult(KVDatabase kvdb, Function<KVTransaction,R> function)
protected void	updateRetryStats(RetryTransactionException e)

Methods inherited from class io.permazen.test.TestSupport

assertEquals, assertEquals, b, ba, buildList, buildMap, buildSet, buildSortedMap, buildSortedSet, checkMap, checkSet, checkValid, createTempDirectory, deleteDirectoryHierarchy, diff, getRandom, randomBytes, randomBytes, readResource, readResource, readResource, s, seedRandom, setUpValidator, show

Methods inherited from class java.lang.Object

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

Field Detail

numTransactionAttempts

protected final AtomicInteger numTransactionAttempts

numTransactionRetries

protected final AtomicInteger numTransactionRetries

Constructor Detail

KVTestSupport

public KVTestSupport()

Method Detail

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,
                                  byte[] minKey,
                                  byte[] 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,
                             byte[] minKey,
                             byte[] maxKey)

s

protected String s(KVPair pair)

kv

protected static KVPair kv(String... key)

stringView

public static NavigableMap<String,String> stringView(NavigableMap<byte[],byte[]> byteMap)

stringView

public static NavigableSet<String> stringView(NavigableSet<byte[]> 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(RetryTransactionException e)

mapRetryExceptionMessage

protected String mapRetryExceptionMessage(String message)