Class PulsarClientOpDispenser

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

io.nosqlbench.adapter.pulsar.dispensers.PulsarClientOpDispenser

All Implemented Interfaces:

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

Direct Known Subclasses:

MessageConsumerOpDispenser, MessageProducerOpDispenser, MessageReaderOpDispenser

public abstract class PulsarClientOpDispenser
extends PulsarBaseOpDispenser

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<Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE>>	msgSeqErrSimuTypeSetFunc
protected final LongFunction<String>	payloadRttFieldFunc
protected final org.apache.pulsar.client.api.PulsarClient	pulsarClient
protected final org.apache.pulsar.client.api.Schema<?>	pulsarSchema
protected final LongFunction<Boolean>	seqTrackingFunc
protected final LongFunction<Supplier<org.apache.pulsar.client.api.transaction.Transaction>>	transactSupplierFunc
protected final LongFunction<Boolean>	useTransactFunc

Fields inherited from class io.nosqlbench.adapter.pulsar.dispensers.PulsarBaseOpDispenser

asyncApiFunc, parsedOp, pulsarAdapterMetrics, pulsarSpace, tgtNameFunc, totalCycleNum, 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	PulsarClientOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, PulsarSpace pulsarSpace)

Method Summary

Modifier and Type	Method	Description
protected LongFunction<Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE>>	getStaticErrSimuTypeSetOpValueFunc()
protected Supplier<org.apache.pulsar.client.api.transaction.Transaction>	getTransactionSupplier()

Methods inherited from class io.nosqlbench.adapter.pulsar.dispensers.PulsarBaseOpDispenser

getConsumer, getProducer, getPulsarSpace, getReader, lookupMandtoryStrOpValueFunc, lookupOptionalStrOpValueFunc, lookupOptionalStrOpValueFunc, lookupStaticBoolConfigValueFunc, lookupStaticIntOpValueFunc, lookupStaticStrSetOpValueFunc

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

pulsarClient

protected final org.apache.pulsar.client.api.PulsarClient pulsarClient

pulsarSchema

protected final org.apache.pulsar.client.api.Schema<?> pulsarSchema

useTransactFunc

protected final LongFunction<Boolean> useTransactFunc

seqTrackingFunc

protected final LongFunction<Boolean> seqTrackingFunc

payloadRttFieldFunc

protected final LongFunction<String> payloadRttFieldFunc

transactSupplierFunc

protected final LongFunction<Supplier<org.apache.pulsar.client.api.transaction.Transaction>> transactSupplierFunc

msgSeqErrSimuTypeSetFunc

protected final LongFunction<Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE>> msgSeqErrSimuTypeSetFunc

Constructor Details

PulsarClientOpDispenser

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

Method Details

getTransactionSupplier

protected Supplier<org.apache.pulsar.client.api.transaction.Transaction> getTransactionSupplier()

getStaticErrSimuTypeSetOpValueFunc

protected LongFunction<Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE>> getStaticErrSimuTypeSetOpValueFunc()