com.mesosphere.sdk.scheduler

Class Metrics

java.lang.Object

com.mesosphere.sdk.scheduler.Metrics

public class Metrics
extends java.lang.Object

This class encapsulates the components necessary for tracking Scheduler metrics.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Metrics.OperationsCounter This class records counter metrics for all Mesos Operations performed by the scheduler.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static java.lang.String	DECLINE_LONG
(package private) static java.lang.String	DECLINE_SHORT
(package private) static java.lang.String	PROCESS_OFFERS
(package private) static java.lang.String	PROCESSED_OFFERS
(package private) static java.lang.String	RECEIVED_OFFERS
(package private) static java.lang.String	REVIVE_THROTTLES
(package private) static java.lang.String	REVIVES

Constructor Summary

Constructors

Constructor and Description
Metrics()

Method Summary

Modifier and Type	Method and Description
static void	configureMetricsEndpoints(ServletContextHandler context, java.lang.String codahaleMetricsEndpoint, java.lang.String prometheusEndpoint) Appends endpoint servlets to the provided context which will serve codahale-style and prometheus-style metrics.
static void	configureStatsd(SchedulerConfig schedulerConfig) Configures the metrics service to emit StatsD-formatted metrics to the configured UDP host/port with the specified interval.
static Timer.Context	getProcessOffersDurationTimer() Returns a timer context which may be used to measure the time spent processing offers.
static MetricRegistry	getRegistry()
static void	incrementDeclinesLong(long amount)
static void	incrementDeclinesShort(long amount)
static void	incrementProcessedOffers(long amount)
static void	incrementReceivedOffers(long amount)
static void	incrementRevives()
static void	incrementReviveThrottles()
static void	record(Protos.TaskStatus taskStatus) Records the provided taskStatus received from Mesos.

Methods inherited from class java.lang.Object

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

Field Detail

RECEIVED_OFFERS

static final java.lang.String RECEIVED_OFFERS

See Also:

Constant Field Values

PROCESSED_OFFERS

static final java.lang.String PROCESSED_OFFERS

See Also:

Constant Field Values

PROCESS_OFFERS

static final java.lang.String PROCESS_OFFERS

See Also:

Constant Field Values

REVIVES

static final java.lang.String REVIVES

See Also:

Constant Field Values

REVIVE_THROTTLES

static final java.lang.String REVIVE_THROTTLES

See Also:

Constant Field Values

DECLINE_SHORT

static final java.lang.String DECLINE_SHORT

See Also:

Constant Field Values

DECLINE_LONG

static final java.lang.String DECLINE_LONG

See Also:

Constant Field Values

Constructor Detail

Metrics

public Metrics()

Method Detail

getRegistry

public static MetricRegistry getRegistry()

configureStatsd

public static void configureStatsd(SchedulerConfig schedulerConfig)

Configures the metrics service to emit StatsD-formatted metrics to the configured UDP host/port with the specified interval.

configureMetricsEndpoints

public static void configureMetricsEndpoints(ServletContextHandler context,
                                             java.lang.String codahaleMetricsEndpoint,
                                             java.lang.String prometheusEndpoint)

Appends endpoint servlets to the provided context which will serve codahale-style and prometheus-style metrics.

incrementReceivedOffers

public static void incrementReceivedOffers(long amount)

incrementProcessedOffers

public static void incrementProcessedOffers(long amount)

getProcessOffersDurationTimer

public static Timer.Context getProcessOffersDurationTimer()

Returns a timer context which may be used to measure the time spent processing offers. The returned timer must be terminated by invoking Timer.Context#stop().

incrementRevives

public static void incrementRevives()

incrementReviveThrottles

public static void incrementReviveThrottles()

incrementDeclinesShort

public static void incrementDeclinesShort(long amount)

incrementDeclinesLong

public static void incrementDeclinesLong(long amount)

record

public static void record(Protos.TaskStatus taskStatus)

Records the provided taskStatus received from Mesos.