Class PulsarBaseOpDispenser

java.lang.Object

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

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

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<PulsarOp,PulsarSpace>

io.nosqlbench.adapter.pulsar.dispensers.PulsarBaseOpDispenser

All Implemented Interfaces:

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

Direct Known Subclasses:

PulsarAdminOpDispenser, PulsarClientOpDispenser

public abstract class PulsarBaseOpDispenser
extends BaseOpDispenser<PulsarOp,PulsarSpace>

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
protected final LongFunction<Boolean>	asyncApiFunc
protected final ParsedOp	parsedOp
protected final PulsarAdapterMetrics	pulsarAdapterMetrics
protected final PulsarSpace	pulsarSpace
protected final LongFunction<String>	tgtNameFunc
protected final long	totalCycleNum
protected final int	totalThreadNum

Fields inherited from class io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser

EXPECTED_RESULT, spaceF, START_TIMERS, STOP_TIMERS, VERIFIER, VERIFIER_IMPORTS, VERIFIER_INIT, 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	PulsarBaseOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, PulsarSpace pulsarSpace)

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.client.api.Consumer<?>	getConsumer(String cycleTopicNameListStr, String cycleTopicPatternStr, String cycleSubscriptionName, String cycleSubscriptionType, String cycleConsumerName, String cycleKeySharedSubscriptionRanges)
org.apache.pulsar.client.api.Producer<?>	getProducer(String cycleTopicName, String cycleProducerName)
PulsarSpace	getPulsarSpace()
org.apache.pulsar.client.api.Reader<?>	getReader(String cycleTopicName, String cycleReaderName, String cycleStartMsgPos)
protected LongFunction<String>	lookupMandtoryStrOpValueFunc(String paramName)
protected LongFunction<String>	lookupOptionalStrOpValueFunc(String paramName)
protected LongFunction<String>	lookupOptionalStrOpValueFunc(String paramName, String defaultValue)
protected LongFunction<Boolean>	lookupStaticBoolConfigValueFunc(String paramName, boolean defaultValue)
protected LongFunction<Integer>	lookupStaticIntOpValueFunc(String paramName, int defaultValue)
protected LongFunction<Set<String>>	lookupStaticStrSetOpValueFunc(String paramName)

Methods inherited from class io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser

apply, getLabels, getOpName, getVerifier, onError, onStart, onSuccess

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

parsedOp

protected final ParsedOp parsedOp

pulsarSpace

protected final PulsarSpace pulsarSpace

pulsarAdapterMetrics

protected final PulsarAdapterMetrics pulsarAdapterMetrics

asyncApiFunc

protected final LongFunction<Boolean> asyncApiFunc

tgtNameFunc

protected final LongFunction<String> tgtNameFunc

totalThreadNum

protected final int totalThreadNum

totalCycleNum

protected final long totalCycleNum

Constructor Details

PulsarBaseOpDispenser

protected PulsarBaseOpDispenser(DriverAdapter adapter,
 ParsedOp op,
 LongFunction<String> tgtNameFunc,
 PulsarSpace pulsarSpace)

Method Details

getPulsarSpace

public PulsarSpace getPulsarSpace()

lookupStaticBoolConfigValueFunc

protected LongFunction<Boolean> lookupStaticBoolConfigValueFunc(String paramName,
 boolean defaultValue)

lookupStaticStrSetOpValueFunc

protected LongFunction<Set<String>> lookupStaticStrSetOpValueFunc(String paramName)

lookupStaticIntOpValueFunc

protected LongFunction<Integer> lookupStaticIntOpValueFunc(String paramName,
 int defaultValue)

lookupOptionalStrOpValueFunc

protected LongFunction<String> lookupOptionalStrOpValueFunc(String paramName,
 String defaultValue)

lookupOptionalStrOpValueFunc

protected LongFunction<String> lookupOptionalStrOpValueFunc(String paramName)

lookupMandtoryStrOpValueFunc

protected LongFunction<String> lookupMandtoryStrOpValueFunc(String paramName)

getProducer

public org.apache.pulsar.client.api.Producer<?> getProducer(String cycleTopicName,
 String cycleProducerName)

getConsumer

public org.apache.pulsar.client.api.Consumer<?> getConsumer(String cycleTopicNameListStr,
 String cycleTopicPatternStr,
 String cycleSubscriptionName,
 String cycleSubscriptionType,
 String cycleConsumerName,
 String cycleKeySharedSubscriptionRanges)

getReader

public org.apache.pulsar.client.api.Reader<?> getReader(String cycleTopicName,
 String cycleReaderName,
 String cycleStartMsgPos)