consumer/limiter.go (
2
lines of code) (
raw
):
package consumer type Limiter func(topic string)