ratelimit

Documentation

Index

• type Info
• type InfoEvent
• type RateLimiter
  • func NewRateLimiter(ctx context.Context, interval time.Duration, numEvents int, ...) *RateLimiter
  • func (r *RateLimiter) Drop()

Types

type Info

type Info struct {
	NumberOfDroppedProcessEvents uint64 `json:"number_of_dropped_process_events"`
}

type InfoEvent

type InfoEvent struct {
	RateLimitInfo *Info     `json:"rate_limit_info"`
	NodeName      string    `json:"node_name"`
	Time          time.Time `json:"time"`
}

type RateLimiter

type RateLimiter struct {
	*rate.Limiter
	// contains filtered or unexported fields
}

func NewRateLimiter

func NewRateLimiter(ctx context.Context, interval time.Duration, numEvents int, encoder *json.Encoder) *RateLimiter

func (*RateLimiter) Drop

func (r *RateLimiter) Drop()