Class BaseOpDispenser<OP extends CycleOp<?>,SPACE extends Space>

java.lang.Object

io.nosqlbench.nb.api.components.core.NBBaseComponentMetrics

io.nosqlbench.nb.api.components.core.NBBaseComponent

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<OP,SPACE>

Type Parameters:

OP - The type of operation

All Implemented Interfaces:

OpDispenser<OP>, OpResultTracker, NBComponent, NBComponentAdvisors, NBComponentEvents, NBComponentMetrics, NBComponentProps, NBComponentServices, NBComponentTimeline, NBProviderSearch, NBTokenWords, NBLabeledElement, AutoCloseable, LongFunction<OP>

Direct Known Subclasses:

AmqpBaseOpDispenser, AssertingOpDispenser, AzureAISearchBaseOpDispenser, CapturingOpDispenser, Cqld4BaseOpDispenser, Cqld4GremlinOpDispenser, DataApiOpDispenser, DDBCreateTableOpDispenser, DDBDeleteTableOpDispenser, DDBGetItemOpDispenser, DDBPutItemOpDispenser, DDBQueryOpDispenser, DiagOpDispenser, DryrunOpDispenser, ExampleOpDispenserType1, ExampleOpDispenserType2, GCPSpannerBaseOpDispenser, HttpOpDispenser, KafkaBaseOpDispenser, MongoCommandOpDispenser, MongoDbUpdateOpDispenser, Neo4JBaseOpDispenser, PulsarBaseOpDispenser, QdrantBaseOpDispenser, RawDynamoDBOpDispenser, ResultPrintingOpDispenser, S4JBaseOpDispenser, StdoutOpDispenser, TcpClientOpDispenser, TcpServerOpDispenser, WeaviateBaseOpDispenser

public abstract class BaseOpDispenser<OP extends CycleOp<?>,SPACE extends Space>
extends NBBaseComponent
implements OpDispenser<OP>

See OpDispenser for details on how to use this type.

Some details are tracked per op template, which aligns to the life-cycle of the op dispenser. Thus, each op dispenser is where the stats for all related operations are kept.

Nested Class Summary

Nested classes/interfaces inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

NBLabeledElement.BasicLabeledElement

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXPECTED_RESULT
protected static final org.apache.logging.log4j.Logger	logger
protected LongFunction<? extends SPACE>	spaceF
static final String	START_TIMERS
static final String	STOP_TIMERS
static final String	VERIFIER
static final String	VERIFIER_IMPORTS
static final String	VERIFIER_INIT
final com.codahale.metrics.Timer	verifierTimer

Fields inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponent

bufferOrphanedMetrics, closed_ns, error, errored_ns, metricsBuffer, parent, started_epoch_ms, started_ns, state, teardown_ns

Fields inherited from interface io.nosqlbench.nb.api.components.core.NBComponent

EMPTY_COMPONENT

Fields inherited from interface io.nosqlbench.nb.api.components.core.NBComponentProps

HDRDIGITS, SUMMARY

Fields inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

EMPTY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseOpDispenser(NBComponent parentC, ParsedOp op, LongFunction<? extends SPACE> spaceF)

Method Summary

Modifier and Type	Method	Description
final OP	apply(long value)
NBLabels	getLabels()
String	getOpName()
CycleFunction<Boolean>	getVerifier()
void	onError(long cycleValue, long resultNanos, Throwable t)
void	onStart(long cycleValue)
void	onSuccess(long cycleValue, long nanoTime)

Methods inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponent

addAdvisor, addMetricsCloseable, attachChild, beforeDetach, close, create, detachChild, find, findParentService, getAdvisors, getChildren, getComponentOnlyLabels, getComponentProp, getComponentState, getNanosSinceStart, getParent, getTokens, nanosof_close, nanosof_error, nanosof_start, nanosof_teardown, onError, onEvent, reportExecutionMetric, setComponentProp, started_epoch_ms, teardown, toString

Methods inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponentMetrics

addComponentMetric, addListener, findComponentMetrics, findComponentMetrics, getComponentMetric, getComponentMetrics, removeListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.nosqlbench.nb.api.components.core.NBComponentAdvisors

getAdvisorResults

Methods inherited from interface io.nosqlbench.nb.api.components.core.NBComponentMetrics

addComponentMetric, findComponentMetrics, findComponentMetrics, findOneComponentMetric, findOneComponentMetric, getComponentMetric, getComponentMetrics

Methods inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement

description

Methods inherited from interface io.nosqlbench.adapters.api.activityimpl.OpDispenser

getOp

Field Details

logger

protected static final org.apache.logging.log4j.Logger logger

VERIFIER

public static final String VERIFIER

See Also:

• Constant Field Values

VERIFIER_INIT

public static final String VERIFIER_INIT

See Also:

• Constant Field Values

EXPECTED_RESULT

public static final String EXPECTED_RESULT

See Also:

• Constant Field Values

VERIFIER_IMPORTS

public static final String VERIFIER_IMPORTS

See Also:

• Constant Field Values

START_TIMERS

public static final String START_TIMERS

See Also:

• Constant Field Values

STOP_TIMERS

public static final String STOP_TIMERS

See Also:

• Constant Field Values

verifierTimer

public final com.codahale.metrics.Timer verifierTimer

spaceF

protected LongFunction<? extends SPACE extends Space> spaceF

Constructor Details

BaseOpDispenser

protected BaseOpDispenser(NBComponent parentC,
 ParsedOp op,
 LongFunction<? extends SPACE> spaceF)

Method Details

getVerifier

public CycleFunction<Boolean> getVerifier()

Specified by:

getVerifier in interface OpDispenser<OP extends CycleOp<?>>

getOpName

public String getOpName()

Specified by:

getOpName in interface OpDispenser<OP extends CycleOp<?>>

onStart

public void onStart(long cycleValue)

Specified by:

onStart in interface OpResultTracker

onSuccess

public void onSuccess(long cycleValue,
 long nanoTime)

Specified by:

onSuccess in interface OpResultTracker

onError

public void onError(long cycleValue,
 long resultNanos,
 Throwable t)

Specified by:

onError in interface OpResultTracker

getLabels

public NBLabels getLabels()

Specified by:

getLabels in interface NBLabeledElement

Overrides:

getLabels in class NBBaseComponent

apply

public final OP apply(long value)

Specified by:

apply in interface LongFunction<OP extends CycleOp<?>>