Package com.amazonaws.xray.strategy.sampling.reservoir

Class CentralizedReservoir

java.lang.Object

com.amazonaws.xray.strategy.sampling.reservoir.CentralizedReservoir

public class CentralizedReservoir
extends Object

Constructor Summary

Constructors

Constructor	Description
CentralizedReservoir(long capacity)

Method Summary

Modifier and Type	Method	Description
long	getCurrentEpoch()
long	getInterval()
long	getQuota()
long	getUsed()
boolean	isBorrow(Instant now)
boolean	isExpired(Instant now)
boolean	isStale(Instant now)
boolean	take(Instant now)
void	update(com.amazonaws.services.xray.model.SamplingRule r)
void	update(com.amazonaws.services.xray.model.SamplingTargetDocument target, Instant now)

Methods inherited from class java.lang.Object

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

Constructor Details

CentralizedReservoir

public CentralizedReservoir(long capacity)

Method Details

update

public void update(com.amazonaws.services.xray.model.SamplingRule r)

isExpired

public boolean isExpired(Instant now)

isBorrow

public boolean isBorrow(Instant now)

isStale

public boolean isStale(Instant now)

update

public void update(com.amazonaws.services.xray.model.SamplingTargetDocument target,
 Instant now)

take

public boolean take(Instant now)

getQuota

public long getQuota()

getUsed

public long getUsed()

getCurrentEpoch

public long getCurrentEpoch()

getInterval

public long getInterval()