Package org.apache.ignite.internal.processors.cache.persistence.wal.reader

Class StandaloneGridKernalContext

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.wal.reader.StandaloneGridKernalContext

All Implemented Interfaces:

Iterable<GridComponent>, GridKernalContext

public class StandaloneGridKernalContext
extends Object
implements GridKernalContext

Dummy context for offline utilities. All grid components registered in the standalone context must be properly stopped since the lifecycle of them are controlled by kernal.

See Also:

GridComponent.stop(boolean)

Constructor Summary

Constructors

Constructor	Description
StandaloneGridKernalContext(IgniteLogger log, @Nullable File binaryMetadataFileStoreDir, @Nullable File marshallerMappingFileStoreDir)
StandaloneGridKernalContext(IgniteLogger log, @Nullable CompressionProcessor compressProc, @Nullable File binaryMetadataFileStoreDir, @Nullable File marshallerMappingFileStoreDir)

Method Summary

Modifier and Type	Method	Description
Object	addNodeAttribute(String key, Object val)	Add attribute to node attributes.
GridAffinityProcessor	affinity()	Gets cache data affinity processor.
GridCacheProcessor	cache()	Gets caches processor.
IgniteCacheObjectProcessor	cacheObjects()	Gets cache object processor.
GridCheckpointManager	checkpoint()	Gets checkpoint manager.
boolean	clientDisconnected()
ClientListenerProcessor	clientListener()	Gets client listener processor.
boolean	clientNode()
static void	closeAllComponents(GridKernalContext kctx)
GridClosureProcessor	closure()	Gets closure processor.
ClusterProcessor	cluster()	Gets Cluster processor.
GridCollisionManager	collision()	Gets collision manager.
List<GridComponent>	components()	Gets list of all grid components in the order they were added.
CompressionProcessor	compress()
IgniteConfiguration	config()	Gets grid configuration.
GridContinuousProcessor	continuous()	Gets event continuous processor.
<T> T	createComponent(Class<T> cls)	Creates optional component.
<K,V> DataStreamProcessor<K,V>	dataStream()	Gets data streamer processor.
DataStructuresProcessor	dataStructures()	Gets data structures processor.
IgniteDefragmentation	defragmentation()	Gets defragmentation manager.
GridDeploymentManager	deploy()	Gets deployment manager.
DiagnosticProcessor	diagnostic()	Gets diagnostic processor.
GridDiscoveryManager	discovery()	Gets discovery manager.
DistributedConfigurationProcessor	distributedConfiguration()	Gets distributed configuration processor.
DistributedMetaStorage	distributedMetastorage()	Gets global metastorage.
DurableBackgroundTasksProcessor	durableBackgroundTask()
GridEncryptionManager	encryption()	Gets encryption manager.
GridEventStorageManager	event()	Gets event storage manager.
IgniteExceptionRegistry	exceptionRegistry()	Gets exception registry.
GridFailoverManager	failover()	Gets failover manager.
FailureProcessor	failure()	Gets failure processor.
GridKernalGateway	gateway()	Gets kernal gateway.
Executor	getAsyncContinuationExecutor()	Executor that is in charge of processing user async continuations.
IgniteEx	grid()	Gets grid instance managed by kernal.
boolean	hasNodeAttribute(String key)	Check if node has specified attribute.
String	igniteInstanceName()	Gets Ignite instance name.
GridIndexingManager	indexing()	Gets indexing manager.
IndexProcessor	indexProcessor()	Indexes processor.
GridInternalSubscriptionProcessor	internalSubscriptionProcessor()
boolean	invalid()	Checks whether this node is invalid due to a critical error or not.
GridIoManager	io()	Gets communication manager.
boolean	isStopping()
@NotNull Iterator<GridComponent>	iterator()
GridJobProcessor	job()	Gets job processor.
GridJobMetricsProcessor	jobMetric()	Gets job metric processor.
GridLoadBalancerManager	loadBalancing()	Gets load balancing manager.
UUID	localNodeId()	Gets local node ID.
IgniteLogger	log(Class<?> cls)	Gets logger for given class.
IgniteLogger	log(String ctgr)	Gets logger for given category.
LongJVMPauseDetector	longJvmPauseDetector()	Gets long JVM pause detector.
MaintenanceRegistry	maintenanceRegistry()	Gets maintenance registry.
GridMarshallerMappingProcessor	mapping()	Gets grid marshaller mapping processor.
MarshallerContextImpl	marshallerContext()	Gets marshaller context.
GridMetricManager	metric()	Gets metric manager.
Object	nodeAttribute(String key)	Get node attribute by name.
Map<String,Object>	nodeAttributes()
PdsFoldersResolver	pdsFolderResolver()
GridPerformanceSuggestions	performance()
PerformanceStatisticsProcessor	performanceStatistics()	Gets Performance statistics processor.
PlatformProcessor	platform()
PluginProvider	pluginProvider(String name)
IgnitePluginProcessor	plugins()
PoolProcessor	pools()	Gets pool processor.
GridPortProcessor	ports()	Gets port processor.
protected IgniteConfiguration	prepareIgniteConfiguration()
void	printMemoryStats()	Print grid kernal memory stats (sizes of internal structures, etc.).
GridQueryProcessor	query()	Gets query processor.
boolean	recoveryMode()
GridResourceProcessor	resource()	Gets resource processor.
IgniteRestProcessor	rest()	Gets REST processor.
IgniteScheduleProcessorAdapter	schedule()	Gets schedule processor.
IgniteSecurity	security()	Gets instance of IgniteSecurity.
GridSegmentationProcessor	segmentation()	Gets segmentation processor.
boolean	segmented()	Checks whether this node detected its segmentation from the rest of the grid.
IgniteServiceProcessor	service()	Gets service processor.
GridTaskSessionProcessor	session()	Gets task session processor.
static void	startAllComponents(GridKernalContext kctx)
GridClusterStateProcessor	state()	Gets cluster state processor.
GridSystemViewManager	systemView()	Gets system view manager.
GridTaskProcessor	task()	Gets task processor.
GridTimeoutProcessor	timeout()	Gets timeout processor.
Tracing	tracing()	Gets tracing processor.
CacheObjectTransformerProcessor	transformer()	Gets transformation processor.
Thread.UncaughtExceptionHandler	uncaughtExceptionHandler()
String	userVersion(ClassLoader ldr)	Gets user version for given class loader by checking META-INF/ignite.xml file for userVersion attribute.
WorkersRegistry	workersRegistry()	Gets workers registry.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

