Package org.apache.ignite.internal
Interface GridKernalContext
-
- All Superinterfaces:
Iterable<GridComponent>
- All Known Implementing Classes:
GridKernalContextImpl,StandaloneGridKernalContext
@GridToStringExclude public interface GridKernalContext extends Iterable<GridComponent>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ObjectaddNodeAttribute(String key, Object val)Add attribute to node attributes.GridAffinityProcessoraffinity()Gets cache data affinity processor.GridCacheProcessorcache()Gets caches processor.IgniteCacheObjectProcessorcacheObjects()Gets cache object processor.GridCheckpointManagercheckpoint()Gets checkpoint manager.booleanclientDisconnected()ClientListenerProcessorclientListener()Gets client listener processor.booleanclientNode()GridClosureProcessorclosure()Gets closure processor.ClusterProcessorcluster()Gets Cluster processor.GridCollisionManagercollision()Gets collision manager.List<GridComponent>components()Gets list of all grid components in the order they were added.CompressionProcessorcompress()IgniteConfigurationconfig()Gets grid configuration.GridContinuousProcessorcontinuous()Gets event continuous processor.<T> TcreateComponent(Class<T> cls)Creates optional component.<K,V>
DataStreamProcessor<K,V>dataStream()Gets data streamer processor.DataStructuresProcessordataStructures()Gets data structures processor.IgniteDefragmentationdefragmentation()Gets defragmentation manager.GridDeploymentManagerdeploy()Gets deployment manager.DiagnosticProcessordiagnostic()Gets diagnostic processor.GridDiscoveryManagerdiscovery()Gets discovery manager.DistributedConfigurationProcessordistributedConfiguration()Gets distributed configuration processor.DistributedMetaStoragedistributedMetastorage()Gets global metastorage.DurableBackgroundTasksProcessordurableBackgroundTask()GridEncryptionManagerencryption()Gets encryption manager.GridEventStorageManagerevent()Gets event storage manager.IgniteExceptionRegistryexceptionRegistry()Gets exception registry.GridFailoverManagerfailover()Gets failover manager.FailureProcessorfailure()Gets failure processor.GridKernalGatewaygateway()Gets kernal gateway.ExecutorgetAsyncContinuationExecutor()Executor that is in charge of processing user async continuations.IgniteExgrid()Gets grid instance managed by kernal.booleanhasNodeAttribute(String key)Check if node has specified attribute.StringigniteInstanceName()Gets Ignite instance name.GridIndexingManagerindexing()Gets indexing manager.IndexProcessorindexProcessor()Indexes processor.GridInternalSubscriptionProcessorinternalSubscriptionProcessor()booleaninvalid()Checks whether this node is invalid due to a critical error or not.GridIoManagerio()Gets communication manager.booleanisStopping()GridJobProcessorjob()Gets job processor.GridJobMetricsProcessorjobMetric()Gets job metric processor.GridLoadBalancerManagerloadBalancing()Gets load balancing manager.UUIDlocalNodeId()Gets local node ID.IgniteLoggerlog(Class<?> cls)Gets logger for given class.IgniteLoggerlog(String ctgr)Gets logger for given category.LongJVMPauseDetectorlongJvmPauseDetector()Gets long JVM pause detector.MaintenanceRegistrymaintenanceRegistry()Gets maintenance registry.GridMarshallerMappingProcessormapping()Gets grid marshaller mapping processor.MarshallerContextImplmarshallerContext()Gets marshaller context.GridMetricManagermetric()Gets metric manager.ObjectnodeAttribute(String key)Get node attribute by name.Map<String,Object>nodeAttributes()PdsFoldersResolverpdsFolderResolver()GridPerformanceSuggestionsperformance()PerformanceStatisticsProcessorperformanceStatistics()Gets Performance statistics processor.PlatformProcessorplatform()PluginProviderpluginProvider(String name)IgnitePluginProcessorplugins()PoolProcessorpools()Gets pool processor.GridPortProcessorports()Gets port processor.voidprintMemoryStats()Print grid kernal memory stats (sizes of internal structures, etc.).GridQueryProcessorquery()Gets query processor.booleanrecoveryMode()GridResourceProcessorresource()Gets resource processor.IgniteRestProcessorrest()Gets REST processor.IgniteScheduleProcessorAdapterschedule()Gets schedule processor.IgniteSecuritysecurity()Gets instance ofIgniteSecurity.GridSegmentationProcessorsegmentation()Gets segmentation processor.booleansegmented()Checks whether this node detected its segmentation from the rest of the grid.IgniteServiceProcessorservice()Gets service processor.GridTaskSessionProcessorsession()Gets task session processor.GridClusterStateProcessorstate()Gets cluster state processor.GridSystemViewManagersystemView()Gets system view manager.GridTaskProcessortask()Gets task processor.GridTimeoutProcessortimeout()Gets timeout processor.Tracingtracing()Gets tracing processor.CacheObjectTransformerProcessortransformer()Gets transformation processor.Thread.UncaughtExceptionHandleruncaughtExceptionHandler()StringuserVersion(ClassLoader ldr)Gets user version for given class loader by checkingMETA-INF/ignite.xmlfile foruserVersionattribute.WorkersRegistryworkersRegistry()Gets workers registry.-
Methods inherited from interface java.lang.Iterable
forEach, iterator, spliterator
-
-
-
-
Method Detail
-
components
List<GridComponent> components()
Gets list of all grid components in the order they were added.- Returns:
- List of all grid components in the order they were added.
-
localNodeId
UUID localNodeId()
Gets local node ID.- Returns:
- Local node ID.
-
igniteInstanceName
String igniteInstanceName()
Gets Ignite instance name.- Returns:
- Ignite instance name.
-
log
IgniteLogger log(String ctgr)
Gets logger for given category.- Parameters:
ctgr- Category.- Returns:
- Logger.
-
log
IgniteLogger log(Class<?> cls)
Gets logger for given class.- Parameters:
cls- Class to get logger for.- Returns:
- Logger.
-
isStopping
boolean isStopping()
- Returns:
Trueif grid is in the process of stopping.
-
gateway
GridKernalGateway gateway()
Gets kernal gateway.- Returns:
- Kernal gateway.
-
grid
IgniteEx grid()
Gets grid instance managed by kernal.- Returns:
- Grid instance.
-
config
IgniteConfiguration config()
Gets grid configuration.- Returns:
- Grid configuration.
-
task
GridTaskProcessor task()
Gets task processor.- Returns:
- Task processor.
-
affinity
GridAffinityProcessor affinity()
Gets cache data affinity processor.- Returns:
- Cache data affinity processor.
-
job
GridJobProcessor job()
Gets job processor.- Returns:
- Job processor
-
timeout
GridTimeoutProcessor timeout()
Gets timeout processor.- Returns:
- Timeout processor.
-
resource
GridResourceProcessor resource()
Gets resource processor.- Returns:
- Resource processor.
-
jobMetric
GridJobMetricsProcessor jobMetric()
Gets job metric processor.- Returns:
- Metrics processor.
-
metric
GridMetricManager metric()
Gets metric manager.- Returns:
- Monitoring manager.
-
maintenanceRegistry
MaintenanceRegistry maintenanceRegistry()
Gets maintenance registry.- Returns:
- Maintenance registry.
-
transformer
CacheObjectTransformerProcessor transformer()
Gets transformation processor.- Returns:
- Transformation processor.
-
systemView
GridSystemViewManager systemView()
Gets system view manager.- Returns:
- Monitoring manager.
-
cache
GridCacheProcessor cache()
Gets caches processor.- Returns:
- Cache processor.
-
state
GridClusterStateProcessor state()
Gets cluster state processor.- Returns:
- Cluster state processor.
-
distributedMetastorage
DistributedMetaStorage distributedMetastorage()
Gets global metastorage.- Returns:
- Global metastorage.
-
distributedConfiguration
DistributedConfigurationProcessor distributedConfiguration()
Gets distributed configuration processor.- Returns:
- Distributed configuration processor.
-
tracing
Tracing tracing()
Gets tracing processor.- Returns:
- Tracing processor.
-
session
GridTaskSessionProcessor session()
Gets task session processor.- Returns:
- Session processor.
-
closure
GridClosureProcessor closure()
Gets closure processor.- Returns:
- Closure processor.
-
service
IgniteServiceProcessor service()
Gets service processor.- Returns:
- Service processor.
-
ports
GridPortProcessor ports()
Gets port processor.- Returns:
- Port processor.
-
schedule
IgniteScheduleProcessorAdapter schedule()
Gets schedule processor.- Returns:
- Schedule processor.
-
rest
IgniteRestProcessor rest()
Gets REST processor.- Returns:
- REST processor.
-
segmentation
GridSegmentationProcessor segmentation()
Gets segmentation processor.- Returns:
- Segmentation processor.
-
dataStream
<K,V> DataStreamProcessor<K,V> dataStream()
Gets data streamer processor.- Returns:
- Data streamer processor.
-
continuous
GridContinuousProcessor continuous()
Gets event continuous processor.- Returns:
- Event continuous processor.
-
pools
PoolProcessor pools()
Gets pool processor.- Returns:
- Pool processor.
-
mapping
GridMarshallerMappingProcessor mapping()
Gets grid marshaller mapping processor.- Returns:
- Mapping processor.
-
cacheObjects
IgniteCacheObjectProcessor cacheObjects()
Gets cache object processor.- Returns:
- Cache object processor.
-
query
GridQueryProcessor query()
Gets query processor.- Returns:
- Query processor.
-
clientListener
ClientListenerProcessor clientListener()
Gets client listener processor.- Returns:
- Client listener processor.
-
plugins
IgnitePluginProcessor plugins()
- Returns:
- Plugin processor.
-
deploy
GridDeploymentManager deploy()
Gets deployment manager.- Returns:
- Deployment manager.
-
io
GridIoManager io()
Gets communication manager.- Returns:
- Communication manager.
-
discovery
GridDiscoveryManager discovery()
Gets discovery manager.- Returns:
- Discovery manager.
-
checkpoint
GridCheckpointManager checkpoint()
Gets checkpoint manager.- Returns:
- Checkpoint manager.
-
event
GridEventStorageManager event()
Gets event storage manager.- Returns:
- Event storage manager.
-
failover
GridFailoverManager failover()
Gets failover manager.- Returns:
- Failover manager.
-
collision
GridCollisionManager collision()
Gets collision manager.- Returns:
- Collision manager.
-
security
IgniteSecurity security()
Gets instance ofIgniteSecurity.- Returns:
- Ignite security.
-
loadBalancing
GridLoadBalancerManager loadBalancing()
Gets load balancing manager.- Returns:
- Load balancing manager.
-
indexing
GridIndexingManager indexing()
Gets indexing manager.- Returns:
- Indexing manager.
-
indexProcessor
IndexProcessor indexProcessor()
Indexes processor.- Returns:
- Indexes processor.
-
encryption
GridEncryptionManager encryption()
Gets encryption manager.- Returns:
- Encryption manager.
-
defragmentation
IgniteDefragmentation defragmentation()
Gets defragmentation manager.- Returns:
- Defragmentation manager.
-
workersRegistry
WorkersRegistry workersRegistry()
Gets workers registry.- Returns:
- Workers registry.
-
dataStructures
DataStructuresProcessor dataStructures()
Gets data structures processor.- Returns:
- Data structures processor.
-
longJvmPauseDetector
LongJVMPauseDetector longJvmPauseDetector()
Gets long JVM pause detector.- Returns:
- Long JVM pause detector.
-
diagnostic
DiagnosticProcessor diagnostic()
Gets diagnostic processor.- Returns:
- Diagnostic processor.
-
invalid
boolean invalid()
Checks whether this node is invalid due to a critical error or not.- Returns:
Trueif this node is invalid,falseotherwise.
-
segmented
boolean segmented()
Checks whether this node detected its segmentation from the rest of the grid.- Returns:
Trueif this node has segmented,falseotherwise.
-
failure
FailureProcessor failure()
Gets failure processor.
-
printMemoryStats
void printMemoryStats()
Print grid kernal memory stats (sizes of internal structures, etc.). NOTE: This method is for testing and profiling purposes only.
-
performance
GridPerformanceSuggestions performance()
- Returns:
- Performance suggestions object.
-
userVersion
String userVersion(ClassLoader ldr)
Gets user version for given class loader by checkingMETA-INF/ignite.xmlfile foruserVersionattribute. Ifignite.xmlfile is not found, or user version is not specified there, then default version (empty string) is returned.- Parameters:
ldr- Class loader.- Returns:
- User version for given class loader or empty string if no version was explicitly specified.
-
pluginProvider
PluginProvider pluginProvider(String name) throws PluginNotFoundException
- Parameters:
name- Plugin name.- Returns:
- Plugin provider instance.
- Throws:
PluginNotFoundException- If plugin provider for the given name was not found.
-
createComponent
<T> T createComponent(Class<T> cls)
Creates optional component.- Parameters:
cls- Component class.- Returns:
- Created component.
-
exceptionRegistry
IgniteExceptionRegistry exceptionRegistry()
Gets exception registry.- Returns:
- Exception registry.
-
nodeAttribute
Object nodeAttribute(String key)
Get node attribute by name.- Parameters:
key- Attribute name.- Returns:
- Attribute value.
-
hasNodeAttribute
boolean hasNodeAttribute(String key)
Check if node has specified attribute.- Parameters:
key- Attribute name.- Returns:
trueIf node has attribute with specified name.
-
addNodeAttribute
Object addNodeAttribute(String key, Object val)
Add attribute to node attributes.- Parameters:
key- Attribute name.val- Attribute value.- Returns:
- Previous attribute value associated with attribute name.
-
cluster
ClusterProcessor cluster()
Gets Cluster processor.- Returns:
- Cluster processor.
-
marshallerContext
MarshallerContextImpl marshallerContext()
Gets marshaller context.- Returns:
- Marshaller context.
-
clientNode
boolean clientNode()
- Returns:
Trueif local node is client node (has flagIgniteConfiguration.isClientMode()set).
-
clientDisconnected
boolean clientDisconnected()
- Returns:
Trueif local node in disconnected state.
-
platform
PlatformProcessor platform()
- Returns:
- Platform processor.
-
pdsFolderResolver
PdsFoldersResolver pdsFolderResolver()
- Returns:
- PDS mode folder name resolver, also generates consistent ID in case new folder naming is used
-
internalSubscriptionProcessor
GridInternalSubscriptionProcessor internalSubscriptionProcessor()
- Returns:
- subscription processor to manage internal-only (strict node-local) subscriptions between components.
-
uncaughtExceptionHandler
Thread.UncaughtExceptionHandler uncaughtExceptionHandler()
- Returns:
- Default uncaught exception handler used by thread pools.
-
compress
CompressionProcessor compress()
- Returns:
- Compression processor.
-
recoveryMode
boolean recoveryMode()
- Returns:
Trueif node is in recovery mode (before join to topology).
-
durableBackgroundTask
DurableBackgroundTasksProcessor durableBackgroundTask()
- Returns:
- Local continuous tasks processor.
-
performanceStatistics
PerformanceStatisticsProcessor performanceStatistics()
Gets Performance statistics processor.- Returns:
- Performance statistics processor.
-
getAsyncContinuationExecutor
Executor getAsyncContinuationExecutor()
Executor that is in charge of processing user async continuations.- Returns:
- Executor that is in charge of processing user async continuations.
-
-