Package com.linkedin.venice.meta

Class RetryManager

java.lang.Object

com.linkedin.venice.meta.RetryManager

public class RetryManager
extends Object

Constructor Summary

Constructors

Constructor	Description
RetryManager(io.tehuti.metrics.MetricsRepository metricsRepository, String metricNamePrefix, long enforcementWindowInMs, double retryBudgetInPercentDecimal, ScheduledExecutorService scheduler, String storeName, RequestType requestType)
RetryManager(io.tehuti.metrics.MetricsRepository metricsRepository, String metricNamePrefix, String storeName, RequestType requestType, long enforcementWindowInMs, double retryBudgetInPercentDecimal, Clock clock, ScheduledExecutorService scheduler)

Method Summary

Modifier and Type	Method	Description
TokenBucket	getRetryTokenBucket()
boolean	isRetryAllowed()
boolean	isRetryAllowed(int numberOfRetries)
void	recordRequest()
void	recordRequests(int requests)

Methods inherited from class java.lang.Object

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

Constructor Details

RetryManager

public RetryManager(io.tehuti.metrics.MetricsRepository metricsRepository,
 String metricNamePrefix,
 String storeName,
 RequestType requestType,
 long enforcementWindowInMs,
 double retryBudgetInPercentDecimal,
 Clock clock,
 ScheduledExecutorService scheduler)

RetryManager

public RetryManager(io.tehuti.metrics.MetricsRepository metricsRepository,
 String metricNamePrefix,
 long enforcementWindowInMs,
 double retryBudgetInPercentDecimal,
 ScheduledExecutorService scheduler,
 String storeName,
 RequestType requestType)

Method Details

recordRequest

public void recordRequest()

recordRequests

public void recordRequests(int requests)

isRetryAllowed

public boolean isRetryAllowed()

isRetryAllowed

public boolean isRetryAllowed(int numberOfRetries)

getRetryTokenBucket

public TokenBucket getRetryTokenBucket()