NewAcquiredStrategyToken will create a new acquired strategy token.

NewCommonMetricSampler will create a new CommonMetricSampler that will auto-instrument metrics.

NewCommonMetricSamplerOrNil will only create a new CommonMetricSampler if a valid registry is supplied.

NewFloat64MetricSupplierWrapper will wrap a float64-return value func to a supplier func.

NewIntMetricSupplierWrapper will wrap a int-return value func to a supplier func.

NewNotAcquiredStrategyToken will create a new un-acquired strategy token.

NewUint64MetricSupplierWrapper will wrap a uint64-return value func to a supplier func.

PrefixMetricWithName will prefix a given name with the metric name in the form "<name>.<metric>".

MetricDropped is the name of the metric for dropped counts.

MetricInFlight is the name of the metric for current in flight count.

MetricLimit is the name of the metric for current limit.

MetricMinRTT is the name of the metric for the Minimum Round Trip Time.

MetricPartitionLimit is the name of the metric for a current partition's limit.

MetricQueueLimit represents the name of the metric for the max size of a lifo queue.

MetricQueueSize represents the name of the metric for the size of a lifo queue.

MetricRTT is the name of the metric for the sample Round Trip Time distribution.

MetricWindowMinRTT is the name of the metric for the Window's Minimum Round Trip Time.

MetricWindowQueueSize represents the name of the metric for the Window's Queue Size.

EmptyMetricRegistryInstance is a singleton empty metric registry instance.

CommonMetricSampler is a set of common metrics reported by all Limit implementations.

EmptyMetricRegistry implements a void reporting metric registry.

EmptyMetricSampleListener implements a sample listener that ignores everything.

StaticStrategyToken represents a static strategy token, simple but flexible.

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

Limiter defines the contract for a concurrency limiter.

LimiterRegistry lookup for integrations that support multiple Limiters, i.e.

Listener implements token listener for callback to the limiter when and how it should be released.

MeasurementInterface defines the contract for tracking a measurement such as a minimum or average of a sample set.

MetricRegistry is a simple abstraction for tracking metrics in the limiters.

MetricSampleListener is a listener to receive samples for a distribution.

SampleWindow represents the details of the current sample window.

Strategy defines how the limiter logic should acquire or not acquire tokens.

StrategyToken represents a token from a limiter algorithm.

LimitChangeListener is a callback method to receive a notification whenever the limit is updated to a new value.

MetricSupplier will return the supplied metric value.