fairqueue

Documentation

Index

• func NewFIFOQueue() *fifoQueue
• func NewRateLimitingFairQueue(opts ...OptConfig) workqueue.RateLimitingInterface
• type Item
• type OptConfig
  • func WithIdleQueueCheckPeriod(period time.Duration) OptConfig
  • func WithQueueExpireDuration(expireDuration time.Duration) OptConfig
  • func WithRateLimiter(rateLimiter workqueue.RateLimiter) OptConfig

Functions

func NewFIFOQueue

func NewFIFOQueue() *fifoQueue

func NewRateLimitingFairQueue

func NewRateLimitingFairQueue(opts ...OptConfig) workqueue.RateLimitingInterface

Types

type Item

type Item interface {
	GroupName() string
}

type OptConfig

type OptConfig func(*option)

func WithIdleQueueCheckPeriod

func WithIdleQueueCheckPeriod(period time.Duration) OptConfig

WithIdleQueueCheckPeriod update the idle queue check period.

func WithQueueExpireDuration

func WithQueueExpireDuration(expireDuration time.Duration) OptConfig

WithQueueExpireDuration update the queue expire duration.

func WithRateLimiter

func WithRateLimiter(rateLimiter workqueue.RateLimiter) OptConfig

WithRateLimiter update the rate limiter.