Package com.linkedin.venice.router.api.routing.helix

Class HelixGroupSelector

java.lang.Object

com.linkedin.venice.router.api.routing.helix.HelixGroupSelector

All Implemented Interfaces:

HelixGroupSelectionStrategy

public class HelixGroupSelector
extends Object
implements HelixGroupSelectionStrategy

This class is a thin wrapper of HelixInstanceConfigRepository and HelixGroupSelectionStrategy, and it will delegate all the related API calls to the corresponding objects. Besides that, this class is also in charge of emitting metrics for each Helix Group.

Constructor Summary

Constructors

Constructor	Description
HelixGroupSelector(io.tehuti.metrics.MetricsRepository metricsRepository, HelixInstanceConfigRepository instanceConfigRepository, HelixGroupSelectionStrategyEnum strategyEnum, TimeoutProcessor timeoutProcessor)

Method Summary

Modifier and Type	Method	Description
void	finishRequest(long requestId, int groupId, double latency)	Notify the corresponding Helix Group that the request is completed, and the implementation will decide whether any cleanup is required or not.
int	getGroupCount()
int	getInstanceGroupId(String instanceId)
int	selectGroup(long requestId, int groupNum)	Select a Helix Group for the current request.

Methods inherited from class java.lang.Object

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

Constructor Details

HelixGroupSelector

public HelixGroupSelector(io.tehuti.metrics.MetricsRepository metricsRepository,
 HelixInstanceConfigRepository instanceConfigRepository,
 HelixGroupSelectionStrategyEnum strategyEnum,
 TimeoutProcessor timeoutProcessor)

Method Details

getInstanceGroupId

public int getInstanceGroupId(String instanceId)

getGroupCount

public int getGroupCount()

selectGroup

public int selectGroup(long requestId,
 int groupNum)

Description copied from interface: HelixGroupSelectionStrategy

Select a Helix Group for the current request.

Specified by:

selectGroup in interface HelixGroupSelectionStrategy

finishRequest

public void finishRequest(long requestId,
 int groupId,
 double latency)

Description copied from interface: HelixGroupSelectionStrategy

Notify the corresponding Helix Group that the request is completed, and the implementation will decide whether any cleanup is required or not.

Specified by:

finishRequest in interface HelixGroupSelectionStrategy