com.netflix.concurrency.limits.limit

Class TracingLimitDecorator

java.lang.Object

com.netflix.concurrency.limits.limit.TracingLimitDecorator

All Implemented Interfaces:

Limit

public class TracingLimitDecorator
extends java.lang.Object
implements Limit

Constructor Summary

Constructors

Constructor and Description
TracingLimitDecorator(Limit delegate)

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
static TracingLimitDecorator	wrap(Limit delegate)

Methods inherited from class java.lang.Object

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

Constructor Detail

TracingLimitDecorator

public TracingLimitDecorator(Limit delegate)

Method Detail

wrap

public static TracingLimitDecorator wrap(Limit delegate)

getLimit

public int getLimit()

Specified by:

getLimit in interface Limit

Returns:

Current estimated limit

onSample

public 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

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