Package io.debezium.metrics.stats

Class MeasurementCollector<T extends MeasurementEvent>

java.lang.Object

io.debezium.metrics.stats.MeasurementCollector<T>

All Implemented Interfaces:

Consumer<T>

public class MeasurementCollector<T extends MeasurementEvent>
extends Object
implements Consumer<T>

Single point for submitting all kind of measurements. Implementation needs to take into account that some statistics processing methods may be blocking and therefore needs to handle it in a way that prevents any contention during record processing, e.g. processing measurement events in a dedicated thread.

Author:

vjuranek

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	MeasurementCollector.MeasurementPublisher

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOGGER
private final Map<Class<T>,Measurement<T>>	measurements
private Thread	publisherThread
private final BlockingQueue<T>	queue
private static final int	QUEUE_SIZE

Constructor Summary

Constructors

Constructor	Description
MeasurementCollector()

Method Summary

Modifier and Type	Method	Description
void	accept(T measurementEvent)
void	addMeasurement(Class<T> clazz, Measurement<T> measurement)
void	reset()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

QUEUE_SIZE

private static final int QUEUE_SIZE

See Also:

• Constant Field Values

measurements

private final Map<Class<T extends MeasurementEvent>,Measurement<T extends MeasurementEvent>> measurements

queue

private final BlockingQueue<T extends MeasurementEvent> queue

publisherThread

private Thread publisherThread

Constructor Details

MeasurementCollector

public MeasurementCollector()

Method Details

accept

public void accept(T measurementEvent)

Specified by:

accept in interface Consumer<T extends MeasurementEvent>

addMeasurement

public void addMeasurement(Class<T> clazz,
 Measurement<T> measurement)

start

public void start()

stop

public void stop()

reset

public void reset()