rate

package module

v1.0.1 Latest Latest Go to latest Published: Jan 31, 2024 License: MIT Imports: 3 Imported by: 1

Details

Because I found out that 99% of the CPU consumed was golang.org/x/time/rate.Limiter.Wait() calling time.Now().

This section is empty.

This section is empty.

func NewTicker(ctx context.Context, rate *int32) <-chan struct{}

NewTicker returns a channel that sends a `struct{}{}` at most `*rate` times per second.

A nil `rate` or a `*rate` of zero or less sends as quickly as possible.

The channel is closed when the context is done.

type Limiter struct {
	// contains filtered or unexported fields
}

Limiter provides efficient rate limiting. The zero value is immediately usable.

A Limiter is not safe to use from multiple goroutines simultaneously.

func (rl *Limiter) Wait(rate *int32)

Wait sleeps at least long enough to ensure that the given `*rate` of events per second is not exceeded.

A nil `rate` or a `*rate` of zero or less doesn't wait at all.