fairqueue

Documentation

Index

• func NewRateLimitingFairQueue(opts ...OptConfig) workqueue.RateLimitingInterface
• type FifoQueue
  • func NewFifoQueue() *FifoQueue
  • func (q *FifoQueue) Add(item interface{})
  • func (q *FifoQueue) Get() (item interface{}, empty bool)
  • func (q *FifoQueue) LastActiveTime() time.Time
  • func (q *FifoQueue) Len() int
• type Item
• type OptConfig
  • func WithIdleQueueCheckPeriod(period time.Duration) OptConfig
  • func WithQueueExpireDuration(expireDuration time.Duration) OptConfig
  • func WithRateLimiter(rateLimiter workqueue.RateLimiter) OptConfig

Functions

func NewRateLimitingFairQueue

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

Types

type FifoQueue

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

func NewFifoQueue

func NewFifoQueue() *FifoQueue

func (*FifoQueue) Add

func (q *FifoQueue) Add(item interface{})

func (*FifoQueue) Get

func (q *FifoQueue) Get() (item interface{}, empty bool)

Get pop the queue head. indicate whether the queue is empty.

func (*FifoQueue) LastActiveTime

func (q *FifoQueue) LastActiveTime() time.Time

func (*FifoQueue) Len

func (q *FifoQueue) Len() int

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.