Class IgnitePluginProcessor
- java.lang.Object
-
- org.apache.ignite.internal.processors.GridProcessorAdapter
-
- org.apache.ignite.internal.processors.plugin.IgnitePluginProcessor
-
- All Implemented Interfaces:
GridComponent,GridProcessor
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 Description IgnitePluginProcessor(GridKernalContext ctx, IgniteConfiguration cfg, List<PluginProvider> providers)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Collection<PluginProvider>allProviders()voidcollectGridNodeData(DiscoveryDataBag dataBag)Collects discovery data on nodes already in grid on receivingTcpDiscoveryNodeAddedMessage.voidcollectJoiningNodeData(DiscoveryDataBag dataBag)Collects discovery data on joining node before sendingTcpDiscoveryJoinRequestMessagerequest.<T> TcreateComponent(Class<T> cls)@Nullable GridComponent.DiscoveryDataExchangeTypediscoveryDataType()Gets unique component type to distinguish components providing discovery data.<T extends Extension>
@Nullable T[]extensions(Class<T> extensionItf)voidonGridDataReceived(DiscoveryDataBag.GridDiscoveryData data)Receives discovery data object from remote nodes (called on new node during discovery process).voidonJoiningNodeDataReceived(DiscoveryDataBag.JoiningNodeDiscoveryData data)Method is called on nodes that are already in grid (not on joining node).<T extends PluginContext>
TpluginContextForProvider(PluginProvider provider)<T extends PluginProvider>
TpluginProvider(String name)voidstart()Starts grid component.-
Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter
assertParameter, onDisconnected, onKernalStart, onKernalStop, onReconnected, printMemoryStats, stop, toString, validateNode, validateNode
-
-
-
-
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> @Nullable 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
nullif no one plugin override this component.
-
start
public void start() throws IgniteCheckedExceptionStarts grid component.- Specified by:
startin interfaceGridComponent- Overrides:
startin classGridProcessorAdapter- Throws:
IgniteCheckedException- Throws in case of any errors.
-
discoveryDataType
@Nullable public @Nullable GridComponent.DiscoveryDataExchangeType discoveryDataType()
Gets unique component type to distinguish components providing discovery data. Must return non-null value if component implements any of methodsGridComponent.collectJoiningNodeData(DiscoveryDataBag)orGridComponent.collectGridNodeData(DiscoveryDataBag).- Specified by:
discoveryDataTypein interfaceGridComponent- Overrides:
discoveryDataTypein classGridProcessorAdapter- Returns:
- Unique component type for discovery data exchange.
-
collectJoiningNodeData
public void collectJoiningNodeData(DiscoveryDataBag dataBag)
Collects discovery data on joining node before sendingTcpDiscoveryJoinRequestMessagerequest.- Specified by:
collectJoiningNodeDatain interfaceGridComponent- Overrides:
collectJoiningNodeDatain classGridProcessorAdapter- Parameters:
dataBag- container object to store discovery data in.
-
collectGridNodeData
public void collectGridNodeData(DiscoveryDataBag dataBag)
Collects discovery data on nodes already in grid on receivingTcpDiscoveryNodeAddedMessage.- Specified by:
collectGridNodeDatain interfaceGridComponent- Overrides:
collectGridNodeDatain classGridProcessorAdapter- 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:
onJoiningNodeDataReceivedin interfaceGridComponent- Overrides:
onJoiningNodeDataReceivedin classGridProcessorAdapter- Parameters:
data-DiscoveryDataBag.JoiningNodeDiscoveryDatainterface 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:
onGridDataReceivedin interfaceGridComponent- Overrides:
onGridDataReceivedin classGridProcessorAdapter- Parameters:
data-DiscoveryDataBag.GridDiscoveryDatainterface to retrieve discovery data collected on remote nodes (data common for all nodes in grid and specific for each node).
-
-