com.netflix.genie.core.services.impl

Class RandomizedClusterLoadBalancerImpl

java.lang.Object

com.netflix.genie.core.services.impl.RandomizedClusterLoadBalancerImpl

All Implemented Interfaces:

ClusterLoadBalancer, org.springframework.core.Ordered

public class RandomizedClusterLoadBalancerImpl
extends java.lang.Object
implements ClusterLoadBalancer

Basic implementation of a load balancer where a cluster is picked at random.

Field Summary

Fields inherited from interface com.netflix.genie.core.services.ClusterLoadBalancer

DEFAULT_ORDER

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
RandomizedClusterLoadBalancerImpl()

Method Summary

Modifier and Type	Method and Description
int	getOrder()
Cluster	selectCluster(java.util.List<Cluster> clusters, JobRequest jobRequest) Return best cluster to run job on.

Methods inherited from class java.lang.Object

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

Constructor Detail

RandomizedClusterLoadBalancerImpl

public RandomizedClusterLoadBalancerImpl()

Method Detail

selectCluster

public Cluster selectCluster(@Nonnull @NonNull @NotEmpty
                             java.util.List<Cluster> clusters,
                             @Nonnull @NonNull
                             JobRequest jobRequest)
                      throws GenieException

Return best cluster to run job on.

Specified by:

selectCluster in interface ClusterLoadBalancer

Parameters:

clusters - An immutable, non-empty list of available clusters to choose from

jobRequest - The job request these clusters are being load balanced for

Returns:

the "best" cluster to run job on or null if no cluster selected

Throws:

GenieException - if there is any error

getOrder

public int getOrder()

Specified by:

getOrder in interface ClusterLoadBalancer

Specified by:

getOrder in interface org.springframework.core.Ordered