Package com.linkedin.davinci.kafka.consumer

Class AdaptiveThrottlerSignalService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.davinci.kafka.consumer.AdaptiveThrottlerSignalService

All Implemented Interfaces:

Closeable, AutoCloseable

public class AdaptiveThrottlerSignalService
extends AbstractVeniceService

This class contains service to periodically refresh all the signals for throttlers and update all registered throttler based on new signal values.

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.service.AbstractVeniceService

AbstractVeniceService.ServiceState

Field Summary

Fields

Modifier and Type	Field	Description
static final long	HEARTBEAT_LAG_LIMIT
static final String	MULTI_GET_LATENCY_P99_METRIC_NAME
static final String	READ_COMPUTE_LATENCY_P99_METRIC_NAME
static final String	SINGLE_GET_LATENCY_P99_METRIC_NAME

Fields inherited from class com.linkedin.venice.service.AbstractVeniceService

logger, serviceState

Constructor Summary

Constructors

Constructor	Description
AdaptiveThrottlerSignalService(VeniceServerConfig veniceServerConfig, io.tehuti.metrics.MetricsRepository metricsRepository, HeartbeatMonitoringService heartbeatMonitoringService)

Method Summary

Modifier and Type	Method	Description
AdaptiveThrottlingServiceStats	getAdaptiveThrottlingServiceStats()
boolean	isCurrentFollowerMaxHeartbeatLagSignalActive()
boolean	isCurrentLeaderMaxHeartbeatLagSignalActive()
boolean	isNonCurrentFollowerMaxHeartbeatLagSignalActive()
boolean	isNonCurrentLeaderMaxHeartbeatLagSignalActive()
boolean	isReadLatencySignalActive()
void	refreshSignalAndThrottler()
void	registerThrottler(VeniceAdaptiveThrottler adaptiveIngestionThrottler)
boolean	startInner()
void	stopInner()

Methods inherited from class com.linkedin.venice.service.AbstractVeniceService

close, getName, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Field Details

HEARTBEAT_LAG_LIMIT

public static final long HEARTBEAT_LAG_LIMIT

SINGLE_GET_LATENCY_P99_METRIC_NAME

public static final String SINGLE_GET_LATENCY_P99_METRIC_NAME

See Also:

• Constant Field Values

MULTI_GET_LATENCY_P99_METRIC_NAME

public static final String MULTI_GET_LATENCY_P99_METRIC_NAME

See Also:

• Constant Field Values

READ_COMPUTE_LATENCY_P99_METRIC_NAME

public static final String READ_COMPUTE_LATENCY_P99_METRIC_NAME

See Also:

• Constant Field Values

Constructor Details

AdaptiveThrottlerSignalService

public AdaptiveThrottlerSignalService(VeniceServerConfig veniceServerConfig,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 HeartbeatMonitoringService heartbeatMonitoringService)

Method Details

registerThrottler

public void registerThrottler(VeniceAdaptiveThrottler adaptiveIngestionThrottler)

getAdaptiveThrottlingServiceStats

public AdaptiveThrottlingServiceStats getAdaptiveThrottlingServiceStats()

refreshSignalAndThrottler

public void refreshSignalAndThrottler()

isReadLatencySignalActive

public boolean isReadLatencySignalActive()

isCurrentLeaderMaxHeartbeatLagSignalActive

public boolean isCurrentLeaderMaxHeartbeatLagSignalActive()

isCurrentFollowerMaxHeartbeatLagSignalActive

public boolean isCurrentFollowerMaxHeartbeatLagSignalActive()

isNonCurrentLeaderMaxHeartbeatLagSignalActive

public boolean isNonCurrentLeaderMaxHeartbeatLagSignalActive()

isNonCurrentFollowerMaxHeartbeatLagSignalActive

public boolean isNonCurrentFollowerMaxHeartbeatLagSignalActive()

startInner

public boolean startInner()
                   throws Exception

Specified by:

startInner in class AbstractVeniceService

Returns:

true if the service is completely started, false if it is still starting asynchronously (in this case, it is the implementer's responsibility to set AbstractVeniceService.serviceState to AbstractVeniceService.ServiceState.STARTED upon completion of the async work).

Throws:

Exception

stopInner

public void stopInner()
               throws Exception

Specified by:

stopInner in class AbstractVeniceService

Throws:

Exception