throttle

Documentation

Index

• type Throttle
  • func NewThrottle(count int64, interval time.Duration) *Throttle
  • func (t Throttle) Middleware(h types.HandlerFunc) types.HandlerFunc

Types

type Throttle

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

Throttle provides a middleware that limits the amount of messages processed per unit of time. This may be done e.g. to prevent excessive load caused by running a handler on a long queue of unprocessed messages.

func NewThrottle

func NewThrottle(count int64, interval time.Duration) *Throttle

NewThrottle creates a new Throttle middleware. Example duration and count: NewThrottle(10, time.Second) for 10 messages per second

func (Throttle) Middleware

func (t Throttle) Middleware(h types.HandlerFunc) types.HandlerFunc