StandaloneGridKernalContext

public StandaloneGridKernalContext(IgniteLogger log,
                                   @Nullable
                                   @Nullable File binaryMetadataFileStoreDir,
                                   @Nullable
                                   @Nullable File marshallerMappingFileStoreDir)
                            throws IgniteCheckedException

Parameters:

log - Logger.

binaryMetadataFileStoreDir - folder specifying location of metadata File Store. null means no specific folder is configured.

marshallerMappingFileStoreDir - folder specifying location of marshaller mapping file store. null means no specific folder is configured. Providing null will disable unmarshall for non primitive objects, BinaryObjects will be provided

Throws:

IgniteCheckedException

StandaloneGridKernalContext

public StandaloneGridKernalContext(IgniteLogger log,
                                   @Nullable
                                   @Nullable CompressionProcessor compressProc,
                                   @Nullable
                                   @Nullable File binaryMetadataFileStoreDir,
                                   @Nullable
                                   @Nullable File marshallerMappingFileStoreDir)
                            throws IgniteCheckedException

Parameters:

log - Logger.

compressProc - Compression processor.

binaryMetadataFileStoreDir - folder specifying location of metadata File Store. null means no specific folder is configured.

marshallerMappingFileStoreDir - folder specifying location of marshaller mapping file store. null means no specific folder is configured. Providing null will disable unmarshall for non primitive objects, BinaryObjects will be provided

Throws:

IgniteCheckedException

Method Detail

prepareIgniteConfiguration

protected IgniteConfiguration prepareIgniteConfiguration()

Returns:

Ignite configuration which allows to start requied processors for WAL reader

components

public List<GridComponent> components()

Gets list of all grid components in the order they were added.

Specified by:

components in interface GridKernalContext

Returns:

List of all grid components in the order they were added.

localNodeId

public UUID localNodeId()

Gets local node ID.

Specified by:

localNodeId in interface GridKernalContext

Returns:

Local node ID.

igniteInstanceName

public String igniteInstanceName()

Gets Ignite instance name.

Specified by:

igniteInstanceName in interface GridKernalContext

Returns:

Ignite instance name.

log

public IgniteLogger log(String ctgr)

Gets logger for given category.

Specified by:

log in interface GridKernalContext

Parameters:

ctgr - Category.

Returns:

Logger.

log

public IgniteLogger log(Class<?> cls)

Gets logger for given class.

Specified by:

log in interface GridKernalContext

Parameters:

cls - Class to get logger for.

Returns:

Logger.

isStopping

public boolean isStopping()

Specified by:

isStopping in interface GridKernalContext

Returns:

True if grid is in the process of stopping.

gateway

