Code

Rate limit processor#22883

Code

Merged

ycombinator merged 53 commits intoelastic:masterelastic/beats:masterfrom ycombinator:lb-processor-rate-limitycombinator/beats:lb-processor-rate-limitCopy head branch name to clipboardDec 12, 2020

+969

Commits

Commits on Dec 11, 2020

• Implement basic scaffolding for rate_limit processor

  ycombinator

  committed
  b4c068c

• Fixing import cycle

  ycombinator

  committed
  2400b67

• Adding skeleton for token bucket algo

  ycombinator

  committed
  b9028cd

• Set default algorithm in default config

  ycombinator

  committed
  dce6dae

• Using an algo constructor

  ycombinator

  committed
  ca41a82

• Implement token bucket rate limiting algorithm

  ycombinator

  committed
  fb960e5

• Resolving some TODOs

  ycombinator

  committed
  80a37f8

• Adding license header

  ycombinator

  committed
  8b550d3

• Removing old TODO comment

  ycombinator

  committed
  bff5ee7

• Adding tests

  ycombinator

  committed
  752ff9c

• Reverting to previous logic

  ycombinator

  committed
  028b67a

• Adding CHANGELOG entry

  ycombinator

  committed
  d08d9a6

• Adding TODOs for more tests

  ycombinator

  committed
  0a6b0cd

• Fixing comment

  ycombinator

  committed
  c9852c9

• Fixing error messages

  ycombinator

  committed
  1fb20e3

• Fixing comment

  ycombinator

  committed
  8e8a204

• Fleshing out godoc comments

  ycombinator

  committed
  dfc5907

• Fixing logger location

  ycombinator

  committed
  fa63dbb

• Fixing up docs a bit

  ycombinator

  committed
  189a170

• Adding test for "fields" config

  ycombinator

  committed
  1e0c6ec

• WIP: adding test for burst multiplier

  ycombinator

  committed
  8639e3b

• Return pointer to bucket from getBucket

  ycombinator

  committed
  a9faa7e

• Keep pointers to buckets in map to avoid map reassignment

  ycombinator

  committed
  193cb1f

• Fix test

  ycombinator

  committed
  7597c67

• Fix logic as we cannot allow withdrawal of fractional (<1) tokens

  ycombinator

  committed
  f918076

• Move burst multiplier default to token_bucket algo

  ycombinator

  committed
  ae35015

• Implementing GC

  ycombinator

  committed
  1a17229

• Making the factory take the algo config and return the algo

  ycombinator

  committed
  44c31e4

• Reduce nesting level

  ycombinator

  committed
  c3be265

• Use mitchellh/hashstructure

  ycombinator

  committed
  56e4731

• Using sync.Map

  ycombinator

  committed
  ae8874b

• Removing algorithm and algorithm options from documentation

  ycombinator

  committed
  900019c

• Mocking clock

  ycombinator

  committed
  58124f5

• Adding license headers

  ycombinator

  committed
  eb81d13

• Using atomic.Uints for metrics counters

  ycombinator

  committed
  742ed41

• Fixing logic

  ycombinator

  committed
  b4990a0

• Use github.com/jonboulle/clockwork

  ycombinator

  committed
  40e1382

• Running make update

  ycombinator

  committed
  a220fbf

• Add mutex to prevent only one GC thread from running at any time

  ycombinator

  committed
  4b53054

• Adding logging

  ycombinator

  committed
  c36b186

• Remove NumBuckets GC threshold

  ycombinator

  committed
  c89ecca

• Use non-blocking mutex

  ycombinator

  committed
  425b03a

• Perform actual GC in own goroutine

  ycombinator

  committed
  e10a73d

• Running mage fmt

  ycombinator

  committed
  91493ba

• Fixing processor name

  ycombinator

  committed
  c957161

• Importing rate limit processor

  ycombinator

  committed
  3f4b800

• Initialize mutex

  ycombinator

  committed
  84c4f74

• Do not register as a JS processor

  ycombinator

  committed
  ac6343b

• Remove unused field

  ycombinator

  committed
  00251a8

• Mark processor as beta

  ycombinator

  committed
  a3ce476

• Renaming package

  ycombinator

  committed
  5125748

• Flatenning package hierarchy

  ycombinator

  committed
  0ffcd7d

• Remove SetClock from algorithm interface

  ycombinator

  committed
  2b92955