Package org.apache.ignite.internal.managers.systemview

Class GridSystemViewManager

java.lang.Object

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

org.apache.ignite.internal.managers.systemview.GridSystemViewManager

All Implemented Interfaces:

Iterable<SystemView<?>>, GridComponent, GridManager, ReadOnlySystemViewRegistry

public class GridSystemViewManager
extends GridManagerAdapter<SystemViewExporterSpi>
implements ReadOnlySystemViewRegistry

This manager should provide ReadOnlySystemViewRegistry for each configured SystemViewExporterSpi.

See Also:

SystemView, SystemViewAdapter

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.managers.GridManagerAdapter

ctx, log

Constructor Summary

Constructors

Constructor	Description
GridSystemViewManager(GridKernalContext ctx)

Method Summary

Modifier and Type	Method	Description
void	addSystemViewCreationListener(Consumer<SystemView<?>> lsnr)	Adds listener of view creation events.
@NotNull Iterator<SystemView<?>>	iterator()
<R,D> void	registerFiltrableView(String name, String desc, SystemViewRowAttributeWalker<R> walker, Function<Map<String,Object>,Iterable<D>> dataSupplier, Function<D,R> rowFunc)	Registers FiltrableSystemViewAdapter view with content filtering capabilities.
<C,R,D> void	registerInnerArrayView(String name, String desc, SystemViewRowAttributeWalker<R> walker, Collection<C> container, Function<C,D[]> dataExtractor, BiFunction<C,D,R> rowFunc)	Registers SystemViewInnerCollectionsAdapter view which exports container content.
<C,R,D> void	registerInnerCollectionView(String name, String desc, SystemViewRowAttributeWalker<R> walker, Iterable<C> container, Function<C,Iterable<D>> dataExtractor, BiFunction<C,D,R> rowFunc)	Registers SystemViewInnerCollectionsAdapter view which exports container content.
<R,D> void	registerView(String name, String desc, SystemViewRowAttributeWalker<R> walker, Collection<D> data, Function<D,R> rowFunc)	Registers SystemViewAdapter view which exports Collection content.
<R,D> void	registerView(String name, String desc, SystemViewRowAttributeWalker<R> walker, Supplier<Collection<D>> dataSupplier, Function<D,R> rowFunc)	Registers view which exports Collection content provided by specified Supplier.
<R> void	registerView(SystemView<R> sysView)	Registers SystemView instance.
void	start()	Starts grid component.
void	stop(boolean cancel)	Stops grid component.
<R> @Nullable SystemView<R>	view(String name)

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, onKernalStart0, 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

Constructor Detail

GridSystemViewManager

public GridSystemViewManager(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

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.

registerView

public <R> void registerView(SystemView<R> sysView)

Registers SystemView instance.

Type Parameters:

R - Row type.

Parameters:

sysView - System view.

registerView

public <R,D> void registerView(String name,
                                     String desc,
                                     SystemViewRowAttributeWalker<R> walker,
                                     Collection<D> data,
                                     Function<D,R> rowFunc)

Registers SystemViewAdapter view which exports Collection content.

Type Parameters:

R - View row type.

D - Collection data type.

Parameters:

name - Name.

desc - Description.

walker - Row walker.

data - Data.

rowFunc - value to row function.

registerInnerCollectionView

public <C,R,D> void registerInnerCollectionView(String name,
                                                            String desc,
                                                            SystemViewRowAttributeWalker<R> walker,
                                                            Iterable<C> container,
                                                            Function<C,Iterable<D>> dataExtractor,
                                                            BiFunction<C,D,R> rowFunc)

Registers SystemViewInnerCollectionsAdapter view which exports container content.

Type Parameters:

C - Container entry type.

R - View row type.

D - Collection data type.

Parameters:

name - Name.

desc - Description.

walker - Row walker.

container - Container of the data.

dataExtractor - Data extractor function.

rowFunc - Row function

registerInnerArrayView

public <C,R,D> void registerInnerArrayView(String name,
                                                       String desc,
                                                       SystemViewRowAttributeWalker<R> walker,
                                                       Collection<C> container,
                                                       Function<C,D[]> dataExtractor,
                                                       BiFunction<C,D,R> rowFunc)

Registers SystemViewInnerCollectionsAdapter view which exports container content.

Type Parameters:

C - Container entry type.

R - View row type.

D - Collection data type.

Parameters:

name - Name.

desc - Description.

walker - Row walker.

container - Container of the data.

dataExtractor - Data extractor function.

rowFunc - Row function

registerView

public <R,D> void registerView(String name,
                                     String desc,
                                     SystemViewRowAttributeWalker<R> walker,
                                     Supplier<Collection<D>> dataSupplier,
                                     Function<D,R> rowFunc)

Registers view which exports Collection content provided by specified Supplier.

Type Parameters:

R - View row type.

D - Collection data type.

Parameters:

name - Name.

desc - Description.

walker - Row walker.

dataSupplier - Data supplier.

rowFunc - value to row function.

registerFiltrableView

public <R,D> void registerFiltrableView(String name,
                                              String desc,
                                              SystemViewRowAttributeWalker<R> walker,
                                              Function<Map<String,Object>,Iterable<D>> dataSupplier,
                                              Function<D,R> rowFunc)

Registers FiltrableSystemViewAdapter view with content filtering capabilities.

Type Parameters:

R - View row type.

D - Collection data type.

Parameters:

name - Name.

desc - Description.

walker - Row walker.

dataSupplier - Data supplier with content filtering capabilities.

rowFunc - Row function

view

@Nullable
public <R> @Nullable SystemView<R> view(String name)

Parameters:

name - Name of the view.

Returns:

List.

addSystemViewCreationListener

public void addSystemViewCreationListener(Consumer<SystemView<?>> lsnr)

Adds listener of view creation events.

Specified by:

addSystemViewCreationListener in interface ReadOnlySystemViewRegistry

Parameters:

lsnr - Listener.

iterator

@NotNull
public @NotNull Iterator<SystemView<?>> iterator()

Specified by:

iterator in interface Iterable<SystemView<?>>