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

Class GridTcpDiscoveryJdbcMetricsStore

java.lang.Object

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

org.gridgain.grid.spi.discovery.tcp.metricsstore.jdbc.GridTcpDiscoveryJdbcMetricsStore

All Implemented Interfaces:

GridTcpDiscoveryMetricsStore

public class GridTcpDiscoveryJdbcMetricsStore
extends GridTcpDiscoveryMetricsStoreAdapter

JDBC-based metrics store.

Configuration

Mandatory

• Data source (see setDataSource(DataSource)).

Optional

There are no optional configuration parameters.

The database will contain 1 table to hold nodes metrics (tbl_metrics).

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHK_QRY Query to check database validity.
static String	CREATE_METRICS_TABLE_QRY Query to create metrics table.
static String	GET_ALL_IDS_QRY Query to get all node IDs.
static String	GET_METRICS_QRY Query to get metrics.
static String	PUT_METRICS_QRY Query to put metrics.
static String	REMOVE_METRICS_QRY Query to remove metrics.

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

DFLT_METRICS_EXPIRE_TIME

Constructor Summary

Constructors

Constructor and Description
GridTcpDiscoveryJdbcMetricsStore()

Method Summary

Methods

Modifier and Type	Method and Description
Collection<UUID>	allNodeIds() Gets all node IDs currently contained in the store.
protected Map<UUID,GridNodeMetrics>	metrics0(Collection<UUID> nodeIds) Requests metrics from store in case local cached metrics are outdated.
protected void	removeMetrics0(Collection<UUID> nodeIds) Removes metrics from store.
void	setDataSource(DataSource dataSrc) Sets data source.
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

GET_METRICS_QRY

public static final String GET_METRICS_QRY

Query to get metrics.

See Also:

Constant Field Values

REMOVE_METRICS_QRY

public static final String REMOVE_METRICS_QRY

Query to remove metrics.

See Also:

Constant Field Values

GET_ALL_IDS_QRY

public static final String GET_ALL_IDS_QRY

Query to get all node IDs.

See Also:

Constant Field Values

PUT_METRICS_QRY

public static final String PUT_METRICS_QRY

Query to put metrics.

See Also:

Constant Field Values

CREATE_METRICS_TABLE_QRY

public static final String CREATE_METRICS_TABLE_QRY

Query to create metrics table.

See Also:

Constant Field Values

CHK_QRY

public static final String CHK_QRY

Query to check database validity.

See Also:

Constant Field Values

Constructor Detail

GridTcpDiscoveryJdbcMetricsStore

public GridTcpDiscoveryJdbcMetricsStore()

Method Detail

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.

removeMetrics0

protected 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.

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.

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.

setDataSource

@GridSpiConfiguration(optional=false)
public void setDataSource(DataSource dataSrc)

Sets data source.

Data source should be fully configured and ready-to-use.

Parameters:

dataSrc - Data source.

toString

public String toString()

Overrides:

toString in class Object