Configuration.throttleMessageRate()
Description
Appends a throttleMessageRate filter to the current pipeline layout.
A throttleMessageRate filter limits the number of Messages passing through per unit of time.
- INPUT - Any types of Events.
- OUTPUT - Same Events as the input.
This filter passes down everything unaltered. It doesn't change anything in the event stream. It only delays them.
Syntax
pipy().pipeline().throttleMessageRate(new algo.Quota(quota, { per }))pipy().pipeline().throttleMessageRate(() => getQuota())
Parameters
throttleMessageRate(quota)
quota
A Quota object or a function returns it.
Return Value
The same Configuration object.