Interface GridKernalContext

    • 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:
        True if grid is in the process of stopping.
      • grid

        IgniteEx grid()
        Gets grid instance managed by kernal.
        Returns:
        Grid instance.
      • affinity

        GridAffinityProcessor affinity()
        Gets cache data affinity processor.
        Returns:
        Cache data affinity processor.
      • metric

        GridMetricManager metric()
        Gets metric manager.
        Returns:
        Monitoring manager.
      • maintenanceRegistry

        MaintenanceRegistry maintenanceRegistry()
        Gets maintenance registry.
        Returns:
        Maintenance registry.
      • 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.
      • 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.
      • clientListener

        ClientListenerProcessor clientListener()
        Gets client listener processor.
        Returns:
        Client listener processor.
      • io

        GridIoManager io()
        Gets communication manager.
        Returns:
        Communication manager.
      • loadBalancing

        GridLoadBalancerManager loadBalancing()
        Gets load balancing manager.
        Returns:
        Load balancing manager.
      • indexProcessor

        IndexProcessor indexProcessor()
        Indexes processor.
        Returns:
        Indexes processor.
      • 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:
        True if this node is invalid, false otherwise.
      • segmented

        boolean segmented()
        Checks whether this node detected its segmentation from the rest of the grid.
        Returns:
        True if this node has segmented, false otherwise.
      • printMemoryStats

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

        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.
        Parameters:
        ldr - Class loader.
        Returns:
        User version for given class loader or empty string if no version was explicitly specified.
      • 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:
        true If 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.
      • nodeAttributes

        Map<String,​Object> nodeAttributes()
        Returns:
        Node attributes.
      • cluster

        ClusterProcessor cluster()
        Gets Cluster processor.
        Returns:
        Cluster processor.
      • marshallerContext

        MarshallerContextImpl marshallerContext()
        Gets marshaller context.
        Returns:
        Marshaller context.
      • clientDisconnected

        boolean clientDisconnected()
        Returns:
        True if local node in disconnected state.
      • 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.
      • recoveryMode

        boolean recoveryMode()
        Returns:
        True if node is in recovery mode (before join to topology).
      • 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.