@Validated
public interface ClusterLoadBalancer
Modifier and Type | Method and Description |
---|---|
Cluster |
selectCluster(@NonNull @NotEmpty java.util.Set<Cluster> clusters,
@NonNull JobRequest jobRequest)
Return best cluster to run job on.
|
@Nullable Cluster selectCluster(@Nonnull @NonNull @NotEmpty @NonNull @NotEmpty java.util.Set<Cluster> clusters, @Nonnull @NonNull @NonNull JobRequest jobRequest) throws GenieException
clusters
- An immutable, non-empty list of available clusters to choose fromjobRequest
- The job request these clusters are being load balanced forGenieException
- if there is any error