Uses of Class
org.apache.ignite.internal.worker.WorkersRegistry

Packages that use WorkersRegistry

Package	Description
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.processors.cache.persistence.checkpoint
org.apache.ignite.internal.processors.cache.persistence.wal.reader
org.apache.ignite.internal.worker	System worker registry and control MBean implementation.
org.apache.ignite.spi.communication.tcp.internal	Contains connection health-checkers for TCP/IP-based implementation of communication SPI.

Uses of WorkersRegistry in org.apache.ignite.internal

Methods in org.apache.ignite.internal that return WorkersRegistry

Modifier and Type	Method and Description
WorkersRegistry	GridKernalContextImpl.workersRegistry() Gets workers registry.
WorkersRegistry	GridKernalContext.workersRegistry() Gets workers registry.

Methods in org.apache.ignite.internal with parameters of type WorkersRegistry

Modifier and Type	Method and Description
void	IgniteKernal.start(IgniteConfiguration cfg, GridAbsClosure errHnd, WorkersRegistry workerRegistry, Thread.UncaughtExceptionHandler hnd, TimeBag startTimer)

Constructors in org.apache.ignite.internal with parameters of type WorkersRegistry

Constructor and Description
GridKernalContextImpl(GridLoggerProxy log, IgniteEx grid, IgniteConfiguration cfg, GridKernalGateway gw, List<PluginProvider> plugins, IgnitePredicate<String> clsFilter, WorkersRegistry workerRegistry, Thread.UncaughtExceptionHandler hnd, LongJVMPauseDetector pauseDetector) Creates new kernal context.

Uses of WorkersRegistry in org.apache.ignite.internal.processors.cache.persistence.checkpoint

Constructors in org.apache.ignite.internal.processors.cache.persistence.checkpoint with parameters of type WorkersRegistry

Constructor and Description
CheckpointManager(Function<Class<?>,IgniteLogger> logger, String igniteInstanceName, String checkpointThreadName, IgniteWriteAheadLogManager wal, WorkersRegistry workersRegistry, DataStorageConfiguration persistenceCfg, FilePageStoreManager pageStoreManager, IgniteThrowableBiPredicate<Long,Integer> checkpointInapplicableChecker, Supplier<Collection<DataRegion>> dataRegions, Supplier<Collection<CacheGroupContext>> cacheGroupContexts, IgniteThrowableFunction<Integer,PageMemoryEx> pageMemoryGroupResolver, PageMemoryImpl.ThrottlingPolicy throttlingPolicy, IgniteCacheSnapshotManager snapshotMgr, DataStorageMetricsImpl persStoreMetrics, LongJVMPauseDetector longJvmPauseDetector, FailureProcessor failureProcessor, GridCacheProcessor cacheProcessor, Supplier<Integer> cpFreqDeviation, Executor checkpointMapSnapshotExecutor)
LightweightCheckpointManager(Function<Class<?>,IgniteLogger> logger, String igniteInstanceName, String checkpointThreadName, WorkersRegistry workersRegistry, DataStorageConfiguration persistenceCfg, Supplier<Collection<DataRegion>> dataRegions, IgniteThrowableFunction<Integer,PageMemoryEx> pageMemoryGroupResolver, PageMemoryImpl.ThrottlingPolicy throttlingPolicy, IgniteCacheSnapshotManager snapshotMgr, DataStorageMetricsImpl persStoreMetrics, LongJVMPauseDetector longJvmPauseDetector, FailureProcessor failureProcessor, GridCacheProcessor cacheProcessor)

Uses of WorkersRegistry in org.apache.ignite.internal.processors.cache.persistence.wal.reader

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.reader that return WorkersRegistry

Modifier and Type	Method and Description
WorkersRegistry	StandaloneGridKernalContext.workersRegistry() Gets workers registry.

Uses of WorkersRegistry in org.apache.ignite.internal.worker

Constructors in org.apache.ignite.internal.worker with parameters of type WorkersRegistry

Constructor and Description
FailureHandlingMxBeanImpl(@NotNull WorkersRegistry workersRegistry, @NotNull IgniteCacheDatabaseSharedManager dbMgr)
WorkersControlMXBeanImpl(WorkersRegistry registry) Constructor.

Uses of WorkersRegistry in org.apache.ignite.spi.communication.tcp.internal

Constructors in org.apache.ignite.spi.communication.tcp.internal with parameters of type WorkersRegistry

Constructor and Description
CommunicationWorker(String igniteInstanceName, IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attrs, ConnectionClientPool clientPool, Supplier<FailureProcessor> failureProcessorSupplier, Function<UUID,ClusterNode> nodeGetter, Function<UUID,Boolean> pingNode, Supplier<IgniteExceptionRegistry> eRegistrySupplier, GridNioServerWrapper nioSrvWrapper, WorkersRegistry workersRegistry, String spiName)
ConnectionClientPool(TcpCommunicationConfiguration cfg, AttributeNames attrs, IgniteLogger log, TcpCommunicationMetricsListener metricsLsnr, Supplier<ClusterNode> locNodeSupplier, Function<UUID,ClusterNode> nodeGetter, Supplier<MessageFormatter> msgFormatterSupplier, WorkersRegistry registry, TcpCommunicationSpi tcpCommSpi, ClusterStateProvider clusterStateProvider, GridNioServerWrapper nioSrvWrapper, String igniteInstanceName)
GridNioServerWrapper(IgniteLogger log, TcpCommunicationConfiguration cfg, AttributeNames attributeNames, Tracing tracing, Function<UUID,ClusterNode> nodeGetter, Supplier<ClusterNode> locNodeSupplier, ConnectGateway connectGate, ClusterStateProvider stateProvider, Supplier<IgniteExceptionRegistry> eRegistrySupplier, CommunicationWorker commWorker, IgniteConfiguration igniteCfg, GridNioServerListener<Message> srvLsnr, String igniteInstanceName, WorkersRegistry workersRegistry, @Nullable GridMetricManager metricMgr, ThrowableBiFunction<ClusterNode,Integer,GridCommunicationClient,IgniteCheckedException> createTcpClientFun, CommunicationListener<Message> lsnr, TcpHandshakeExecutor tcpHandshakeExecutor) Deprecated.