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 java.lang.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)	Notify the corresponding Helix Group that the request is completed, and the implementation will decide whether any cleanup is required or not.
int	getAvgGroupPendingRequest()	Get the average of the pending requests among all the groups
int	getGroupCount()
int	getInstanceGroupId(java.lang.String instanceId)
int	getMaxGroupPendingRequest()	Get the maximum of the pending requests among all the groups
int	getMinGroupPendingRequest()	Get the minimum of the pending requests among all the groups
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 Detail

HelixGroupSelector

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

Method Detail

getInstanceGroupId

public int getInstanceGroupId(java.lang.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)

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

getMaxGroupPendingRequest

public int getMaxGroupPendingRequest()

Description copied from interface: HelixGroupSelectionStrategy

Get the maximum of the pending requests among all the groups

Specified by:

getMaxGroupPendingRequest in interface HelixGroupSelectionStrategy

getMinGroupPendingRequest

public int getMinGroupPendingRequest()

Description copied from interface: HelixGroupSelectionStrategy

Get the minimum of the pending requests among all the groups

Specified by:

getMinGroupPendingRequest in interface HelixGroupSelectionStrategy

getAvgGroupPendingRequest

public int getAvgGroupPendingRequest()

Description copied from interface: HelixGroupSelectionStrategy

Get the average of the pending requests among all the groups

Specified by:

getAvgGroupPendingRequest in interface HelixGroupSelectionStrategy