public GridKernalGateway gateway()

Gets kernal gateway.

Specified by:

gateway in interface GridKernalContext

Returns:

Kernal gateway.

grid

public IgniteEx grid()

Gets grid instance managed by kernal.

Specified by:

grid in interface GridKernalContext

Returns:

Grid instance.

config

public IgniteConfiguration config()

Gets grid configuration.

Specified by:

config in interface GridKernalContext

Returns:

Grid configuration.

task

public GridTaskProcessor task()

Gets task processor.

Specified by:

task in interface GridKernalContext

Returns:

Task processor.

affinity

public GridAffinityProcessor affinity()

Gets cache data affinity processor.

Specified by:

affinity in interface GridKernalContext

Returns:

Cache data affinity processor.

job

public GridJobProcessor job()

Gets job processor.

Specified by:

job in interface GridKernalContext

Returns:

Job processor

timeout

public GridTimeoutProcessor timeout()

Gets timeout processor.

Specified by:

timeout in interface GridKernalContext

Returns:

Timeout processor.

resource

public GridResourceProcessor resource()

Gets resource processor.

Specified by:

resource in interface GridKernalContext

Returns:

Resource processor.

jobMetric

public GridJobMetricsProcessor jobMetric()

Gets job metric processor.

Specified by:

jobMetric in interface GridKernalContext

Returns:

Metrics processor.

metric

public GridMetricManager metric()

Gets metric manager.

Specified by:

metric in interface GridKernalContext

Returns:

Monitoring manager.

systemView

public GridSystemViewManager systemView()

Gets system view manager.

Specified by:

systemView in interface GridKernalContext

Returns:

Monitoring manager.

cache

public GridCacheProcessor cache()

Gets caches processor.

Specified by:

cache in interface GridKernalContext

Returns:

Cache processor.

state

public GridClusterStateProcessor state()

Gets cluster state processor.

Specified by:

state in interface GridKernalContext

Returns:

Cluster state processor.

distributedMetastorage

public DistributedMetaStorage distributedMetastorage()

Gets global metastorage.

Specified by:

distributedMetastorage in interface GridKernalContext

Returns:

Global metastorage.

distributedConfiguration

public DistributedConfigurationProcessor distributedConfiguration()

Gets distributed configuration processor.

Specified by:

distributedConfiguration in interface GridKernalContext

Returns:

Distributed configuration processor.

tracing

public Tracing tracing()

Gets tracing processor.

Specified by:

tracing in interface GridKernalContext

Returns:

Tracing processor.

session

public GridTaskSessionProcessor session()

Gets task session processor.

Specified by:

session in interface GridKernalContext

Returns:

Session processor.

closure

public GridClosureProcessor closure()

Gets closure processor.

Specified by:

closure in interface GridKernalContext

Returns:

Closure processor.

service

public IgniteServiceProcessor service()

Gets service processor.

Specified by:

service in interface GridKernalContext

Returns:

Service processor.

ports

public GridPortProcessor ports()

Gets port processor.

Specified by:

ports in interface GridKernalContext

Returns:

Port processor.

schedule

public IgniteScheduleProcessorAdapter schedule()

Gets schedule processor.

Specified by:

schedule in interface GridKernalContext

Returns:

Schedule processor.

maintenanceRegistry

public MaintenanceRegistry maintenanceRegistry()

Gets maintenance registry.

Specified by:

maintenanceRegistry in interface GridKernalContext

Returns:

Maintenance registry.

transformer

public CacheObjectTransformerProcessor transformer()

Gets transformation processor.

Specified by:

transformer in interface GridKernalContext

Returns:

Transformation processor.

rest

public IgniteRestProcessor rest()

Gets REST processor.

Specified by:

rest in interface GridKernalContext

Returns:

REST processor.

segmentation

public GridSegmentationProcessor segmentation()

Gets segmentation processor.

Specified by:

segmentation in interface GridKernalContext

Returns:

Segmentation processor.

dataStream

public <K,V> DataStreamProcessor<K,V> dataStream()

Gets data streamer processor.

Specified by:

dataStream in interface GridKernalContext

Returns:

Data streamer processor.

continuous

public GridContinuousProcessor continuous()

Gets event continuous processor.

Specified by:

continuous in interface GridKernalContext

Returns:

Event continuous processor.

pools

public PoolProcessor pools()

Gets pool processor.

Specified by:

pools in interface GridKernalContext

Returns:

Pool processor.

mapping

public GridMarshallerMappingProcessor mapping()

Gets grid marshaller mapping processor.

Specified by:

mapping in interface GridKernalContext

Returns:

Mapping processor.

