Class MessageProducerOpDispenser

java.lang.Object

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

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

io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser<KafkaOp,KafkaSpace>

io.nosqlbench.adapter.kafka.dispensers.KafkaBaseOpDispenser

io.nosqlbench.adapter.kafka.dispensers.MessageProducerOpDispenser

All Implemented Interfaces:

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

public class MessageProducerOpDispenser
extends KafkaBaseOpDispenser

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	MSG_BODY_OP_PARAM
static final String	MSG_HEADER_OP_PARAM
static final String	MSG_KEY_OP_PARAM
protected final LongFunction<Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE>>	msgSeqErrSimuTypeSetFunc
protected final LongFunction<Boolean>	seqTrackingFunc
protected final int	txnBatchNum

Fields inherited from class io.nosqlbench.adapter.kafka.dispensers.KafkaBaseOpDispenser

asyncAPI, consumerGrpCnt, kafkaAdapterMetrics, kafkaClntCnt, kafkaSpace, parsedOp, topicConfMap, topicNameStrFunc, 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

Constructor	Description
MessageProducerOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, KafkaSpace kafkaSpace)

Method Summary

Modifier and Type	Method	Description
KafkaOp	getOp(long cycle)	This method should do all the work of creating an operation that is executable by some other caller.
OpTimeTrackKafkaProducer	getOpTimeTrackKafkaProducer(long cycle, String topicName, String clientId)
protected LongFunction<Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE>>	getStaticErrSimuTypeSetOpValueFunc()

Methods inherited from class io.nosqlbench.adapter.kafka.dispensers.KafkaBaseOpDispenser

getKafkaAdapterMetrics, getKafkaSpace, getName, lookupMandtoryStrOpValueFunc, lookupOptionalStrOpValueFunc, lookupOptionalStrOpValueFunc, lookupStaticBoolConfigValueFunc

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

Field Details

MSG_HEADER_OP_PARAM

public static final String MSG_HEADER_OP_PARAM

See Also:

• Constant Field Values

MSG_KEY_OP_PARAM

public static final String MSG_KEY_OP_PARAM

See Also:

• Constant Field Values

MSG_BODY_OP_PARAM

public static final String MSG_BODY_OP_PARAM

See Also:

• Constant Field Values

txnBatchNum

protected final int txnBatchNum

seqTrackingFunc

protected final LongFunction<Boolean> seqTrackingFunc

msgSeqErrSimuTypeSetFunc

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

Constructor Details

MessageProducerOpDispenser

public MessageProducerOpDispenser(DriverAdapter adapter,
 ParsedOp op,
 LongFunction<String> tgtNameFunc,
 KafkaSpace kafkaSpace)

Method Details

getOpTimeTrackKafkaProducer

public OpTimeTrackKafkaProducer getOpTimeTrackKafkaProducer(long cycle,
 String topicName,
 String clientId)

getOp

public KafkaOp getOp(long cycle)

Description copied from interface: OpDispenser

This method should do all the work of creating an operation that is executable by some other caller. The value produced by the apply method should not require additional processing if a caller wants to execute the operation multiple times, as for retries.

Parameters:

cycle - The cycle number which serves as the seed for any generated op fields to be bound into an operation.

Returns:

an executable operation

getStaticErrSimuTypeSetOpValueFunc

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