org.gridgain.grid.spi.discovery.tcp.metricsstore.sharedfs

Class GridTcpDiscoverySharedFsMetricsStore

java.lang.Object

org.gridgain.grid.spi.discovery.tcp.metricsstore.GridTcpDiscoveryMetricsStoreAdapter

org.gridgain.grid.spi.discovery.tcp.metricsstore.sharedfs.GridTcpDiscoverySharedFsMetricsStore

All Implemented Interfaces:

GridTcpDiscoveryMetricsStore

public class GridTcpDiscoverySharedFsMetricsStore
extends GridTcpDiscoveryMetricsStoreAdapter

Shared filesystem-based metrics store.

Configuration

Mandatory

There are no mandatory configuration parameters.

Optional

• Path (see setPath(String)).
• Metrics expire time (see GridTcpDiscoveryMetricsStoreAdapter.setMetricsExpireTime(int)).

If getPath() is not provided, then DFLT_PATH will be used and only local nodes will discover each other. To enable metrics store working over network you must provide a path to a shared directory explicitly.

The directory will contain files with serialized metrics named like the following 94816A59-EB51-44EE-BB67-8B24B9C10A09.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DFLT_PATH Default path for local testing only.

Fields inherited from class org.gridgain.grid.spi.discovery.tcp.metricsstore.GridTcpDiscoveryMetricsStoreAdapter

DFLT_METRICS_EXPIRE_TIME

Constructor Summary

Constructors

Constructor and Description
GridTcpDiscoverySharedFsMetricsStore()

Method Summary

Methods

Modifier and Type	Method and Description
Collection<UUID>	allNodeIds() Gets all node IDs currently contained in the store.
String	getPath() Gets path.
protected Map<UUID,GridNodeMetrics>	metrics0(Collection<UUID> nodeIds) Requests metrics from store in case local cached metrics are outdated.
void	removeMetrics0(Collection<UUID> nodeIds) Removes metrics from store.
void	setPath(String path) Sets path.
String	toString()
void	updateLocalMetrics(UUID locNodeId, GridNodeMetrics metrics) Updates local node metrics in the store.

Methods inherited from class org.gridgain.grid.spi.discovery.tcp.metricsstore.GridTcpDiscoveryMetricsStoreAdapter

getMetricsExpireTime, metrics, onSpiContextDestroyed, onSpiContextInitialized, removeMetrics, setMetricsExpireTime, spiContext

Methods inherited from class java.lang.Object

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

Field Detail

DFLT_PATH

public static final String DFLT_PATH

Default path for local testing only.

See Also:

Constant Field Values

Constructor Detail

GridTcpDiscoverySharedFsMetricsStore

public GridTcpDiscoverySharedFsMetricsStore()

Method Detail

getPath

public String getPath()

Gets path.

Returns:

Shared path.

setPath

@GridSpiConfiguration(optional=true)
public void setPath(String path)

Sets path.

Parameters:

path - Shared path.

updateLocalMetrics

public void updateLocalMetrics(UUID locNodeId,
                      GridNodeMetrics metrics)
                        throws GridSpiException

Updates local node metrics in the store.

Parameters:

locNodeId - Id of the local node (caller node).

metrics - Local node metrics.

Throws:

GridSpiException - If an error occurs.

metrics0

protected Map<UUID,GridNodeMetrics> metrics0(Collection<UUID> nodeIds)
                                      throws GridSpiException

Requests metrics from store in case local cached metrics are outdated.

Specified by:

metrics0 in class GridTcpDiscoveryMetricsStoreAdapter

Parameters:

nodeIds - Nodes to request metrics for.

Returns:

Metrics map.

Throws:

GridSpiException - If any error occurs.

allNodeIds

public Collection<UUID> allNodeIds()
                            throws GridSpiException

Gets all node IDs currently contained in the store.

Returns:

Node IDs currently contained in the store.

Throws:

GridSpiException - if an error occurs.

removeMetrics0

public void removeMetrics0(Collection<UUID> nodeIds)
                    throws GridSpiException

Removes metrics from store.

Specified by:

removeMetrics0 in class GridTcpDiscoveryMetricsStoreAdapter

Parameters:

nodeIds - Nodes to remove metrics of.

Throws:

GridSpiException - If any error occurs.

toString

public String toString()

Overrides:

toString in class Object