Class PulsarOp

java.lang.Object

io.nosqlbench.adapter.pulsar.ops.PulsarOp

All Implemented Interfaces:

CycleOp<Object>, LongFunction<Object>

Direct Known Subclasses:

PulsarAdminOp, PulsarClientOp

public abstract class PulsarOp
extends Object
implements CycleOp<Object>

Field Summary

Fields

Modifier and Type	Field	Description
protected final boolean	asyncApi
protected final PulsarAdapterMetrics	pulsarAdapterMetrics

Constructor Summary

Constructors

Constructor	Description
PulsarOp(PulsarAdapterMetrics pulsarAdapterMetrics, boolean asyncApi)

Method Summary

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.nosqlbench.adapters.api.activityimpl.uniform.flowtypes.CycleOp

apply

Field Details

asyncApi

protected final boolean asyncApi

pulsarAdapterMetrics

protected final PulsarAdapterMetrics pulsarAdapterMetrics

Constructor Details

PulsarOp

public PulsarOp(PulsarAdapterMetrics pulsarAdapterMetrics,
 boolean asyncApi)