Package com.linkedin.venice.fastclient.meta

Class LeastLoadedClientRoutingStrategy

java.lang.Object

com.linkedin.venice.fastclient.meta.AbstractClientRoutingStrategy

com.linkedin.venice.fastclient.meta.LeastLoadedClientRoutingStrategy

public class LeastLoadedClientRoutingStrategy
extends AbstractClientRoutingStrategy

This strategy is trying to route the request to the least-loaded instances. 1. If the weight of every instance is same, it will fall back to the round-robin fashion. 2. This strategy will skip any blocked instance. 3. When any selected instance is marked as unhealthy, this strategy will try to back-fill with the healthy instances, and there are two purposes: a. The latency shouldn't be affected since this strategy will still try to send request to the required healthy instances. b. The unhealthy instance will still receive any requests, so we could mark it healthy once it is recovered.

Constructor Summary

Constructors

Constructor	Description
LeastLoadedClientRoutingStrategy(InstanceHealthMonitor instanceHealthMonitor)

Method Summary

Modifier and Type	Method	Description
String	getReplicas(long requestId, int groupId, List<String> replicas)

Methods inherited from class com.linkedin.venice.fastclient.meta.AbstractClientRoutingStrategy

getHelixGroupId, trackRequest, updateHelixGroupInfo

Methods inherited from class java.lang.Object

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

Constructor Details

LeastLoadedClientRoutingStrategy

public LeastLoadedClientRoutingStrategy(InstanceHealthMonitor instanceHealthMonitor)

Method Details

getReplicas

public String getReplicas(long requestId,
 int groupId,
 List<String> replicas)

Overrides:

getReplicas in class AbstractClientRoutingStrategy