org.apache.ignite.internal.processors.plugin

Class IgnitePluginProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.plugin.IgnitePluginProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

Direct Known Subclasses:

StandaloneIgnitePluginProcessor

public class IgnitePluginProcessor
extends GridProcessorAdapter

Nested Class Summary

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

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, diagnosticLog, log

Constructor Summary

Constructors

Constructor and Description
IgnitePluginProcessor(GridKernalContext ctx, IgniteConfiguration cfg, List<PluginProvider> providers)

Method Summary

Methods

Modifier and Type	Method and Description
Collection<PluginProvider>	allProviders()
void	collectGridNodeData(DiscoveryDataBag dataBag) Collects discovery data on nodes already in grid on receiving TcpDiscoveryNodeAddedMessage.
void	collectJoiningNodeData(DiscoveryDataBag dataBag) Collects discovery data on joining node before sending TcpDiscoveryJoinRequestMessage request.
<T> T	createComponent(Class<T> cls)
GridComponent.DiscoveryDataExchangeType	discoveryDataType() Gets unique component type to distinguish components providing discovery data.
<T extends Extension> T[]	extensions(Class<T> extensionItf)
void	onGridDataReceived(DiscoveryDataBag.GridDiscoveryData data) Receives discovery data object from remote nodes (called on new node during discovery process).
void	onJoiningNodeDataReceived(DiscoveryDataBag.JoiningNodeDiscoveryData data) Method is called on nodes that are already in grid (not on joining node).
<T extends PluginContext> T	pluginContextForProvider(PluginProvider provider)
<T extends PluginProvider> T	pluginProvider(String name)
void	start() Starts grid component.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, onDisconnected, onKernalStart, onKernalStop, onReconnected, printMemoryStats, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

IgnitePluginProcessor

public IgnitePluginProcessor(GridKernalContext ctx,
                     IgniteConfiguration cfg,
                     List<PluginProvider> providers)
                      throws IgniteCheckedException

Parameters:

ctx - Kernal context.

cfg - Ignite configuration.

providers - Plugin providers.

Throws:

IgniteCheckedException

Method Detail

extensions

@Nullable
public <T extends Extension> T[] extensions(Class<T> extensionItf)

Parameters:

extensionItf - Extension interface class.

Returns:

Returns implementation for provided extension from all plugins.

pluginProvider

@Nullable
public <T extends PluginProvider> T pluginProvider(String name)

Parameters:

name - Plugin name.

Returns:

Plugin provider.

allProviders

public Collection<PluginProvider> allProviders()

Returns:

All plugin providers.

pluginContextForProvider

public <T extends PluginContext> T pluginContextForProvider(PluginProvider provider)

Parameters:

provider - Plugin context.

Returns:

Plugin context.

createComponent

public <T> T createComponent(Class<T> cls)

Type Parameters:

T - Component type.

Parameters:

cls - Component class.

Returns:

Component class instance or null if no one plugin override this component.

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException - Throws in case of any errors.

discoveryDataType

@Nullable
public GridComponent.DiscoveryDataExchangeType discoveryDataType()

Gets unique component type to distinguish components providing discovery data. Must return non-null value if component implements any of methods GridComponent.collectJoiningNodeData(DiscoveryDataBag) or GridComponent.collectGridNodeData(DiscoveryDataBag).

Specified by:

discoveryDataType in interface GridComponent

Overrides:

discoveryDataType in class GridProcessorAdapter

Returns:

Unique component type for discovery data exchange.

collectJoiningNodeData

public void collectJoiningNodeData(DiscoveryDataBag dataBag)

Collects discovery data on joining node before sending TcpDiscoveryJoinRequestMessage request.

Specified by:

collectJoiningNodeData in interface GridComponent

Overrides:

collectJoiningNodeData in class GridProcessorAdapter

Parameters:

dataBag - container object to store discovery data in.

collectGridNodeData

public void collectGridNodeData(DiscoveryDataBag dataBag)

Collects discovery data on nodes already in grid on receiving TcpDiscoveryNodeAddedMessage.

Specified by:

collectGridNodeData in interface GridComponent

Overrides:

collectGridNodeData in class GridProcessorAdapter

Parameters:

dataBag - container object to store discovery data in.

onJoiningNodeDataReceived

public void onJoiningNodeDataReceived(DiscoveryDataBag.JoiningNodeDiscoveryData data)

Method is called on nodes that are already in grid (not on joining node). It receives discovery data from joining node.

Specified by:

onJoiningNodeDataReceived in interface GridComponent

Overrides:

onJoiningNodeDataReceived in class GridProcessorAdapter

Parameters:

data - DiscoveryDataBag.JoiningNodeDiscoveryData interface to retrieve discovery data of joining node.

onGridDataReceived

public void onGridDataReceived(DiscoveryDataBag.GridDiscoveryData data)

Receives discovery data object from remote nodes (called on new node during discovery process).

Specified by:

onGridDataReceived in interface GridComponent

Overrides:

onGridDataReceived in class GridProcessorAdapter

Parameters:

data - DiscoveryDataBag.GridDiscoveryData interface to retrieve discovery data collected on remote nodes (data common for all nodes in grid and specific for each node).