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)
Map<String,NElement>	getOptions()
List<NWorkBalancerRunningJob>	getRunningJobs()
int	getRunningJobsCount()
NOptional<NWorkBalancerWorkerLoad>	getWorkerLoad(String workerName)
Map<String,NWorkBalancerWorkerLoad>	getWorkerLoads()
List<NWorkBalancerWorker>	getWorkers()
boolean	hasRunningJobs()
NCallable<T>	of(String name, NWorkBalancerJob<T> job)

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>

getRunningJobs

public List<NWorkBalancerRunningJob> getRunningJobs()

Specified by:

getRunningJobs in interface NWorkBalancer<T>

hasRunningJobs

public boolean hasRunningJobs()

Specified by:

hasRunningJobs in interface NWorkBalancer<T>

getRunningJobsCount

public int getRunningJobsCount()

Specified by:

getRunningJobsCount in interface NWorkBalancer<T>

getWorkers

public List<NWorkBalancerWorker> getWorkers()

Specified by:

getWorkers in interface NWorkBalancer<T>

getWorkerLoad

public NOptional<NWorkBalancerWorkerLoad> getWorkerLoad(String workerName)

Specified by:

getWorkerLoad in interface NWorkBalancer<T>

getWorkerLoads

public Map<String,NWorkBalancerWorkerLoad> getWorkerLoads()

Specified by:

getWorkerLoads in interface NWorkBalancer<T>

getOption

public NOptional<NElement> getOption(String name)

Specified by:

getOption in interface NWorkBalancer<T>

getOptions

public Map<String,NElement> getOptions()

Specified by:

getOptions in interface NWorkBalancer<T>