com.netflix.concurrency.limits

Interface Limit

All Known Implementing Classes:

AbstractLimit, AIMDLimit, FixedLimit, Gradient2Limit, GradientLimit, SettableLimit, TracingLimitDecorator, VegasLimit, WindowedLimit

public interface Limit

Contract for an algorithm that calculates a concurrency limit based on rtt measurements

Method Summary

Modifier and Type	Method and Description
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

Method Detail

getLimit

int getLimit()

Returns:

Current estimated limit

notifyOnChange

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

Parameters:

consumer -

onSample

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

Update the limiter with a sample

Parameters:

startTime -

rtt -

inflight -

didDrop -