com.rabbitmq.perf.metrics

Class CsvMetricsFormatter

java.lang.Object

com.rabbitmq.perf.metrics.CsvMetricsFormatter

All Implemented Interfaces:

MetricsFormatter

public class CsvMetricsFormatter
extends java.lang.Object
implements MetricsFormatter

Exports metrics to a CSV file.

Since:

2.19.0

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	confirmedEnabled
protected boolean	publishedEnabled
protected boolean	receivedEnabled
protected boolean	returnedEnabled

Constructor Summary

Constructors

Constructor and Description
CsvMetricsFormatter(java.io.PrintWriter out, java.lang.String testId, boolean publishedEnabled, boolean receivedEnabled, boolean returnedEnabled, boolean confirmedEnabled, java.util.concurrent.TimeUnit latencyCollectionTimeUnit)

Method Summary

Modifier and Type	Method and Description
void	header()
void	report(java.time.Duration durationSinceStart, double publishedRate, double confirmedRate, double nackedRate, double returnedRate, double receivedRate, long[] confirmedLatencyStats, long[] consumerLatencyStats)
protected boolean	shouldDisplayConfirmLatency()
protected boolean	shouldDisplayConsumerLatency()
void	summary(java.time.Duration elapsed, double ratePublished, double rateReceived, long[] consumedLatencyTotal, long[] confirmedLatencyTotal)
protected java.lang.String	summary(java.time.Duration elapsed, double ratePublished, double rateReceived, long[] consumedLatencyTotal, long[] confirmedLatencyTotal, java.lang.String testId, java.util.concurrent.TimeUnit latencyCollectionTimeUnit)

Methods inherited from class java.lang.Object

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

Field Detail

publishedEnabled

protected final boolean publishedEnabled

receivedEnabled

protected final boolean receivedEnabled

returnedEnabled

protected final boolean returnedEnabled

confirmedEnabled

protected final boolean confirmedEnabled

Constructor Detail

CsvMetricsFormatter

public CsvMetricsFormatter(java.io.PrintWriter out,
                           java.lang.String testId,
                           boolean publishedEnabled,
                           boolean receivedEnabled,
                           boolean returnedEnabled,
                           boolean confirmedEnabled,
                           java.util.concurrent.TimeUnit latencyCollectionTimeUnit)

Method Detail

header

public void header()

Specified by:

header in interface MetricsFormatter

report

public void report(java.time.Duration durationSinceStart,
                   double publishedRate,
                   double confirmedRate,
                   double nackedRate,
                   double returnedRate,
                   double receivedRate,
                   long[] confirmedLatencyStats,
                   long[] consumerLatencyStats)

Specified by:

report in interface MetricsFormatter

summary

public void summary(java.time.Duration elapsed,
                    double ratePublished,
                    double rateReceived,
                    long[] consumedLatencyTotal,
                    long[] confirmedLatencyTotal)

Specified by:

summary in interface MetricsFormatter

shouldDisplayConsumerLatency

protected boolean shouldDisplayConsumerLatency()

shouldDisplayConfirmLatency

protected boolean shouldDisplayConfirmLatency()

summary

protected java.lang.String summary(java.time.Duration elapsed,
                                   double ratePublished,
                                   double rateReceived,
                                   long[] consumedLatencyTotal,
                                   long[] confirmedLatencyTotal,
                                   java.lang.String testId,
                                   java.util.concurrent.TimeUnit latencyCollectionTimeUnit)