core

Dec 28, 2021

Changes in this version

+ const MetricQueueLimit

+ const MetricQueueSize

Dec 27, 2021

Changes in this version

type MetricSupplier

+ func NewUint64MetricSupplierWrapper(s func() uint64) MetricSupplier

Nov 2, 2021

Changes in this version

+ const MetricLifoQueueLimit

+ const MetricLifoQueueSize

Oct 5, 2018

Changes in this version

+ const MetricDropped

+ const MetricInFlight

+ const MetricLimit

+ const MetricMinRTT

+ const MetricPartitionLimit

+ const MetricRTT

+ const MetricWindowMinRTT

+ const MetricWindowQueueSize

+ var EmptyMetricRegistryInstance = &EmptyMetricRegistry

+ func PrefixMetricWithName(metric, name string) string

+ type CommonMetricSampler struct

+ DropCounterListener MetricSampleListener

+ InFlightListener MetricSampleListener

+ RTTListener MetricSampleListener

+ func NewCommonMetricSampler(registry MetricRegistry, limit Limit, name string, tags ...string) *CommonMetricSampler

+ func (s *CommonMetricSampler) Sample(rtt int64, inFlight int, didDrop bool)

+ type EmptyMetricRegistry struct

+ func (*EmptyMetricRegistry) RegisterCount(ID string, tags ...string) MetricSampleListener

+ func (*EmptyMetricRegistry) RegisterDistribution(ID string, tags ...string) MetricSampleListener

+ func (*EmptyMetricRegistry) RegisterGauge(ID string, supplier MetricSupplier, tags ...string)

+ func (*EmptyMetricRegistry) RegisterTiming(ID string, tags ...string) MetricSampleListener

+ func (*EmptyMetricRegistry) Start()

+ func (*EmptyMetricRegistry) Stop()

+ type EmptyMetricSampleListener struct

+ func (*EmptyMetricSampleListener) AddSample(value float64, tags ...string)

+ type Limit interface

+ EstimatedLimit func() int

+ NotifyOnChange func(consumer LimitChangeListener)

+ OnSample func(startTime int64, rtt int64, inFlight int, didDrop bool)

+ type LimitChangeListener func(limit int)

+ type Limiter interface

+ Acquire func(ctx context.Context) (listener Listener, ok bool)

+ type LimiterRegistry interface

+ Get func(key string) Limiter

+ type Listener interface

+ OnDropped func()

+ OnIgnore func()

+ OnSuccess func()

+ type MeasurementInterface interface

+ Add func(value float64) (float64, bool)

+ Get func() float64

+ Reset func()

+ Update func(operation func(value float64) float64)

+ type MetricRegistry interface

+ RegisterCount func(ID string, tags ...string) MetricSampleListener

+ RegisterDistribution func(ID string, tags ...string) MetricSampleListener

+ RegisterGauge func(ID string, supplier MetricSupplier, tags ...string)

+ RegisterTiming func(ID string, tags ...string) MetricSampleListener

+ Start func()

+ Stop func()

+ type MetricSampleListener interface

+ AddSample func(value float64, tags ...string)

+ type MetricSupplier func() (value float64, ok bool)

+ func NewFloat64MetricSupplierWrapper(s func() float64) MetricSupplier

+ func NewIntMetricSupplierWrapper(s func() int) MetricSupplier

+ type SampleWindow interface

+ AverageRTTNanoseconds func() int64

+ CandidateRTTNanoseconds func() int64

+ DidDrop func() bool

+ MaxInFlight func() int

+ SampleCount func() int

+ StartTimeNanoseconds func() int64

+ type StaticStrategyToken struct

+ func (t *StaticStrategyToken) InFlightCount() int

+ func (t *StaticStrategyToken) IsAcquired() bool

+ func (t *StaticStrategyToken) Release()

+ type Strategy interface

+ SetLimit func(limit int)

+ TryAcquire func(ctx context.Context) (token StrategyToken, ok bool)

+ type StrategyToken interface

+ InFlightCount func() int

+ IsAcquired func() bool

+ Release func()

+ func NewAcquiredStrategyToken(inFlightCount int, releaseFunc func()) StrategyToken

+ func NewNotAcquiredStrategyToken(inFlightCount int) StrategyToken