cacheObjects

public IgniteCacheObjectProcessor cacheObjects()

Gets cache object processor.

Specified by:

cacheObjects in interface GridKernalContext

Returns:

Cache object processor.

query

public GridQueryProcessor query()

Gets query processor.

Specified by:

query in interface GridKernalContext

Returns:

Query processor.

clientListener

public ClientListenerProcessor clientListener()

Gets client listener processor.

Specified by:

clientListener in interface GridKernalContext

Returns:

Client listener processor.

plugins

public IgnitePluginProcessor plugins()

Specified by:

plugins in interface GridKernalContext

Returns:

Plugin processor.

deploy

public GridDeploymentManager deploy()

Gets deployment manager.

Specified by:

deploy in interface GridKernalContext

Returns:

Deployment manager.

io

public GridIoManager io()

Gets communication manager.

Specified by:

io in interface GridKernalContext

Returns:

Communication manager.

discovery

public GridDiscoveryManager discovery()

Gets discovery manager.

Specified by:

discovery in interface GridKernalContext

Returns:

Discovery manager.

checkpoint

public GridCheckpointManager checkpoint()

Gets checkpoint manager.

Specified by:

checkpoint in interface GridKernalContext

Returns:

Checkpoint manager.

event

public GridEventStorageManager event()

Gets event storage manager.

Specified by:

event in interface GridKernalContext

Returns:

Event storage manager.

failover

public GridFailoverManager failover()

Gets failover manager.

Specified by:

failover in interface GridKernalContext

Returns:

Failover manager.

collision

public GridCollisionManager collision()

Gets collision manager.

Specified by:

collision in interface GridKernalContext

Returns:

Collision manager.

security

public IgniteSecurity security()

Gets instance of IgniteSecurity.

Specified by:

security in interface GridKernalContext

Returns:

Ignite security.

loadBalancing

public GridLoadBalancerManager loadBalancing()

Gets load balancing manager.

Specified by:

loadBalancing in interface GridKernalContext

Returns:

Load balancing manager.

indexing

public GridIndexingManager indexing()

Gets indexing manager.

Specified by:

indexing in interface GridKernalContext

Returns:

Indexing manager.

indexProcessor

public IndexProcessor indexProcessor()

Indexes processor.

Specified by:

indexProcessor in interface GridKernalContext

Returns:

Indexes processor.

encryption

public GridEncryptionManager encryption()

Gets encryption manager.

Specified by:

encryption in interface GridKernalContext

Returns:

Encryption manager.

defragmentation

public IgniteDefragmentation defragmentation()

Gets defragmentation manager.

Specified by:

defragmentation in interface GridKernalContext

Returns:

Defragmentation manager.

workersRegistry

public WorkersRegistry workersRegistry()

Gets workers registry.

Specified by:

workersRegistry in interface GridKernalContext

Returns:

Workers registry.

dataStructures

public DataStructuresProcessor dataStructures()

Gets data structures processor.

Specified by:

dataStructures in interface GridKernalContext

Returns:

Data structures processor.

invalid

public boolean invalid()

Checks whether this node is invalid due to a critical error or not.

Specified by:

invalid in interface GridKernalContext

Returns:

True if this node is invalid, false otherwise.

segmented

public boolean segmented()

Checks whether this node detected its segmentation from the rest of the grid.

Specified by:

segmented in interface GridKernalContext

Returns:

True if this node has segmented, false otherwise.

failure

public FailureProcessor failure()

Gets failure processor.

Specified by:

failure in interface GridKernalContext

printMemoryStats

public void printMemoryStats()

Print grid kernal memory stats (sizes of internal structures, etc.). NOTE: This method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridKernalContext

performance

public GridPerformanceSuggestions performance()

Specified by:

performance in interface GridKernalContext

Returns:

Performance suggestions object.

userVersion

public String userVersion(ClassLoader ldr)

Gets user version for given class loader by checking META-INF/ignite.xml file for userVersion attribute. If ignite.xml file is not found, or user version is not specified there, then default version (empty string) is returned.

Specified by:

userVersion in interface GridKernalContext

Parameters:

ldr - Class loader.

Returns:

User version for given class loader or empty string if no version was explicitly specified.

pluginProvider

public PluginProvider pluginProvider(String name)
                              throws PluginNotFoundException

Specified by:

pluginProvider in interface GridKernalContext

Parameters:

name - Plugin name.

Returns:

Plugin provider instance.

Throws:

PluginNotFoundException - If plugin provider for the given name was not found.

createComponent

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

Creates optional component.

Specified by:

createComponent in interface GridKernalContext

Parameters:

