Package io.prometheus.metrics.core.metrics

Class Buffer

java.lang.Object

io.prometheus.metrics.core.metrics.Buffer

class Buffer
extends Object

Metrics support concurrent write and scrape operations.

This is implemented by switching to a Buffer when the scrape starts, and applying the values from the buffer after the scrape ends.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) ReentrantLock	appendLock
private static final long	bufferActiveBit
(package private) Condition	bufferFilled
private int	bufferPos
private double[]	observationBuffer
private boolean	reset
(package private) ReentrantLock	runLock
private final AtomicLong[]	stripedObservationCounts

Constructor Summary

Constructors

Constructor	Description
Buffer()

Method Summary

Modifier and Type	Method	Description
(package private) boolean	append(double value)
private void	doAppend(double amount)
(package private) void	reset()	Must be called by the runnable in the run() method.
(package private) <T extends DataPointSnapshot> T	run(Function<Long,Boolean> complete, Supplier<T> createResult, Consumer<Double> observeFunction)

Methods inherited from class java.lang.Object

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

Field Details

bufferActiveBit

private static final long bufferActiveBit

See Also:

• Constant Field Values

stripedObservationCounts

private final AtomicLong[] stripedObservationCounts

observationBuffer

private double[] observationBuffer

bufferPos

private int bufferPos

reset

private boolean reset

appendLock

ReentrantLock appendLock

runLock

ReentrantLock runLock

bufferFilled

Condition bufferFilled

Constructor Details

Buffer

Buffer()

Method Details

append

boolean append(double value)

doAppend

private void doAppend(double amount)

reset

void reset()

Must be called by the runnable in the run() method.

run

<T extends DataPointSnapshot> T run(Function<Long,Boolean> complete,
 Supplier<T> createResult,
 Consumer<Double> observeFunction)