| Package | Description |
|---|---|
| com.rabbitmq.perf | |
| com.rabbitmq.perf.metrics |
| Modifier and Type | Method and Description |
|---|---|
PerformanceMetrics |
ConsumerParameters.getPerformanceMetrics() |
PerformanceMetrics |
ProducerParameters.getPerformanceMetrics() |
| Modifier and Type | Method and Description |
|---|---|
Consumer |
MulticastParams.createConsumer(com.rabbitmq.client.Connection connection,
PerformanceMetrics performanceMetrics,
com.rabbitmq.perf.ValueIndicator<java.lang.Long> consumerLatenciesIndicator,
MulticastSet.CompletionHandler completionHandler,
java.util.concurrent.ExecutorService executorService,
java.util.concurrent.ScheduledExecutorService topologyRecordingScheduledExecutorService) |
Producer |
MulticastParams.createProducer(com.rabbitmq.client.Connection connection,
PerformanceMetrics performanceMetrics,
MulticastSet.CompletionHandler completionHandler,
com.rabbitmq.perf.ValueIndicator<java.lang.Float> rateIndicator,
com.rabbitmq.perf.ValueIndicator<java.lang.Integer> messageSizeIndicator) |
ConsumerParameters |
ConsumerParameters.setPerformanceMetrics(PerformanceMetrics performanceMetrics) |
ProducerParameters |
ProducerParameters.setPerformanceMetrics(PerformanceMetrics performanceMetrics) |
| Constructor and Description |
|---|
MulticastSet(PerformanceMetrics performanceMetrics,
com.rabbitmq.client.ConnectionFactory factory,
MulticastParams params,
java.util.List<java.lang.String> uris,
MulticastSet.CompletionHandler completionHandler) |
MulticastSet(PerformanceMetrics performanceMetrics,
com.rabbitmq.client.ConnectionFactory factory,
MulticastParams params,
java.lang.String testID,
java.util.List<java.lang.String> uris,
MulticastSet.CompletionHandler completionHandler) |
MulticastSet(PerformanceMetrics performanceMetrics,
com.rabbitmq.client.ConnectionFactory factory,
MulticastParams params,
java.lang.String testID,
java.util.List<java.lang.String> uris,
MulticastSet.CompletionHandler completionHandler,
ShutdownService shutdownService,
com.rabbitmq.perf.ExpectedMetrics expectedMetrics) |
Stats(java.time.Duration interval,
boolean useMs,
io.micrometer.core.instrument.MeterRegistry registry,
java.lang.String metricsPrefix,
PerformanceMetrics performanceMetrics) |
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultPerformanceMetrics
Implementation that collects metrics with concurrent utilities.
|
| Modifier and Type | Field and Description |
|---|---|
static PerformanceMetrics |
PerformanceMetrics.NO_OP |
Copyright © 2022 Pivotal Software, Inc.. All rights reserved.