services.moleculer.metrics

Class DefaultMetrics

java.lang.Object

io.micrometer.core.instrument.MeterRegistry

io.micrometer.core.instrument.composite.CompositeMeterRegistry

services.moleculer.metrics.DefaultMetrics

All Implemented Interfaces:

Metrics, MoleculerLifecycle

public class DefaultMetrics
extends io.micrometer.core.instrument.composite.CompositeMeterRegistry
implements Metrics

Nested Class Summary

Nested classes/interfaces inherited from class io.micrometer.core.instrument.MeterRegistry

io.micrometer.core.instrument.MeterRegistry.Config, io.micrometer.core.instrument.MeterRegistry.More

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.HashMap<java.lang.Class<? extends io.micrometer.core.instrument.binder.MeterBinder>,io.micrometer.core.instrument.binder.MeterBinder>	binders
protected int	distributionStatisticBufferLength
protected static org.slf4j.Logger	logger
protected int	percentilePrecision
protected double[]	percentiles
protected boolean	publishPercentileHistogram
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	readLock
protected java.util.HashMap<java.lang.String,java.lang.Object>	registry
protected DropwizardReporters	reporters
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	writeLock

Fields inherited from class io.micrometer.core.instrument.MeterRegistry

clock

Fields inherited from interface services.moleculer.metrics.Metrics

ONE_SECOND

Constructor Summary

Constructors

Constructor and Description
DefaultMetrics()
DefaultMetrics(io.micrometer.core.instrument.MeterRegistry... registries)

Method Summary

Modifier and Type	Method and Description
void	addClassLoaderMetrics()
void	addExecutorServiceMetrics(java.util.concurrent.ExecutorService executor, java.lang.String executorServiceName, java.lang.String... tags)
void	addJvmGcMetrics()
void	addJvmMemoryMetrics()
void	addJvmThreadMetrics()
void	addMetrics(io.micrometer.core.instrument.binder.MeterBinder binder)
void	addProcessorMetrics()
int	getDistributionStatisticBufferLength()
protected <T> T	getMetric(java.lang.String name, java.lang.String[] tags, java.util.function.Supplier<T> factory)
int	getPercentilePrecision()
double[]	getPercentiles()
MetricCounter	increment(java.lang.String name, java.lang.String description, double delta, java.lang.String... tags)
boolean	isPublishPercentileHistogram()
protected DropwizardReporters	reporters()
MetricGauge	set(java.lang.String name, java.lang.String description, double value, java.lang.String... tags)
void	setDistributionStatisticBufferLength(int distributionStatisticBufferLength)
void	setPercentilePrecision(int percentilePrecision)
void	setPercentiles(double[] percentiles)
void	setPublishPercentileHistogram(boolean publishPercentileHistogram)
void	startConsoleReporter() Starts ConsoleReporter.
void	startConsoleReporter(long period, java.util.concurrent.TimeUnit periodUnit) Starts ConsoleReporter.
void	startCsvReporter(long period, java.util.concurrent.TimeUnit periodUnit, java.lang.String directory) Starts CsvReporter.
void	startCsvReporter(java.lang.String directory) Starts CsvReporter.
void	started(ServiceBroker broker)
void	startSlf4jReporter() Starts Slf4jReporter.
void	startSlf4jReporter(long period, java.util.concurrent.TimeUnit periodUnit) Starts Slf4jReporter.
void	startSlf4jReporter(long period, java.util.concurrent.TimeUnit periodUnit, java.lang.String loggerName) Starts Slf4jReporter.
void	stopped()
StoppableTimer	timer(java.lang.String name, java.lang.String description, java.time.Duration duration, java.lang.String... tags)

Methods inherited from class io.micrometer.core.instrument.composite.CompositeMeterRegistry

add, close, defaultHistogramConfig, getBaseTimeUnit, getRegistries, newCounter, newDistributionSummary, newFunctionCounter, newFunctionTimer, newGauge, newLongTaskTimer, newMeter, newTimeGauge, newTimer, remove

Methods inherited from class io.micrometer.core.instrument.MeterRegistry

clear, config, counter, counter, find, forEachMeter, gauge, gauge, gauge, gauge, gaugeCollectionSize, gaugeMapSize, get, getConventionName, getConventionTags, getMeters, isClosed, meterRegistrationFailed, more, newLongTaskTimer, remove, remove, removeByPreFilterId, summary, summary, timer, timer

Methods inherited from class java.lang.Object

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

Methods inherited from interface services.moleculer.metrics.Metrics

increment, timer

Field Detail

logger

protected static final org.slf4j.Logger logger

registry

protected final java.util.HashMap<java.lang.String,java.lang.Object> registry

binders

protected final java.util.HashMap<java.lang.Class<? extends io.micrometer.core.instrument.binder.MeterBinder>,io.micrometer.core.instrument.binder.MeterBinder> binders

reporters

protected DropwizardReporters reporters

readLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock readLock

writeLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock writeLock

publishPercentileHistogram

protected boolean publishPercentileHistogram

