Class PulsarAdminOpDispenser
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.PulsarAdminOpDispenser
- All Implemented Interfaces:
OpDispenser<PulsarOp>,OpResultTracker,NBComponent,NBComponentAdvisors,NBComponentEvents,NBComponentMetrics,NBComponentProps,NBComponentServices,NBComponentTimeline,NBProviderSearch,NBTokenWords,NBLabeledElement,AutoCloseable,LongFunction<PulsarOp>
- Direct Known Subclasses:
AdminNamespaceOpDispenser,AdminTenantOpDispenser,AdminTopicOpDispenser
-
Nested Class Summary
Nested classes/interfaces inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement
NBLabeledElement.BasicLabeledElement -
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final LongFunction<Boolean> protected final org.apache.pulsar.client.admin.PulsarAdminFields inherited from class io.nosqlbench.adapter.pulsar.dispensers.PulsarBaseOpDispenser
asyncApiFunc, parsedOp, pulsarAdapterMetrics, pulsarSpace, tgtNameFunc, totalCycleNum, totalThreadNumFields inherited from class io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser
EXPECTED_RESULT, spaceF, START_TIMERS, STOP_TIMERS, VERIFIER, VERIFIER_IMPORTS, VERIFIER_INIT, verifierTimerFields 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_nsFields inherited from interface io.nosqlbench.nb.api.components.core.NBComponent
EMPTY_COMPONENTFields inherited from interface io.nosqlbench.nb.api.components.core.NBComponentProps
HDRDIGITS, SUMMARYFields inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement
EMPTY -
Constructor Summary
ConstructorsConstructorDescriptionPulsarAdminOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, PulsarSpace pulsarSpace) -
Method Summary
Methods inherited from class io.nosqlbench.adapter.pulsar.dispensers.PulsarBaseOpDispenser
getConsumer, getProducer, getPulsarSpace, getReader, lookupMandtoryStrOpValueFunc, lookupOptionalStrOpValueFunc, lookupOptionalStrOpValueFunc, lookupStaticBoolConfigValueFunc, lookupStaticIntOpValueFunc, lookupStaticStrSetOpValueFuncMethods inherited from class io.nosqlbench.adapters.api.activityimpl.BaseOpDispenser
apply, getLabels, getOpName, getVerifier, onError, onStart, onSuccessMethods 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, toStringMethods inherited from class io.nosqlbench.nb.api.components.core.NBBaseComponentMetrics
addComponentMetric, addListener, findComponentMetrics, findComponentMetrics, getComponentMetric, getComponentMetrics, removeListenerMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface io.nosqlbench.nb.api.components.core.NBComponentAdvisors
getAdvisorResultsMethods inherited from interface io.nosqlbench.nb.api.components.core.NBComponentMetrics
addComponentMetric, findComponentMetrics, findComponentMetrics, findOneComponentMetric, findOneComponentMetric, getComponentMetric, getComponentMetricsMethods inherited from interface io.nosqlbench.nb.api.labels.NBLabeledElement
descriptionMethods inherited from interface io.nosqlbench.adapters.api.activityimpl.OpDispenser
getOp
-
Field Details
-
pulsarAdmin
protected final org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin -
adminDelOpFunc
-
-
Constructor Details
-
PulsarAdminOpDispenser
public PulsarAdminOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, PulsarSpace pulsarSpace)
-