cls - Component class.

Returns:

Created component.

exceptionRegistry

public IgniteExceptionRegistry exceptionRegistry()

Gets exception registry.

Specified by:

exceptionRegistry in interface GridKernalContext

Returns:

Exception registry.

nodeAttribute

public Object nodeAttribute(String key)

Get node attribute by name.

Specified by:

nodeAttribute in interface GridKernalContext

Parameters:

key - Attribute name.

Returns:

Attribute value.

hasNodeAttribute

public boolean hasNodeAttribute(String key)

Check if node has specified attribute.

Specified by:

hasNodeAttribute in interface GridKernalContext

Parameters:

key - Attribute name.

Returns:

true If node has attribute with specified name.

addNodeAttribute

public Object addNodeAttribute(String key,
                               Object val)

Add attribute to node attributes.

Specified by:

addNodeAttribute in interface GridKernalContext

Parameters:

key - Attribute name.

val - Attribute value.

Returns:

Previous attribute value associated with attribute name.

nodeAttributes

public Map<String,Object> nodeAttributes()

Specified by:

nodeAttributes in interface GridKernalContext

Returns:

Node attributes.

cluster

public ClusterProcessor cluster()

Gets Cluster processor.

Specified by:

cluster in interface GridKernalContext

Returns:

Cluster processor.

marshallerContext

public MarshallerContextImpl marshallerContext()

Gets marshaller context.

Specified by:

marshallerContext in interface GridKernalContext

Returns:

Marshaller context.

clientNode

public boolean clientNode()

Specified by:

clientNode in interface GridKernalContext

Returns:

True if local node is client node (has flag IgniteConfiguration.isClientMode() set).

clientDisconnected

public boolean clientDisconnected()

Specified by:

clientDisconnected in interface GridKernalContext

Returns:

True if local node in disconnected state.

platform

public PlatformProcessor platform()

Specified by:

platform in interface GridKernalContext

Returns:

Platform processor.

internalSubscriptionProcessor

public GridInternalSubscriptionProcessor internalSubscriptionProcessor()

Specified by:

internalSubscriptionProcessor in interface GridKernalContext

Returns:

subscription processor to manage internal-only (strict node-local) subscriptions between components.

uncaughtExceptionHandler

public Thread.UncaughtExceptionHandler uncaughtExceptionHandler()

Specified by:

uncaughtExceptionHandler in interface GridKernalContext

Returns:

Default uncaught exception handler used by thread pools.

recoveryMode

public boolean recoveryMode()

Specified by:

recoveryMode in interface GridKernalContext

Returns:

True if node is in recovery mode (before join to topology).

pdsFolderResolver

public PdsFoldersResolver pdsFolderResolver()

Specified by:

pdsFolderResolver in interface GridKernalContext

Returns:

PDS mode folder name resolver, also generates consistent ID in case new folder naming is used

iterator

@NotNull
public @NotNull Iterator<GridComponent> iterator()

Specified by:

iterator in interface Iterable<GridComponent>

compress

public CompressionProcessor compress()

Specified by:

compress in interface GridKernalContext

Returns:

Compression processor.

longJvmPauseDetector

public LongJVMPauseDetector longJvmPauseDetector()

Gets long JVM pause detector.

Specified by:

longJvmPauseDetector in interface GridKernalContext

Returns:

Long JVM pause detector.

diagnostic

public DiagnosticProcessor diagnostic()

Gets diagnostic processor.

Specified by:

diagnostic in interface GridKernalContext

Returns:

Diagnostic processor.

durableBackgroundTask

public DurableBackgroundTasksProcessor durableBackgroundTask()

Specified by:

durableBackgroundTask in interface GridKernalContext

Returns:

Local continuous tasks processor.

performanceStatistics

public PerformanceStatisticsProcessor performanceStatistics()

Gets Performance statistics processor.

Specified by:

performanceStatistics in interface GridKernalContext

Returns:

Performance statistics processor.

getAsyncContinuationExecutor

public Executor getAsyncContinuationExecutor()

Executor that is in charge of processing user async continuations.

Specified by:

getAsyncContinuationExecutor in interface GridKernalContext

Returns:

Executor that is in charge of processing user async continuations.

startAllComponents

public static void startAllComponents(GridKernalContext kctx)
                               throws IgniteCheckedException

Parameters:

kctx - Kernal context.

Throws:

IgniteCheckedException - In case of any error.

closeAllComponents

public static void closeAllComponents(GridKernalContext kctx)
                               throws IgniteCheckedException

Parameters:

kctx - Kernal context.

Throws:

IgniteCheckedException - In case of any error.