ratelimit

type Limiter ¶

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

Limiter implements a simple token-bucket rate limiter. Tokens are replenished over time.

func NewLimiter(rate float64) *Limiter

func (l *Limiter) Wait(n int)

type Writer ¶

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

func NewWriter(w io.Writer, l *Limiter) *Writer

func (rw *Writer) Write(p []byte) (int, error)