percentilePrecision

protected int percentilePrecision

distributionStatisticBufferLength

protected int distributionStatisticBufferLength

percentiles

protected double[] percentiles

Constructor Detail

DefaultMetrics

public DefaultMetrics()

DefaultMetrics

public DefaultMetrics(io.micrometer.core.instrument.MeterRegistry... registries)

Method Detail

started

public void started(ServiceBroker broker)
             throws java.lang.Exception

Specified by:

started in interface MoleculerLifecycle

Throws:

java.lang.Exception

increment

public MetricCounter increment(java.lang.String name,
                               java.lang.String description,
                               double delta,
                               java.lang.String... tags)

Specified by:

increment in interface Metrics

set

public MetricGauge set(java.lang.String name,
                       java.lang.String description,
                       double value,
                       java.lang.String... tags)

Specified by:

set in interface Metrics

timer

public StoppableTimer timer(java.lang.String name,
                            java.lang.String description,
                            java.time.Duration duration,
                            java.lang.String... tags)

Specified by:

timer in interface Metrics

getMetric

protected <T> T getMetric(java.lang.String name,
                          java.lang.String[] tags,
                          java.util.function.Supplier<T> factory)

startConsoleReporter

public void startConsoleReporter()

Starts ConsoleReporter. For simple benchmarks, Metrics comes with ConsoleReporter, which periodically reports all registered metrics to the console. The period time of the sampling is ONE MINUTE.

startConsoleReporter

public void startConsoleReporter(long period,
                                 java.util.concurrent.TimeUnit periodUnit)

Starts ConsoleReporter. For simple benchmarks, Metrics comes with ConsoleReporter, which periodically reports all registered metrics to the console.

Parameters:

period - the amount of time between polls

periodUnit - the unit for period

startCsvReporter

public void startCsvReporter(java.lang.String directory)

Starts CsvReporter. For more complex benchmarks, Metrics comes with CsvReporter, which periodically appends to a set of .csv files in a given directory. The period time of the sampling is ONE SECOND.

Parameters:

directory - directory the directory in which the .csv files will be created

startCsvReporter

public void startCsvReporter(long period,
                             java.util.concurrent.TimeUnit periodUnit,
                             java.lang.String directory)

Starts CsvReporter. For more complex benchmarks, Metrics comes with CsvReporter, which periodically appends to a set of .csv files in a given directory.

Parameters:

period - the amount of time between polls

periodUnit - the unit for period

directory - directory the directory in which the .csv files will be created

startSlf4jReporter

public void startSlf4jReporter()

Starts Slf4jReporter. A reporter class for logging metrics values to a SLF4J Logge} periodically, similar to ConsoleReporter or CsvReporter, but using the SLF4J framework instead. The period time of the sampling is ONE MINUTE.

startSlf4jReporter

public void startSlf4jReporter(long period,
                               java.util.concurrent.TimeUnit periodUnit)

Starts Slf4jReporter. A reporter class for logging metrics values to a SLF4J Logge} periodically, similar to ConsoleReporter or CsvReporter, but using the SLF4J framework instead.

Parameters:

period - the amount of time between polls

periodUnit - the unit for period

startSlf4jReporter

public void startSlf4jReporter(long period,
                               java.util.concurrent.TimeUnit periodUnit,
                               java.lang.String loggerName)

Starts Slf4jReporter. A reporter class for logging metrics values to a SLF4J Logge} periodically, similar to ConsoleReporter or CsvReporter, but using the SLF4J framework instead.

Parameters:

period - the amount of time between polls

periodUnit - the unit for period

loggerName - name of the logger (eg. "moleculer.metrics" or null)

reporters

protected DropwizardReporters reporters()

addClassLoaderMetrics

public void addClassLoaderMetrics()

addJvmMemoryMetrics

public void addJvmMemoryMetrics()

addJvmGcMetrics

public void addJvmGcMetrics()

addProcessorMetrics

public void addProcessorMetrics()

addJvmThreadMetrics

public void addJvmThreadMetrics()

addExecutorServiceMetrics

public void addExecutorServiceMetrics(java.util.concurrent.ExecutorService executor,
                                      java.lang.String executorServiceName,
                                      java.lang.String... tags)

addMetrics

public void addMetrics(io.micrometer.core.instrument.binder.MeterBinder binder)

stopped

public void stopped()

Specified by:

stopped in interface MoleculerLifecycle

isPublishPercentileHistogram

public boolean isPublishPercentileHistogram()

setPublishPercentileHistogram

public void setPublishPercentileHistogram(boolean publishPercentileHistogram)

getPercentilePrecision

public int getPercentilePrecision()

setPercentilePrecision

public void setPercentilePrecision(int percentilePrecision)

getDistributionStatisticBufferLength

public int getDistributionStatisticBufferLength()

setDistributionStatisticBufferLength

public void setDistributionStatisticBufferLength(int distributionStatisticBufferLength)

getPercentiles

public double[] getPercentiles()

setPercentiles

public void setPercentiles(double[] percentiles)