com.netflix.concurrency.limits.limit

Class AbstractLimit

java.lang.Object

com.netflix.concurrency.limits.limit.AbstractLimit

All Implemented Interfaces:

Limit

Direct Known Subclasses:

AIMDLimit, FixedLimit, Gradient2Limit, GradientLimit, SettableLimit, VegasLimit

public abstract class AbstractLimit
extends java.lang.Object
implements Limit

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractLimit(int initialLimit)

Method Summary

Modifier and Type	Method and Description
protected abstract int	_update(long startTime, long rtt, int inflight, boolean didDrop)
int	getLimit()
void	notifyOnChange(java.util.function.Consumer<java.lang.Integer> consumer) Register a callback to receive notification whenever the limit is updated to a new value
void	onSample(long startTime, long rtt, int inflight, boolean didDrop) Update the limiter with a sample
protected void	setLimit(int newLimit)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractLimit

protected AbstractLimit(int initialLimit)

Method Detail

onSample

public final void onSample(long startTime,
                           long rtt,
                           int inflight,
                           boolean didDrop)

Description copied from interface: Limit

Update the limiter with a sample

Specified by:

onSample in interface Limit

_update

protected abstract int _update(long startTime,
                               long rtt,
                               int inflight,
                               boolean didDrop)

getLimit

public final int getLimit()

Specified by:

getLimit in interface Limit

Returns:

Current estimated limit

setLimit

protected void setLimit(int newLimit)

notifyOnChange

public void notifyOnChange(java.util.function.Consumer<java.lang.Integer> consumer)

Description copied from interface: Limit

Register a callback to receive notification whenever the limit is updated to a new value

Specified by:

notifyOnChange in interface Limit