net.thevpc.nuts.runtime.standalone.concurrent

Class NWorkBalancerImpl<T>

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NWorkBalancerImpl<T>

All Implemented Interfaces:

NWorkBalancer<T>

public class NWorkBalancerImpl<T>
extends Object
implements NWorkBalancer<T>

Constructor Summary

Constructors

Constructor and Description
NWorkBalancerImpl(NWorkBalancerModel model, NWorkBalancerFactoryImpl factory)

Method Summary

Modifier and Type	Method and Description
NOptional<NElement>	getOption(String name)
NOptional<NWorkBalancerWorkerLoad>	getWorkerLoad(String workerName)
boolean	isRunning()
NCallable<T>	of(String name, NWorkBalancerJob<T> job)
Map<String,NElement>	options()
List<NWorkBalancerRunningJob>	runningJobs()
int	runningJobsCount()
Map<String,NWorkBalancerWorkerLoad>	workerLoads()
List<NWorkBalancerWorker>	workers()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NWorkBalancerImpl

public NWorkBalancerImpl(NWorkBalancerModel model,
                         NWorkBalancerFactoryImpl factory)

Method Detail

of

public NCallable<T> of(String name,
                       NWorkBalancerJob<T> job)

Specified by:

of in interface NWorkBalancer<T>

runningJobs

public List<NWorkBalancerRunningJob> runningJobs()

Specified by:

runningJobs in interface NWorkBalancer<T>

isRunning

public boolean isRunning()

Specified by:

isRunning in interface NWorkBalancer<T>

runningJobsCount

public int runningJobsCount()

Specified by:

runningJobsCount in interface NWorkBalancer<T>

workers

public List<NWorkBalancerWorker> workers()

Specified by:

workers in interface NWorkBalancer<T>

getWorkerLoad

public NOptional<NWorkBalancerWorkerLoad> getWorkerLoad(String workerName)

Specified by:

getWorkerLoad in interface NWorkBalancer<T>

workerLoads

public Map<String,NWorkBalancerWorkerLoad> workerLoads()

Specified by:

workerLoads in interface NWorkBalancer<T>

getOption

public NOptional<NElement> getOption(String name)

Specified by:

getOption in interface NWorkBalancer<T>

options

public Map<String,NElement> options()

Specified by:

options in interface NWorkBalancer<T>