queue

May 2, 2024

Changes in this version

+ type Count struct

+ Concurrency int

+ RPS float64

type Counter

+ Decrease func(host string, delta int) error

+ EnsureKey func(host string, window, granularity time.Duration)

+ Increase func(host string, delta int) error

+ RemoveKey func(host string) bool

+ UpdateBuckets func(host string, window, granularity time.Duration)

type FakeCounter

+ func (f *FakeCounter) Decrease(host string, i int) error

+ func (f *FakeCounter) EnsureKey(host string, _, _ time.Duration)

+ func (f *FakeCounter) Increase(host string, i int) error

+ func (f *FakeCounter) RemoveKey(host string) bool

+ func (f *FakeCounter) UpdateBuckets(_ string, _, _ time.Duration)

type Memory

+ func (r *Memory) Decrease(host string, delta int) error

+ func (r *Memory) EnsureKey(host string, window, granularity time.Duration)

+ func (r *Memory) Increase(host string, delta int) error

+ func (r *Memory) RemoveKey(host string) bool

+ func (r *Memory) UpdateBuckets(host string, window, granularity time.Duration)

+ type RequestsBuckets struct

+ func NewRequestsBuckets(window, granularity time.Duration) *RequestsBuckets

+ func (t *RequestsBuckets) IsEmpty(now time.Time) bool

+ func (t *RequestsBuckets) Record(now time.Time, value int)

+ func (t *RequestsBuckets) WindowAverage(now time.Time) float64

Nov 16, 2021

Changes in this version

+ func AddCountsRoute(lggr logr.Logger, mux *nethttp.ServeMux, q CountReader)

+ type CountReader interface

+ Current func() (*Counts, error)

+ type Counter interface

+ Ensure func(host string)

+ Remove func(host string) bool

+ Resize func(host string, delta int) error

+ type Counts struct

+ Counts map[string]int

+ func GetCounts(ctx context.Context, lggr logr.Logger, httpCl *nethttp.Client, ...) (*Counts, error)

+ func NewCounts() *Counts

+ func (q *Counts) Aggregate() int

+ func (q *Counts) MarshalJSON() ([]byte, error)

+ func (q *Counts) String() string

+ func (q *Counts) UnmarshalJSON(data []byte) error

+ type FakeCountReader struct

+ func (f *FakeCountReader) Current() (*Counts, error)

+ type FakeCounter struct

+ ResizeTimeout time.Duration

+ ResizedCh chan HostAndCount

+ RetMap map[string]int

+ func NewFakeCounter() *FakeCounter

+ func (f *FakeCounter) Current() (*Counts, error)

+ func (f *FakeCounter) Ensure(host string)

+ func (f *FakeCounter) Remove(host string) bool

+ func (f *FakeCounter) Resize(host string, i int) error

+ type HostAndCount struct

+ Count int

+ Host string

+ type Memory struct

+ func NewMemory() *Memory

+ func (r *Memory) Current() (*Counts, error)

+ func (r *Memory) Ensure(host string)

+ func (r *Memory) Remove(host string) bool

+ func (r *Memory) Resize(host string, delta int) error