com.netflix.genie.core.services

Interface ClusterLoadBalancer

All Superinterfaces:

org.springframework.core.Ordered

All Known Implementing Classes:

RandomizedClusterLoadBalancerImpl, ScriptLoadBalancer

@Validated
public interface ClusterLoadBalancer
extends org.springframework.core.Ordered

Interface for the cluster load-balancer, which returns the "best" cluster to run job on from an array of candidates.

Since:

2.0.0

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_ORDER The default order to apply to any implementation that doesn't explicitly set one.

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Method Summary

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

Field Detail

DEFAULT_ORDER

static final int DEFAULT_ORDER

The default order to apply to any implementation that doesn't explicitly set one.

See Also:

Ordered, OrderComparator, Constant Field Values

Method Detail

selectCluster

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

Return best cluster to run job on.

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

default int getOrder()

Specified by:

getOrder in interface org.springframework.core.Ordered