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 | Method and Description |
---|---|
protected Runner<T> |
AbstractOperationCallable.getRunner()
Gets the runner
|
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
|
Constructor and Description |
---|
AbstractOperationCallable(Runner<T> runner,
T options)
Creates a new operation callable
|
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) |
Constructor and Description |
---|
AbstractGSPCallable(Runner<T> runner,
T options)
Creates a new callable
|
AbstractGSPCallable(Runner<T> runner,
T options,
String uri)
Creates a new callable
|
GSPDeleteCallable(Runner<T> runner,
T options)
Creates a new callable that operates on the default graph
|
GSPDeleteCallable(Runner<T> runner,
T options,
String uri)
Creates a new callable that operates on a specific graph
|
GSPGetCallable(Runner<T> runner,
T options)
Creates a new callable
|
GSPGetCallable(Runner<T> runner,
T options,
String uri)
Creates a new callable
|
GSPHeadCallable(Runner<T> runner,
T options)
Creates a new callable that operates on the default graph
|
GSPHeadCallable(Runner<T> runner,
T options,
String uri)
Creates a new callable that operates on a specific graph
|
GSPPostCallable(Runner<T> runner,
T options,
Model data)
Creates a new callable that operates on the default graph
|
GSPPostCallable(Runner<T> runner,
T options,
Model data,
String uri)
Creates a new callable that operates on a specific graph
|
GSPPutCallable(Runner<T> runner,
T options,
Model data)
Creates a new callable that operates on the default graph
|
GSPPutCallable(Runner<T> runner,
T options,
Model data,
String uri)
Creates a new callable that operates on a specific graph
|
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) |
Constructor and Description |
---|
AbstractInMemoryQueryCallable(Runner<T> runner,
T options)
Creates a new callable
|
AbstractQueryCallable(Runner<T> runner,
T options)
Creates a new callable
|
AbstractRemoteQueryCallable(Runner<T> runner,
T options)
Creates a new callable
|
AbstractScalarValueCallable(Runner<T> runner,
T options,
TCallable callable,
String var)
Creates a new scalar value callable
|
InMemoryQueryCallable(Query q,
Runner<T> runner,
T options)
Creates a new Query Runner
|
LongValueCallable(Runner<T> runner,
T options,
TCallable callable,
String var)
Creates a new callable
|
RemoteQueryCallable(Query q,
Runner<T> runner,
T options)
Creates a new Query Runner
|
WrapperQueryCallable(Runner<T> runner,
T options,
TCallable callable)
Creates a new decorator
|
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
FixedNvpQueryOperation.createCallable(Runner<T> runner,
T options) |
Constructor and Description |
---|
NvpQueryCallable(Query q,
Runner<T> runner,
T options,
Map<String,List<String>> nvps)
Creates a new callable
|
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) |
Constructor and Description |
---|
AbstractInMemoryUpdateCallable(Runner<T> runner,
T options)
Creates a new callable
|
AbstractRemoteUpdateCallable(Runner<T> runner,
T options)
Creates a new callable
|
AbstractUpdateCallable(Runner<T> runner,
T options)
Creates a new callable
|
InMemoryUpdateCallable(UpdateRequest update,
Runner<T> runner,
T options)
Creates a new update runner
|
RemoteUpdateCallable(UpdateRequest update,
Runner<T> runner,
T options)
Creates a new update runner
|
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
FixedNvpUpdateOperation.createCallable(Runner<T> runner,
T options) |
Constructor and Description |
---|
NvpUpdateCallable(UpdateRequest update,
Runner<T> runner,
T options,
Map<String,List<String>> nvps)
Creates a new callable
|
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) |
Constructor and Description |
---|
MixOperationCallable(Runner<T> runner,
T options,
OperationMix mix,
boolean randomOrder)
Creates a new callable
|
NoOpCallable(Runner<T> runner,
T options,
OperationRun runInfo)
Creates a new callable
|
SleepCallable(long sleep,
Runner<T> runner,
T options)
Creates a new sleep callable
|
Modifier and Type | Method and Description |
---|---|
Runner<T> |
ParallelClientManager.getRunner()
Gets the runner
|
Runner<T> |
AbstractParallelClientManager.getRunner() |
Constructor and Description |
---|
AbstractParallelClientManager(Runner<T> runner,
T options)
Creates a new parallel client manager
|
Modifier and Type | Method and Description |
---|---|
Runner<StressOptions> |
StressTestParallelClientManager.getRunner() |
Constructor and Description |
---|
BenchmarkParallelClientManager(Runner<T> runner,
T options)
Creates a new Parallel Client Manager
|
OperationMixCallable(Runner<T> runner,
T options)
Creates a new operation mix runner
|
OperationMixTask(Runner<T> runner,
T options)
Creates a new Task
|
SoakTestParallelClientManager(Runner<SoakOptions> runner,
SoakOptions options)
Creates a new Parallel Client Manager
|
StressTestParallelClientManager(Runner<StressOptions> runner,
StressOptions options)
Creates a new Parallel Client Manager
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRunner<T extends Options>
Abstract implementation of a runner providing common halting and progress
reporting functionality
|
class |
BenchmarkRunner
A benchmark runner
|
class |
SmokeRunner
A smoke test runner
|
class |
SoakRunner
A soak test runner
|
class |
StressRunner
A stress test runner
|
Modifier and Type | Method and Description |
---|---|
<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.