limiter

Documentation

Index

• type RateLimiter
  • func NewRateLimiter(limiterName string, limit int64) *RateLimiter
  • func (rt *RateLimiter) MustThrottleReconcile() bool

Types

type RateLimiter

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

RateLimiter limits reconcile callback calls

func NewRateLimiter

func NewRateLimiter(limiterName string, limit int64) *RateLimiter

NewRateLimiter returns limiter with limit per 2 seconds

func (*RateLimiter) MustThrottleReconcile

func (rt *RateLimiter) MustThrottleReconcile() bool

MustThrottleReconcile registers reconcile event and checks if it must be throttled