io.confluent.telemetry.collector

Class LastValueTracker<T>

java.lang.Object

io.confluent.telemetry.collector.LastValueTracker<T>

Type Parameters:

T - The type of the value.

public class LastValueTracker<T>
extends Object

A LastValueTracker uses a ConcurrentMap to maintain historic values for a given key, and return a previous value and an Instant for that value.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LastValueTracker.InstantAndValue<T>

Constructor Summary

Constructors

Constructor and Description
LastValueTracker()

Method Summary

Modifier and Type	Method and Description
boolean	contains(MetricKey metricKey)
Optional<LastValueTracker.InstantAndValue<T>>	getAndSet(MetricKey metricKey, Instant now, T value) Return the last instant/value for the given MetricKey, or Optional.empty if there isn't one.
AtomicReference<LastValueTracker.InstantAndValue<T>>	remove(MetricKey metricKey)

Methods inherited from class java.lang.Object

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

Constructor Detail

LastValueTracker

public LastValueTracker()

Method Detail

getAndSet

public Optional<LastValueTracker.InstantAndValue<T>> getAndSet(MetricKey metricKey,
                                                               Instant now,
                                                               T value)

Return the last instant/value for the given MetricKey, or Optional.empty if there isn't one.

Parameters:

metricKey - the key for which to calculate a getAndSet.

now - the timestamp for the new value.

value - the current value.

Returns:

the timestamp of the previous entry and its value. If there isn't a previous entry, then this method returns Optional.empty()

remove

public AtomicReference<LastValueTracker.InstantAndValue<T>> remove(MetricKey metricKey)

contains

public boolean contains(MetricKey metricKey)