workqueue

package module

Go to main page

Versions in this module

v2

v2.2.4

Jul 12, 2024

v2.2.3

Jul 10, 2024

Changes in this version

+ const PRIORITY_FASTEST

+ const PRIORITY_HIGH

+ const PRIORITY_LOW

+ const PRIORITY_NORMAL

+ const PRIORITY_SLOWEST

+ type NewSetFunc = func() Set

type QueueConfig

+ func (c *QueueConfig) WithSetCreator(fn NewSetFunc) *QueueConfig

+ type Set = interface

+ Add func(item interface{})

+ Cleanup func()

+ Contains func(item interface{}) bool

+ Len func() int

+ List func() []interface{}

+ Remove func(item interface{})

v2.2.2

Jul 7, 2024

v2.2.1

Jul 7, 2024

Changes in this version

+ type NewSetContainer = func() SetContainer

type QueueConfig

+ func (c *QueueConfig) WithSetContainerCreator(fn NewSetContainer) *QueueConfig

+ type SetContainer = interface

+ Add func(item interface{})

+ Cleanup func()

+ Contains func(item interface{}) bool

+ Len func() int

+ List func() []interface{}

+ Remove func(item interface{})

v2.2.0

Jul 7, 2024

Changes in this version

+ func DelayTo(duration int64) int64

type PriorityQueue

+ HeapRange func(fn func(value interface{}, priority int64) bool)

v2.1.3

Jun 5, 2024

v2.1.2

Jun 4, 2024

Changes in this version

type DelayingQueue

+ HeapRange func(fn func(value interface{}, delay int64) bool)

type Queue

+ Range func(fn func(value interface{}) bool)

v2.1.1

Jun 3, 2024

v2.1.0

May 29, 2024

Changes in this version

+ const MINI_PRIORITY

+ var ErrElementAlreadyExist = errors.New("element already exist")

+ var ErrElementIsNil = errors.New("element is nil")

+ var ErrQueueIsClosed = errors.New("queue is shutting down")

+ var ErrQueueIsEmpty = errors.New("queue is empty")

+ type BucketRateLimiterImpl struct

+ func (rl *BucketRateLimiterImpl) When(interface{}) time.Duration

+ type DelayingQueue interface

+ PutWithDelay func(interface{}, int64) error

+ func NewDelayingQueue(config *DelayingQueueConfig) DelayingQueue

+ type DelayingQueueCallback interface

+ OnDelay func(interface{}, int64)

+ OnPullError func(interface{}, error)

+ type DelayingQueueCallbackImpl struct

+ func NewNopDelayingQueueCallbackImpl() *DelayingQueueCallbackImpl

+ func (impl *DelayingQueueCallbackImpl) OnDelay(interface{}, int64)

+ func (impl *DelayingQueueCallbackImpl) OnPullError(interface{}, error)

+ type DelayingQueueConfig struct

+ func NewDelayingQueueConfig() *DelayingQueueConfig

+ func (c *DelayingQueueConfig) WithCallback(cb DelayingQueueCallback) *DelayingQueueConfig

+ type DelayingQueueImpl struct

+ func (q *DelayingQueueImpl) PutWithDelay(value interface{}, delay int64) error

+ func (q *DelayingQueueImpl) Shutdown()

+ type Limiter interface

+ When func(interface{}) time.Duration

+ func NewBucketRateLimiterImpl(r float64, burst int64) Limiter

+ func NewNopRateLimiterImpl() Limiter

+ type NopRateLimiterImpl struct

+ func (rl *NopRateLimiterImpl) When(interface{}) time.Duration

+ type PriorityQueue interface

+ PutWithPriority func(interface{}, int64) error

+ func NewPriorityQueue(config *PriorityQueueConfig) PriorityQueue

+ type PriorityQueueCallback interface

+ OnPriority func(interface{}, int64)

+ type PriorityQueueCallbackImpl struct

+ func NewNopPriorityQueueCallbackImpl() *PriorityQueueCallbackImpl

+ func (impl *PriorityQueueCallbackImpl) OnPriority(interface{}, int64)

+ type PriorityQueueConfig struct

+ func NewPriorityQueueConfig() *PriorityQueueConfig

+ func (c *PriorityQueueConfig) WithCallback(cb PriorityQueueCallback) *PriorityQueueConfig

+ type PriorityQueueImpl struct

+ func (q *PriorityQueueImpl) Put(value interface{}) error

+ func (q *PriorityQueueImpl) PutWithPriority(value interface{}, priority int64) error

+ func (q *PriorityQueueImpl) Shutdown()

+ type Queue interface

+ Done func(interface{})

+ Get func() (interface{}, error)

+ IsClosed func() bool

+ Len func() int

+ Put func(interface{}) error

+ Shutdown func()

+ Values func() []interface{}

+ func NewQueue(config *QueueConfig) Queue

+ type QueueCallback interface

+ OnDone func(interface{})

+ OnGet func(interface{})

+ OnPut func(interface{})

+ type QueueCallbackImpl struct

+ func NewNopQueueCallbackImpl() *QueueCallbackImpl

+ func (impl *QueueCallbackImpl) OnDone(interface{})

+ func (impl *QueueCallbackImpl) OnGet(interface{})

+ func (impl *QueueCallbackImpl) OnPut(interface{})

+ type QueueConfig struct

+ func NewQueueConfig() *QueueConfig

+ func (c *QueueConfig) WithCallback(cb QueueCallback) *QueueConfig

+ func (c *QueueConfig) WithValueIdempotent() *QueueConfig

+ type QueueImpl struct

+ func (q *QueueImpl) Done(value interface{})

+ func (q *QueueImpl) Get() (interface{}, error)

+ func (q *QueueImpl) IsClosed() bool

+ func (q *QueueImpl) Len() int

+ func (q *QueueImpl) Put(value interface{}) error

+ func (q *QueueImpl) Shutdown()

+ func (q *QueueImpl) Values() []interface{}

+ type RateLimitingQueue interface

+ PutWithLimited func(interface{}) error

+ func NewRateLimitingQueue(config *RateLimitingQueueConfig) RateLimitingQueue

+ type RateLimitingQueueCallback interface

+ OnLimited func(interface{})

+ type RateLimitingQueueCallbackImpl struct

+ func NewNopRateLimitingQueueCallbackImpl() *RateLimitingQueueCallbackImpl

+ func (impl *RateLimitingQueueCallbackImpl) OnLimited(interface{})

+ type RateLimitingQueueConfig struct

+ func NewRateLimitingQueueConfig() *RateLimitingQueueConfig

+ func (c *RateLimitingQueueConfig) WithCallback(cb RateLimitingQueueCallback) *RateLimitingQueueConfig

+ func (c *RateLimitingQueueConfig) WithLimiter(limiter Limiter) *RateLimitingQueueConfig

+ type RateLimitingQueueImpl struct

+ func (q *RateLimitingQueueImpl) PutWithLimited(value interface{}) error

+ func (q *RateLimitingQueueImpl) Shutdown()

Other modules containing this package

github.com/shengyanli1982/workqueue

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL