Uses of Class
io.nosqlbench.adapter.kafka.KafkaSpace
Packages that use KafkaSpace
Package
Description
-
Uses of KafkaSpace in io.nosqlbench.adapter.kafka
Subclasses with type arguments of type KafkaSpace in io.nosqlbench.adapter.kafkaClasses in io.nosqlbench.adapter.kafka that implement interfaces with type arguments of type KafkaSpaceMethods in io.nosqlbench.adapter.kafka that return types with arguments of type KafkaSpaceMethod parameters in io.nosqlbench.adapter.kafka with type arguments of type KafkaSpaceModifier and TypeMethodDescriptionKafkaOpMapper.apply(NBComponent adapterC, ParsedOp op, LongFunction<KafkaSpace> spaceF) -
Uses of KafkaSpace in io.nosqlbench.adapter.kafka.dispensers
Subclasses with type arguments of type KafkaSpace in io.nosqlbench.adapter.kafka.dispensersFields in io.nosqlbench.adapter.kafka.dispensers declared as KafkaSpaceMethods in io.nosqlbench.adapter.kafka.dispensers that return KafkaSpaceConstructors in io.nosqlbench.adapter.kafka.dispensers with parameters of type KafkaSpaceModifierConstructorDescriptionprotectedKafkaBaseOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> topicNameStrFunc, KafkaSpace kafkaSpace) MessageConsumerOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, KafkaSpace kafkaSpace) MessageProducerOpDispenser(DriverAdapter adapter, ParsedOp op, LongFunction<String> tgtNameFunc, KafkaSpace kafkaSpace) -
Uses of KafkaSpace in io.nosqlbench.adapter.kafka.ops
Fields in io.nosqlbench.adapter.kafka.ops declared as KafkaSpaceModifier and TypeFieldDescriptionprotected final KafkaSpaceKafkaOp.kafkaSpaceprotected final KafkaSpaceOpTimeTrackKafkaClient.kafkaSpaceConstructors in io.nosqlbench.adapter.kafka.ops with parameters of type KafkaSpaceModifierConstructorDescriptionKafkaOp(KafkaAdapterMetrics kafkaAdapterMetrics, KafkaSpace kafkaSpace, OpTimeTrackKafkaClient opTimeTrackKafkaClient, Object cycleObj) OpTimeTrackKafkaClient(KafkaSpace kafkaSpace) OpTimeTrackKafkaConsumer(KafkaSpace kafkaSpace, boolean asyncMsgCommit, int msgPoolIntervalInMs, boolean autoCommitEnabled, int maxMsgCntPerCommit, org.apache.kafka.clients.consumer.KafkaConsumer<String, String> consumer, KafkaAdapterMetrics kafkaAdapterMetrics, EndToEndStartingTimeSource e2eStartingTimeSrc, Function<String, ReceivedMessageSequenceTracker> receivedMessageSequenceTrackerForTopic, boolean seqTracking) OpTimeTrackKafkaProducer(KafkaSpace kafkaSpace, boolean asyncMsgAck, boolean transactEnabledConfig, int txnBatchNum, boolean seqTracking, Set<EndToEndMetricsAdapterUtil.MSG_SEQ_ERROR_SIMU_TYPE> errSimuTypeSet, org.apache.kafka.clients.producer.KafkaProducer<String, String> producer)