priorityqueue

Jan 23, 2025

Changes in this version

type Opts

+ Log logr.Logger

Jan 16, 2025

Changes in this version

+ type AddOpts struct

+ After time.Duration

+ Priority int

+ RateLimited bool

+ type Opt func(*Opts[T])

+ type Opts struct

+ MetricProvider workqueue.MetricsProvider

+ RateLimiter workqueue.TypedRateLimiter[T]

+ type PriorityQueue interface

+ AddWithOpts func(o AddOpts, Items ...T)

+ GetWithPriority func() (item T, priority int, shutdown bool)

+ func New[T comparable](name string, o ...Opt[T]) PriorityQueue[T]