Package cz.o2.proxima.direct.server.metrics

Class Metrics

java.lang.Object

cz.o2.proxima.direct.server.metrics.Metrics

public class Metrics
extends java.lang.Object

Metrics related to the ingest server.

Field Summary

Fields

Modifier and Type	Field	Description
static ApproxPercentileMetric	BULK_SIZE
static TimeAveragingMetric	COMMIT_LOG_APPEND
static TimeAveragingMetric	COMMIT_UPDATE_DISCARDED
static TimeAveragingMetric	DELETE_REQUESTS
static TimeAveragingMetric	DELETE_WILDCARD_REQUESTS
static TimeAveragingMetric	GET_REQUESTS
static java.lang.String	GROUP
static TimeAveragingMetric	INGEST_BULK
static ApproxPercentileMetric	INGEST_LATENCY
static TimeAveragingMetric	INGEST_SINGLE
static TimeAveragingMetric	INGESTS
static TimeAveragingMetric	INVALID_REQUEST
static TimeAveragingMetric	LIST_REQUESTS
static GaugeMetric	LIVENESS
static TimeAveragingMetric	NON_COMMIT_LOG_DELETES
static TimeAveragingMetric	NON_COMMIT_LOG_UPDATES
static TimeAveragingMetric	NON_COMMIT_WRITES_RETRIES
static TimeAveragingMetric	UPDATE_REQUESTS

Method Summary

Modifier and Type	Method	Description
static java.util.List<java.lang.String>	consumerWatermarkLags()
static Metric<java.lang.Double>	ingestsForAttribute(AttributeDescriptor<?> attr)
static Pair<java.lang.Long,java.lang.Long>	minWatermarkOfConsumers()
static void	reportConsumerWatermark(java.lang.String consumer, boolean bulk, long watermark, long elementTimestamp)
static ApproxPercentileMetric	sizeForAttribute(AttributeDescriptor<?> attr)

Methods inherited from class java.lang.Object

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

Field Detail

GROUP

public static final java.lang.String GROUP

See Also:

Constant Field Values

INGEST_SINGLE

public static final TimeAveragingMetric INGEST_SINGLE

INGEST_BULK

public static final TimeAveragingMetric INGEST_BULK

BULK_SIZE

public static final ApproxPercentileMetric BULK_SIZE

INGESTS

public static final TimeAveragingMetric INGESTS

COMMIT_LOG_APPEND

public static final TimeAveragingMetric COMMIT_LOG_APPEND

GET_REQUESTS

public static final TimeAveragingMetric GET_REQUESTS

LIST_REQUESTS

public static final TimeAveragingMetric LIST_REQUESTS

UPDATE_REQUESTS

public static final TimeAveragingMetric UPDATE_REQUESTS

DELETE_REQUESTS

public static final TimeAveragingMetric DELETE_REQUESTS

DELETE_WILDCARD_REQUESTS

public static final TimeAveragingMetric DELETE_WILDCARD_REQUESTS

NON_COMMIT_LOG_UPDATES

public static final TimeAveragingMetric NON_COMMIT_LOG_UPDATES

NON_COMMIT_LOG_DELETES

public static final TimeAveragingMetric NON_COMMIT_LOG_DELETES

COMMIT_UPDATE_DISCARDED

public static final TimeAveragingMetric COMMIT_UPDATE_DISCARDED

NON_COMMIT_WRITES_RETRIES

public static final TimeAveragingMetric NON_COMMIT_WRITES_RETRIES

INVALID_REQUEST

public static final TimeAveragingMetric INVALID_REQUEST

LIVENESS

public static final GaugeMetric LIVENESS

INGEST_LATENCY

public static final ApproxPercentileMetric INGEST_LATENCY

Method Detail

ingestsForAttribute

public static Metric<java.lang.Double> ingestsForAttribute(AttributeDescriptor<?> attr)

sizeForAttribute

public static ApproxPercentileMetric sizeForAttribute(AttributeDescriptor<?> attr)

reportConsumerWatermark

public static void reportConsumerWatermark(java.lang.String consumer,
                                           boolean bulk,
                                           long watermark,
                                           long elementTimestamp)

minWatermarkOfConsumers

public static Pair<java.lang.Long,java.lang.Long> minWatermarkOfConsumers()

consumerWatermarkLags

public static java.util.List<java.lang.String> consumerWatermarkLags()