Modifier and Type | Method and Description |
---|---|
<T extends Options> |
XmlProgressListener.afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run) |
<T extends Options> |
StreamProgressListener.afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run) |
<T extends Options> |
ProgressListener.afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run)
Invoked after each run of an operation
|
<T extends Options> |
CsvProgressListener.afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run)
Does nothing as this listener discards individual operation run
statistics
|
<T extends Options> |
XmlProgressListener.afterOperationMix(Runner<T> runner,
T options,
OperationMix mix,
OperationMixRun run) |
<T extends Options> |
StreamProgressListener.afterOperationMix(Runner<T> runner,
T options,
OperationMix mix,
OperationMixRun run) |
<T extends Options> |
ProgressListener.afterOperationMix(Runner<T> runner,
T options,
OperationMix mix,
OperationMixRun run)
Invoked after each run of an operation mix
|
<T extends Options> |
CsvProgressListener.afterOperationMix(Runner<T> runner,
T options,
OperationMix mix,
OperationMixRun run)
Handles the Mix progress event by recording the run statistics for later
printing to the CSV file
|
<T extends Options> |
XmlProgressListener.beforeOperation(Runner<T> runner,
T options,
Operation operation)
Does nothing as this listener discards individual operation run
statistics
|
<T extends Options> |
StreamProgressListener.beforeOperation(Runner<T> runner,
T options,
Operation operation) |
<T extends Options> |
ProgressListener.beforeOperation(Runner<T> runner,
T options,
Operation operation)
Invoked before each run of an operation
|
<T extends Options> |
CsvProgressListener.beforeOperation(Runner<T> runner,
T options,
Operation operation)
Does nothing as this listener discards individual operation run
statistics
|
<T extends Options> |
XmlProgressListener.beforeOperationMix(Runner<T> runner,
T options,
OperationMix mix) |
<T extends Options> |
StreamProgressListener.beforeOperationMix(Runner<T> runner,
T options,
OperationMix mix) |
<T extends Options> |
ProgressListener.beforeOperationMix(Runner<T> runner,
T options,
OperationMix mix)
Invoked before each run of an operation mix
|
<T extends Options> |
CsvProgressListener.beforeOperationMix(Runner<T> runner,
T options,
OperationMix mix) |
<T extends Options> |
XmlProgressListener.finish(Runner<T> runner,
T options,
boolean ok)
Handles the finished event by printing statistics to the XML file
|
<T extends Options> |
StreamProgressListener.finish(Runner<T> runner,
T options,
boolean ok) |
<T extends Options> |
ProgressListener.finish(Runner<T> runner,
T options,
boolean ok)
Invoked when test runs finish
|
<T extends Options> |
CsvProgressListener.finish(Runner<T> runner,
T options,
boolean ok)
Handles the finished event by printing relevant statistics to the CSV
file
|
<T extends Options> |
XmlProgressListener.progress(Runner<T> runner,
T options,
String message) |
<T extends Options> |
StreamProgressListener.progress(Runner<T> runner,
T options,
String message) |
<T extends Options> |
ProgressListener.progress(Runner<T> runner,
T options,
String message)
Invoked when an informational progress message is available
|
<T extends Options> |
CsvProgressListener.progress(Runner<T> runner,
T options,
String message)
Does nothing as this listener discards informational messages
|
<T extends Options> |
XmlProgressListener.start(Runner<T> runner,
T options)
Handles the started event by printing run configuration to the XML file
|
<T extends Options> |
StreamProgressListener.start(Runner<T> runner,
T options) |
<T extends Options> |
ProgressListener.start(Runner<T> runner,
T options)
Invoked when test runs start
|
<T extends Options> |
CsvProgressListener.start(Runner<T> runner,
T options)
Handles the started event by preparing a record of the run configuration
which will eventually be printed to the CSV file
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractOperationCallable<T extends Options>
Abstract implementation of an operation callable
|
interface |
OperationCallable<T extends Options>
Interface for operation callables
|
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
Operation.canRun(Runner<T> runner,
T options)
Report whether the operation can run based on the available options
|
<T extends Options> |
Operation.createCallable(Runner<T> runner,
T options)
Creates the callable for running the operation in a background thread
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractGSPCallable<T extends Options>
Abstract callable for GSP operations
|
class |
GSPDeleteCallable<T extends Options>
A callable which runs the Graph Store Protocol DELETE operation
|
class |
GSPGetCallable<T extends Options>
A callable which runs the Graph Store Protocol GET operation
|
class |
GSPHeadCallable<T extends Options>
A callable which runs the Graph Store Protocol HEAD operation
|
class |
GSPPostCallable<T extends Options>
A callable which runs the Graph Store Protocol POST operation
|
class |
GSPPutCallable<T extends Options>
A callable which runs the Graph Store Protocol PUT operation
|
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
AbstractGSPOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
GSPPutOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
GSPPostOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
GSPHeadOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
GSPGetOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
GSPDeleteOperation.createCallable(Runner<T> runner,
T options) |
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
ParameterizedUpdateOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
ParameterizedQueryOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
InMemoryParameterizedUpdateOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
InMemoryParameterizedQueryOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
InMemoryParameterizedUpdateOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
InMemoryParameterizedQueryOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
AbstractParameterizedUpdateOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
AbstractParameterizedQueryOperation.createCallable(Runner<T> runner,
T options) |
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
ParameterizedNvpUpdateOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
ParameterizedNvpQueryOperation.createCallable(Runner<T> runner,
T options) |
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
DatasetSizeOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
AbstractRemoteQueryOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
AbstractInMemoryQueryOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
DatasetSizeOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
AbstractRemoteQueryOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
AbstractInMemoryQueryOperation.createCallable(Runner<T> runner,
T options) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractInMemoryQueryCallable<T extends Options>
Abstract callable for operations that run queries against a local in-memory
dataset
|
class |
AbstractQueryCallable<T extends Options>
Abstract callable for queries
|
class |
AbstractRemoteQueryCallable<T extends Options>
Abstract callable for operations that run queries against a remote service
via HTTP
|
class |
AbstractScalarValueCallable<T extends Options,TCallable extends AbstractQueryCallable<T>>
A callable which counts SELECT results by retrieving the value of a specific
column of the first row and then converting that value into an integer
|
class |
InMemoryQueryCallable<T extends Options>
A Callable for queries so we can execute them asynchronously with timeouts
|
class |
LongValueCallable<T extends Options,TCallable extends AbstractQueryCallable<T>>
A callable for getting the value of a specific variable in the first row of a
result set as a long
|
class |
RemoteQueryCallable<T extends Options>
A Callable for queries so we can execute them asynchronously with timeouts
|
class |
WrapperQueryCallable<T extends Options,TCallable extends AbstractQueryCallable<T>>
A decorator to allow query callables to have parts of their behaviour
modified without extending them directly.
|
Modifier and Type | Class and Description |
---|---|
class |
NvpQueryCallable<T extends Options>
A query callable that adds custom NVPs to the request
|
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
FixedNvpQueryOperation.createCallable(Runner<T> runner,
T options) |
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
InMemoryFixedUpdateOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
FixedUpdateOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
InMemoryFixedUpdateOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
FixedUpdateOperation.createCallable(Runner<T> runner,
T options) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractInMemoryUpdateCallable<T extends Options>
Abstract callable for operations that run updates against a local in-memory
dataset
|
class |
AbstractRemoteUpdateCallable<T extends Options>
Abstract callable for operations that run updates
|
class |
AbstractUpdateCallable<T extends Options>
Abstract callable for update operations
|
class |
InMemoryUpdateCallable<T extends Options> |
class |
RemoteUpdateCallable<T extends Options> |
Modifier and Type | Class and Description |
---|---|
class |
NvpUpdateCallable<T extends Options>
An update callable that adds custom NVPs to the request
|
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
FixedNvpUpdateOperation.createCallable(Runner<T> runner,
T options) |
Modifier and Type | Class and Description |
---|---|
class |
MixOperationCallable<T extends Options>
A callable for running an operation mix as an operation
|
class |
NoOpCallable<T extends Options>
A callable that does nothing
|
class |
SleepCallable<T extends Options>
A callable for sleeping
|
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
SleepOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
MixOperation.canRun(Runner<T> runner,
T options) |
<T extends Options> |
SleepOperation.createCallable(Runner<T> runner,
T options) |
<T extends Options> |
MixOperation.createCallable(Runner<T> runner,
T options) |
Modifier and Type | Class and Description |
---|---|
class |
BenchmarkOptions
Options for benchmarks
|
class |
OptionsImpl
Implementation of generic options
|
class |
SoakOptions
Options for soak testing
|
class |
StressOptions
Options for stress testing
|
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
StressOptions.copy() |
<T extends Options> |
SoakOptions.copy() |
<T extends Options> |
OptionsImpl.copy() |
<T extends Options> |
Options.copy()
Makes a copy of the options
|
<T extends Options> |
BenchmarkOptions.copy() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractParallelClient<T extends Options>
Abstract implementation of a parallel client
|
class |
AbstractParallelClientManager<T extends Options>
Abstract implementation of a parallel client manager
|
interface |
ParallelClient<T extends Options>
Interface for parallel clients
|
interface |
ParallelClientManager<T extends Options>
Interface for parallel client managers
|
class |
ParallelClientManagerTask<T extends Options>
Task for running a parallel client manager
|
class |
ParallelClientTask<T extends Options>
Task for running parallel clients
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultParallelClient<T extends Options>
Default parallel client for running multi-threaded testing
|
class |
OperationMixCallable<T extends Options>
A callable for operation mixes so we can execute them in parallel to do
multi-threaded benchmarks
|
class |
OperationMixTask<T extends Options>
An operation mix task that can be executed
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRunner<T extends Options>
Abstract implementation of a runner providing common halting and progress
reporting functionality
|
interface |
Runner<T extends Options>
Interface for test runners
|
Modifier and Type | Method and Description |
---|---|
void |
SmokeRunner.run(Options options) |
Modifier and Type | Method and Description |
---|---|
protected <T extends Options> |
SamplingOperationMixRunner.getOperationOrder(T options,
OperationMix mix) |
protected <T extends Options> |
InOrderOperationMixRunner.getOperationOrder(T options,
OperationMix mix) |
protected <T extends Options> |
DefaultOperationMixRunner.getOperationOrder(T options,
OperationMix mix) |
protected abstract <T extends Options> |
AbstractOperationMixRunner.getOperationOrder(T options,
OperationMix mix)
Gets the order in which the runner should run the operations
|
protected <T extends Options> |
InOrderOperationMixRunner.reportOperationOrder(T options)
Returns
false since there is no need to report the operation
order since it will always be the same |
protected <T extends Options> |
AbstractOperationMixRunner.reportOperationOrder(T options)
Whether the runner should report the order of operations as a progress
message
|
<T extends Options> |
OperationMixRunner.run(Runner<T> runner,
T options,
OperationMix mix)
Performs a operation mix run returning the statistics as a
OperationMixRun |
<T extends Options> |
AbstractOperationMixRunner.run(Runner<T> runner,
T options,
OperationMix mix) |
protected <T extends Options> |
AbstractOperationMixRunner.runOp(Runner<T> runner,
T options,
Operation op)
Runs an operation based on the configured
OperationRunner using
the DefaultOperationRunner if none is configured |
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
RetryingOperationRunner.run(Runner<T> runner,
T options,
Operation op) |
<T extends Options> |
OperationRunner.run(Runner<T> runner,
T options,
Operation op)
Runs the operation returning the statistics as an
OperationRun |
<T extends Options> |
DefaultOperationRunner.run(Runner<T> runner,
T options,
Operation op) |
protected <T extends Options> |
RetryingOperationRunner.shouldRetry(Runner<T> runner,
T options,
Operation op,
OperationRun run)
Decides whether the runner should continue retrying
|
Copyright © 2015. All rights reserved.