Package org.apache.ignite.internal.processors.metric

Class GridMetricManager

java.lang.Object

org.apache.ignite.internal.managers.GridManagerAdapter<MetricExporterSpi>

org.apache.ignite.internal.processors.metric.GridMetricManager

All Implemented Interfaces:

Iterable<ReadOnlyMetricRegistry>, GridComponent, GridManager, ReadOnlyMetricManager

public class GridMetricManager
extends GridManagerAdapter<MetricExporterSpi>
implements ReadOnlyMetricManager

This manager should provide ReadOnlyMetricManager for each configured MetricExporterSpi.

See Also:

MetricExporterSpi, MetricRegistry

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	GridMetricManager.MemoryUsageMetrics	Memory usage metrics.

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields

Modifier and Type	Field	Description
static String	CLIENT_CONNECTOR_METRICS	Client metrics prefix.
static String	CLUSTER_METRICS	Cluster metrics prefix.
static String	CPU_LOAD	CPU load metric name.
static String	CPU_LOAD_DESCRIPTION	CPU load metric description.
static String	CUSTOM_METRICS	Custom metrics registry name.
static String	DAEMON_THREAD_CNT	Daemon thread count metric name.
static String	GC_CPU_LOAD	GC CPU load metric name.
static String	GC_CPU_LOAD_DESCRIPTION	GC CPU load metric description.
static String	HISTOGRAM_CFG_PREFIX	Prefix for HistogramMetric configuration property name.
static String	HITRATE_CFG_PREFIX	Prefix for HitRateMetric configuration property name.
static String	IGNITE_METRICS	Ignite node metrics prefix.
static String	PEAK_THREAD_CNT	Peak thread count metric name.
static String	PME_DURATION	PME duration metric name.
static String	PME_DURATION_HISTOGRAM	Histogram of PME durations metric name.
static String	PME_METRICS	Partition map exchange metrics prefix.
static String	PME_OPS_BLOCKED_DURATION	PME cache operations blocked duration metric name.
static String	PME_OPS_BLOCKED_DURATION_HISTOGRAM	Histogram of blocking PME durations metric name.
static String	REBALANCED	Whether cluster is in fully rebalanced state metric name.
static String	SYS_METRICS	System metrics prefix.
static String	THREAD_CNT	Thread count metric name.
static String	TOTAL_STARTED_THREAD_CNT	Total started thread count metric name.
static String	TX_METRICS	Transaction metrics prefix.
static String	UP_TIME	Up time metric name.

Fields inherited from class org.apache.ignite.internal.managers.GridManagerAdapter

ctx, log

Constructor Summary

Constructors

Constructor	Description
GridMetricManager(GridKernalContext ctx)

Method Summary

Modifier and Type	Method	Description
void	addMetricRegistryCreationListener(Consumer<ReadOnlyMetricRegistry> lsnr)	Adds listener of metrics registry creation events.
void	addMetricRegistryRemoveListener(Consumer<ReadOnlyMetricRegistry> lsnr)	Adds listener of metrics registry remove events.
void	configureHistogram(String name, long[] bounds)	Stores HistogramMetric configuration in metastorage.
void	configureHitRate(String name, long rateTimeInterval)	Change HitRateMetric configuration if it exists.
IgniteMetrics	custom()
<T extends Metric> T	find(String name, Class<T> type)
MemoryUsage	heapMemoryUsage()	Returns the current memory usage of the heap.
@NotNull Iterator<ReadOnlyMetricRegistry>	iterator()
MemoryUsage	nonHeapMemoryUsage()
protected void	onKernalStart0()
MetricRegistryImpl	registry(String name)	Gets or creates metric registry.
void	remove(String regName)	Removes metric registry.
void	remove(String regName, boolean removeCfg)	Removes metric registry.
void	start()	Starts grid component.
void	stop(boolean cancel)	Stops grid component.

Methods inherited from class org.apache.ignite.internal.managers.GridManagerAdapter

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, enabled, getSpi, getSpi, getSpis, inject, onAfterSpiStart, onBeforeSpiStart, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onKernalStop0, onReconnected, printMemoryStats, startInfo, startSpi, stopInfo, stopSpi, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

SYS_METRICS

public static final String SYS_METRICS

System metrics prefix.

See Also:

Constant Field Values

IGNITE_METRICS

public static final String IGNITE_METRICS

Ignite node metrics prefix.

See Also:

Constant Field Values

PME_METRICS

public static final String PME_METRICS

Partition map exchange metrics prefix.

See Also:

Constant Field Values

CLUSTER_METRICS

public static final String CLUSTER_METRICS

Cluster metrics prefix.

See Also:

Constant Field Values

CLIENT_CONNECTOR_METRICS

public static final String CLIENT_CONNECTOR_METRICS

Client metrics prefix.

TX_METRICS

public static final String TX_METRICS

Transaction metrics prefix.

See Also:

Constant Field Values

GC_CPU_LOAD

public static final String GC_CPU_LOAD

GC CPU load metric name.

See Also:

Constant Field Values

GC_CPU_LOAD_DESCRIPTION

public static final String GC_CPU_LOAD_DESCRIPTION

GC CPU load metric description.

See Also:

