Class PulsarSpace

java.lang.Object

io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace<PulsarSpace>

io.nosqlbench.adapter.pulsar.PulsarSpace

All Implemented Interfaces:

Space, NBNamedElement, AutoCloseable

public class PulsarSpace
extends BaseSpace<PulsarSpace>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	PulsarSpace.ConsumerCacheKey
static final record	PulsarSpace.ProducerCacheKey
static final record	PulsarSpace.ReaderCacheKey

Nested classes/interfaces inherited from class io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace

BaseSpace.BasicSpace

Constructor Summary

Constructors

Constructor	Description
PulsarSpace(PulsarDriverAdapter adapter, long idx, NBConfiguration cfg)

Method Summary

Modifier and Type	Method	Description
void	close()
static NBConfigModel	getConfigModel()
org.apache.pulsar.client.api.Consumer<?>	getConsumer(PulsarSpace.ConsumerCacheKey key, Supplier<org.apache.pulsar.client.api.Consumer<?>> consumerSupplier)
int	getConsumerSetCnt()
org.apache.pulsar.client.api.Producer<?>	getProducer(PulsarSpace.ProducerCacheKey key, Supplier<org.apache.pulsar.client.api.Producer<?>> producerSupplier)
int	getProducerSetCnt()
org.apache.pulsar.client.admin.PulsarAdmin	getPulsarAdmin()
org.apache.pulsar.client.api.PulsarClient	getPulsarClient()
PulsarClientConf	getPulsarNBClientConf()
org.apache.pulsar.client.api.Schema<?>	getPulsarSchema()
String	getPulsarSvcUrl()
org.apache.pulsar.client.api.Reader<?>	getReader(PulsarSpace.ReaderCacheKey key, Supplier<org.apache.pulsar.client.api.Reader<?>> readerSupplier)
int	getReaderSetCnt()
String	getWebSvcUrl()
void	shutdownSpace()

Methods inherited from class io.nosqlbench.adapters.api.activityimpl.uniform.BaseSpace

getName

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarSpace

public PulsarSpace(PulsarDriverAdapter adapter,
 long idx,
 NBConfiguration cfg)

Method Details

getConfigModel

public static NBConfigModel getConfigModel()

getPulsarSvcUrl

public String getPulsarSvcUrl()

getWebSvcUrl

public String getWebSvcUrl()

getPulsarNBClientConf

public PulsarClientConf getPulsarNBClientConf()

getPulsarClient

public org.apache.pulsar.client.api.PulsarClient getPulsarClient()

getPulsarAdmin

public org.apache.pulsar.client.admin.PulsarAdmin getPulsarAdmin()

getPulsarSchema

public org.apache.pulsar.client.api.Schema<?> getPulsarSchema()

getProducerSetCnt

public int getProducerSetCnt()

getConsumerSetCnt

public int getConsumerSetCnt()

getReaderSetCnt

public int getReaderSetCnt()

getProducer

public org.apache.pulsar.client.api.Producer<?> getProducer(PulsarSpace.ProducerCacheKey key,
 Supplier<org.apache.pulsar.client.api.Producer<?>> producerSupplier)

getConsumer

public org.apache.pulsar.client.api.Consumer<?> getConsumer(PulsarSpace.ConsumerCacheKey key,
 Supplier<org.apache.pulsar.client.api.Consumer<?>> consumerSupplier)

getReader

public org.apache.pulsar.client.api.Reader<?> getReader(PulsarSpace.ReaderCacheKey key,
 Supplier<org.apache.pulsar.client.api.Reader<?>> readerSupplier)

shutdownSpace

public void shutdownSpace()

close

public void close()