@GridToStringExclude public interface GridKernalContext extends Iterable<GridComponent>
| Modifier and Type | Method and 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() |
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.
|
MvccProcessor |
coordinators() |
<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() |
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.
|
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.
|
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.
|
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.
|
forEach, iterator, spliteratorList<GridComponent> components()
UUID localNodeId()
String igniteInstanceName()
IgniteLogger log(String ctgr)
ctgr - Category.IgniteLogger log(Class<?> cls)
cls - Class to get logger for.boolean isStopping()
True if grid is in the process of stopping.GridKernalGateway gateway()
IgniteEx grid()
IgniteConfiguration config()
GridTaskProcessor task()
GridAffinityProcessor affinity()
GridJobProcessor job()
GridTimeoutProcessor timeout()
GridResourceProcessor resource()
GridJobMetricsProcessor jobMetric()
GridMetricManager metric()
MaintenanceRegistry maintenanceRegistry()
GridSystemViewManager systemView()
GridCacheProcessor cache()
GridClusterStateProcessor state()
DistributedMetaStorage distributedMetastorage()
DistributedConfigurationProcessor distributedConfiguration()
Tracing tracing()
GridTaskSessionProcessor session()
GridClosureProcessor closure()
IgniteServiceProcessor service()
GridPortProcessor ports()
IgniteScheduleProcessorAdapter schedule()
IgniteRestProcessor rest()
GridSegmentationProcessor segmentation()
<K,V> DataStreamProcessor<K,V> dataStream()
GridContinuousProcessor continuous()
PoolProcessor pools()
GridMarshallerMappingProcessor mapping()
IgniteCacheObjectProcessor cacheObjects()
GridQueryProcessor query()
ClientListenerProcessor clientListener()
IgnitePluginProcessor plugins()
GridDeploymentManager deploy()
GridIoManager io()
GridDiscoveryManager discovery()
GridCheckpointManager checkpoint()
GridEventStorageManager event()
GridFailoverManager failover()
GridCollisionManager collision()
IgniteSecurity security()
IgniteSecurity.GridLoadBalancerManager loadBalancing()
GridIndexingManager indexing()
IndexProcessor indexProcessor()
GridEncryptionManager encryption()
IgniteDefragmentation defragmentation()
WorkersRegistry workersRegistry()
DataStructuresProcessor dataStructures()
LongJVMPauseDetector longJvmPauseDetector()
DiagnosticProcessor diagnostic()
boolean invalid()
True if this node is invalid, false otherwise.boolean segmented()
True if this node has segmented, false otherwise.FailureProcessor failure()
void printMemoryStats()
GridPerformanceSuggestions performance()
String userVersion(ClassLoader ldr)
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.ldr - Class loader.PluginProvider pluginProvider(String name) throws PluginNotFoundException
name - Plugin name.PluginNotFoundException - If plugin provider for the given name was not found.<T> T createComponent(Class<T> cls)
cls - Component class.IgniteExceptionRegistry exceptionRegistry()
Object nodeAttribute(String key)
key - Attribute name.boolean hasNodeAttribute(String key)
key - Attribute name.true If node has attribute with specified name.Object addNodeAttribute(String key, Object val)
key - Attribute name.val - Attribute value.ClusterProcessor cluster()
MarshallerContextImpl marshallerContext()
boolean clientNode()
True if local node is client node (has flag IgniteConfiguration.isClientMode() set).boolean clientDisconnected()
True if local node in disconnected state.PlatformProcessor platform()
MvccProcessor coordinators()
PdsFoldersResolver pdsFolderResolver()
GridInternalSubscriptionProcessor internalSubscriptionProcessor()
Thread.UncaughtExceptionHandler uncaughtExceptionHandler()
CompressionProcessor compress()
boolean recoveryMode()
True if node is in recovery mode (before join to topology).DurableBackgroundTasksProcessor durableBackgroundTask()
PerformanceStatisticsProcessor performanceStatistics()
Executor getAsyncContinuationExecutor()
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023