Constant Field Values

CPU_LOAD

public static final String CPU_LOAD

CPU load metric name.

See Also:

Constant Field Values

CPU_LOAD_DESCRIPTION

public static final String CPU_LOAD_DESCRIPTION

CPU load metric description.

See Also:

Constant Field Values

UP_TIME

public static final String UP_TIME

Up time metric name.

See Also:

Constant Field Values

THREAD_CNT

public static final String THREAD_CNT

Thread count metric name.

See Also:

Constant Field Values

PEAK_THREAD_CNT

public static final String PEAK_THREAD_CNT

Peak thread count metric name.

See Also:

Constant Field Values

TOTAL_STARTED_THREAD_CNT

public static final String TOTAL_STARTED_THREAD_CNT

Total started thread count metric name.

See Also:

Constant Field Values

DAEMON_THREAD_CNT

public static final String DAEMON_THREAD_CNT

Daemon thread count metric name.

See Also:

Constant Field Values

PME_DURATION

public static final String PME_DURATION

PME duration metric name.

See Also:

Constant Field Values

PME_OPS_BLOCKED_DURATION

public static final String PME_OPS_BLOCKED_DURATION

PME cache operations blocked duration metric name.

See Also:

Constant Field Values

PME_DURATION_HISTOGRAM

public static final String PME_DURATION_HISTOGRAM

Histogram of PME durations metric name.

See Also:

Constant Field Values

PME_OPS_BLOCKED_DURATION_HISTOGRAM

public static final String PME_OPS_BLOCKED_DURATION_HISTOGRAM

Histogram of blocking PME durations metric name.

See Also:

Constant Field Values

REBALANCED

public static final String REBALANCED

Whether cluster is in fully rebalanced state metric name.

See Also:

Constant Field Values

CUSTOM_METRICS

public static final String CUSTOM_METRICS

Custom metrics registry name.

See Also:

Constant Field Values

HITRATE_CFG_PREFIX

public static final String HITRATE_CFG_PREFIX

Prefix for HitRateMetric configuration property name.

HISTOGRAM_CFG_PREFIX

public static final String HISTOGRAM_CFG_PREFIX

Prefix for HistogramMetric configuration property name.

Constructor Detail

GridMetricManager

public GridMetricManager(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

onKernalStart0

protected void onKernalStart0()

Overrides:

onKernalStart0 in class GridManagerAdapter<MetricExporterSpi>

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Throws:

IgniteCheckedException - Throws in case of any errors.

stop

public void stop(boolean cancel)
          throws IgniteCheckedException

Stops grid component.

Specified by:

stop in interface GridComponent

Parameters:

cancel - If true, then all ongoing tasks or jobs for relevant components need to be cancelled.

Throws:

IgniteCheckedException - Thrown in case of any errors.

registry

public MetricRegistryImpl registry(String name)

Gets or creates metric registry.

Parameters:

name - Group name.

Returns:

Group of metrics.

custom

public IgniteMetrics custom()

Returns:

Custom metrics.

iterator

@NotNull
public @NotNull Iterator<ReadOnlyMetricRegistry> iterator()

Specified by:

iterator in interface Iterable<ReadOnlyMetricRegistry>

addMetricRegistryCreationListener

public void addMetricRegistryCreationListener(Consumer<ReadOnlyMetricRegistry> lsnr)

Adds listener of metrics registry creation events.

Specified by:

addMetricRegistryCreationListener in interface ReadOnlyMetricManager

Parameters:

lsnr - Listener.

addMetricRegistryRemoveListener

public void addMetricRegistryRemoveListener(Consumer<ReadOnlyMetricRegistry> lsnr)

Adds listener of metrics registry remove events.

Specified by:

addMetricRegistryRemoveListener in interface ReadOnlyMetricManager

Parameters:

lsnr - Listener.

remove

public void remove(String regName)

Removes metric registry.

Parameters:

regName - Metric registry name.

remove

public void remove(String regName,
                   boolean removeCfg)

Removes metric registry.

Parameters:

regName - Metric registry name.

removeCfg - True if remove metric configurations.

configureHitRate

public void configureHitRate(String name,
                             long rateTimeInterval)
                      throws IgniteCheckedException

Change HitRateMetric configuration if it exists.

Parameters:

name - Metric name.

rateTimeInterval - New rate time interval.

Throws:

IgniteCheckedException - If write of configuration failed.

See Also:

HitRateMetric.reset(long, int)

configureHistogram

public void configureHistogram(String name,
                               long[] bounds)
                        throws IgniteCheckedException

Stores HistogramMetric configuration in metastorage.

Parameters:

name - Metric name.

bounds - New bounds.

Throws:

IgniteCheckedException - If write of configuration failed.

find

public <T extends Metric> T find(String name,
                                 Class<T> type)

Parameters:

name - Metric name.

type - Metric type.

Returns:

Metric.

nonHeapMemoryUsage

public MemoryUsage nonHeapMemoryUsage()

Returns:

Memory usage of non-heap memory.

heapMemoryUsage

public MemoryUsage heapMemoryUsage()

Returns the current memory usage of the heap.

Returns:

Memory usage or fake value with zero in case there was exception during take of metrics.