Package com.rabbitmq.stream.metrics

Class MicrometerMetricsCollector

java.lang.Object

com.rabbitmq.stream.metrics.MicrometerMetricsCollector

All Implemented Interfaces:

MetricsCollector

public class MicrometerMetricsCollector
extends Object
implements MetricsCollector

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.micrometer.core.instrument.DistributionSummary	chunkSize

Constructor Summary

Constructors

Constructor	Description
MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry)
MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry, String prefix)
MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry, String prefix, Iterable<io.micrometer.core.instrument.Tag> tags)
MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry, String prefix, String... tags)

Method Summary

Modifier and Type	Method	Description
void	chunk(int entriesCount)
void	closeConnection()
void	consume(long count)
protected io.micrometer.core.instrument.Counter	createChunkCounter(io.micrometer.core.instrument.MeterRegistry registry, String prefix, Iterable<io.micrometer.core.instrument.Tag> tags)
protected io.micrometer.core.instrument.DistributionSummary	createChunkSizeDistributionSummary(io.micrometer.core.instrument.MeterRegistry registry, String prefix, Iterable<io.micrometer.core.instrument.Tag> tags)
void	openConnection()
void	publish(int count)
void	publishConfirm(int count)
void	publishError(int count)
void	readBytes(int readBytes)
void	writtenBytes(int writtenBytes)

Methods inherited from class java.lang.Object

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

Field Details

chunkSize

protected final io.micrometer.core.instrument.DistributionSummary chunkSize

Constructor Details

MicrometerMetricsCollector

public MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry)

MicrometerMetricsCollector

public MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry,
 String prefix)

MicrometerMetricsCollector

public MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry,
 String prefix,
 String... tags)

MicrometerMetricsCollector

public MicrometerMetricsCollector(io.micrometer.core.instrument.MeterRegistry registry,
 String prefix,
 Iterable<io.micrometer.core.instrument.Tag> tags)

Method Details

createChunkCounter

protected io.micrometer.core.instrument.Counter createChunkCounter(io.micrometer.core.instrument.MeterRegistry registry,
 String prefix,
 Iterable<io.micrometer.core.instrument.Tag> tags)

createChunkSizeDistributionSummary

protected io.micrometer.core.instrument.DistributionSummary createChunkSizeDistributionSummary(io.micrometer.core.instrument.MeterRegistry registry,
 String prefix,
 Iterable<io.micrometer.core.instrument.Tag> tags)

openConnection

public void openConnection()

Specified by:

openConnection in interface MetricsCollector

closeConnection

public void closeConnection()

Specified by:

closeConnection in interface MetricsCollector

publish

public void publish(int count)

Specified by:

publish in interface MetricsCollector

publishConfirm

public void publishConfirm(int count)

Specified by:

publishConfirm in interface MetricsCollector

publishError

public void publishError(int count)

Specified by:

publishError in interface MetricsCollector

chunk

public void chunk(int entriesCount)

Specified by:

chunk in interface MetricsCollector

consume

public void consume(long count)

Specified by:

consume in interface MetricsCollector

writtenBytes

public void writtenBytes(int writtenBytes)

Specified by:

writtenBytes in interface MetricsCollector

readBytes

public void readBytes(int readBytes)

Specified by:

readBytes in interface MetricsCollector