Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

core

package

Go to main page

Versions in this module

v0

v0.5.10

Aug 17, 2021

v0.5.8

Aug 17, 2021

v0.1.7

May 19, 2019

v0.1.6

May 18, 2019

v0.1.5

May 14, 2019

v0.1.4

Apr 4, 2019

v0.1.3

Dec 1, 2018

v0.1.2

Dec 1, 2018

v0.1.1

Nov 24, 2018

v0.1.0

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

v0.1.0-rc2

Oct 4, 2018

v0.1.0-rc1

Sep 30, 2018