Add periodic/Doer for frequency-limited action execution

[AndersonQ]

What does this PR do?

Add periodic/Doer for frequency-limited action execution

Why is it important?

The Doer limits the execution of an action to at most once within a specified period. It's designed for managing frequent events by providing a summary with the number of occurrences within the given period. If no event happen, the action is not executed.

Checklist

• My code follows the style guidelines of this project
• I have commented my code, particularly in hard-to-understand areas
• I have added tests that prove my fix is effective or that my feature works

Related issues

• Relates Rate limit "Cannot index event" log messages beats#40157

[cmacknz]

Why not use https://pkg.go.dev/golang.org/x/time/rate or even https://github.com/elastic/beats/tree/main/libbeat/processors/ratelimit

[cmacknz]

There is a custom implementation of the token bucket algorithm in https://github.com/elastic/beats/blob/main/libbeat/processors/ratelimit/token_bucket.go but I'd honestly prefer we replace that the one in x/time/rate as well.

[AndersonQ]

well apart from the fact I missed there is a [Every](https://pkg.go.dev/golang.org/x/time/rate#Every), the work to accumulate the number of events to then log the summary would be the same. Also using the ticker it's a rather straight forward implementation. Thus I don't find it necessary to use https://pkg.go.dev/golang.org/x/time/rate

[pierrehilbert]

@AndersonQ shouldn't we also change the PR title?

[AndersonQ]

@AndersonQ shouldn't we also change the PR title?

I did, but didn't click on 'save' ahah. Now it's fixed, thanks

[rdner]

Not thread-safe.

[elasticmachine]

💚 Build Succeeded

• Buildkite Build
• Commit: d450933

History

• 💚 Build #359 succeeded 456505c
• 💚 Build #356 succeeded 80e14fe
• 💚 Build #355 succeeded e391dbc
• 💔 Build #353 failed b4dcc44
• 💔 Build #352 failed 010244f
• 💔 Build #351 failed 0e24ee6

cc @AndersonQ