Package org.apache.ignite.internal.worker

Class WorkersRegistry

  • All Implemented Interfaces:
    EventListener, GridWorkerListener
    public class WorkersRegistry
extends Object
implements GridWorkerListener
    Workers registry. Maintains a set of workers currently running. Can perform periodic liveness checks for these workers on behalf of any of them.

    • Constructor Detail

      • WorkersRegistry

        public WorkersRegistry​(@NotNull
                       @NotNull IgniteBiInClosure<GridWorker,​FailureType> workerFailedHnd,
                       long sysWorkerBlockedTimeout,
                       IgniteLogger log)
        Parameters:
        workerFailedHnd - Closure to invoke on worker failure.
        sysWorkerBlockedTimeout - Maximum allowed worker heartbeat interval in milliseconds, non-positive value denotes infinite interval.

    • Method Detail

      • register

        public void register​(GridWorker w)
        Adds worker to the registry.
        Parameters:
        w - Worker.

      • unregister

        public void unregister​(String name)
        Removes worker from the registry.
        Parameters:
        name - Worker name.

      • names

        public Collection<String> names()
        Returns names of all registered workers.
        Returns:
        Registered worker names.

      • worker

        public GridWorker worker​(String name)
        Returns worker with given name.
        Parameters:
        name - Name.
        Returns:
        Registered GridWorker with name name or null if not found.

      • livenessCheckEnabled

        public boolean livenessCheckEnabled()

      • livenessCheckEnabled

        public void livenessCheckEnabled​(boolean val)

      • getSystemWorkerBlockedTimeout

        public long getSystemWorkerBlockedTimeout()
        Returns maximum inactivity period for system worker. When exceeded, worker is considered as blocked.
        Returns:
        Maximum inactivity period for system worker in milliseconds.

      • setSystemWorkerBlockedTimeout

        public void setSystemWorkerBlockedTimeout​(long val)
        Sets maximum inactivity period for system worker. When exceeded, worker is considered as blocked.
        Parameters:
        val - Maximum inactivity period for system worker in milliseconds.