Versions in this module Expand all Collapse all v11 v11.0.0 Mar 13, 2019 Changes in this version + func Parallelize(workers, pieces int, doWorkPiece DoWorkPieceFunc) + func ParallelizeUntil(ctx context.Context, workers, pieces int, doWorkPiece DoWorkPieceFunc) + func SetProvider(metricsProvider MetricsProvider) + type BucketRateLimiter struct + func (r *BucketRateLimiter) Forget(item interface{}) + func (r *BucketRateLimiter) NumRequeues(item interface{}) int + func (r *BucketRateLimiter) When(item interface{}) time.Duration + type CounterMetric interface + Inc func() + type DelayingInterface interface + AddAfter func(item interface{}, duration time.Duration) + func NewDelayingQueue() DelayingInterface + func NewNamedDelayingQueue(name string) DelayingInterface + type DoWorkPieceFunc func(piece int) + type GaugeMetric interface + Dec func() + Inc func() + type HistogramMetric interface + Observe func(float64) + type Interface interface + Add func(item interface{}) + Done func(item interface{}) + Get func() (item interface{}, shutdown bool) + Len func() int + ShutDown func() + ShuttingDown func() bool + type ItemExponentialFailureRateLimiter struct + func (r *ItemExponentialFailureRateLimiter) Forget(item interface{}) + func (r *ItemExponentialFailureRateLimiter) NumRequeues(item interface{}) int + func (r *ItemExponentialFailureRateLimiter) When(item interface{}) time.Duration + type ItemFastSlowRateLimiter struct + func (r *ItemFastSlowRateLimiter) Forget(item interface{}) + func (r *ItemFastSlowRateLimiter) NumRequeues(item interface{}) int + func (r *ItemFastSlowRateLimiter) When(item interface{}) time.Duration + type MaxOfRateLimiter struct + func (r *MaxOfRateLimiter) Forget(item interface{}) + func (r *MaxOfRateLimiter) NumRequeues(item interface{}) int + func (r *MaxOfRateLimiter) When(item interface{}) time.Duration + type MetricsProvider interface + NewAddsMetric func(name string) CounterMetric + NewDeprecatedAddsMetric func(name string) CounterMetric + NewDeprecatedDepthMetric func(name string) GaugeMetric + NewDeprecatedLatencyMetric func(name string) SummaryMetric + NewDeprecatedLongestRunningProcessorMicrosecondsMetric func(name string) SettableGaugeMetric + NewDeprecatedRetriesMetric func(name string) CounterMetric + NewDeprecatedUnfinishedWorkSecondsMetric func(name string) SettableGaugeMetric + NewDeprecatedWorkDurationMetric func(name string) SummaryMetric + NewDepthMetric func(name string) GaugeMetric + NewLatencyMetric func(name string) HistogramMetric + NewLongestRunningProcessorSecondsMetric func(name string) SettableGaugeMetric + NewRetriesMetric func(name string) CounterMetric + NewUnfinishedWorkSecondsMetric func(name string) SettableGaugeMetric + NewWorkDurationMetric func(name string) HistogramMetric + type RateLimiter interface + Forget func(item interface{}) + NumRequeues func(item interface{}) int + When func(item interface{}) time.Duration + func DefaultControllerRateLimiter() RateLimiter + func DefaultItemBasedRateLimiter() RateLimiter + func NewItemExponentialFailureRateLimiter(baseDelay time.Duration, maxDelay time.Duration) RateLimiter + func NewItemFastSlowRateLimiter(fastDelay, slowDelay time.Duration, maxFastAttempts int) RateLimiter + func NewMaxOfRateLimiter(limiters ...RateLimiter) RateLimiter + type RateLimitingInterface interface + AddRateLimited func(item interface{}) + Forget func(item interface{}) + NumRequeues func(item interface{}) int + func NewNamedRateLimitingQueue(rateLimiter RateLimiter, name string) RateLimitingInterface + func NewRateLimitingQueue(rateLimiter RateLimiter) RateLimitingInterface + type SettableGaugeMetric interface + Set func(float64) + type SummaryMetric interface + Observe func(float64) + type Type struct + func New() *Type + func NewNamed(name string) *Type + func (q *Type) Add(item interface{}) + func (q *Type) Done(item interface{}) + func (q *Type) Get() (item interface{}, shutdown bool) + func (q *Type) Len() int + func (q *Type) ShutDown() + func (q *Type) ShuttingDown() bool
Go to main page