queue

Apr 19, 2023

Changes in this version

+ type Limits interface

+ MaxOutstandingPerTenant func(user string) int

+ type MockLimits struct

+ MaxOutstanding int

+ func (l MockLimits) MaxOutstandingPerTenant(_ string) int

Dec 2, 2022 GO-2022-1175

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

Oct 4, 2022 GO-2022-1175

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

Jul 15, 2022 GO-2022-1175

  GO-2022-1175: Exposure of local files in github.com/cortexproject/cortex

May 14, 2021

Changes in this version

type RequestQueue

+ func (q *RequestQueue) NotifyQuerierShutdown(querierID string)

Dec 29, 2020

Changes in this version

+ var ErrStopped = errors.New("queue is stopped")

+ var ErrTooManyRequests = errors.New("too many outstanding requests")

+ type Request interface

+ type RequestQueue struct

+ func NewRequestQueue(maxOutstandingPerTenant int, queueLength *prometheus.GaugeVec) *RequestQueue

+ func (q *RequestQueue) EnqueueRequest(userID string, req Request, maxQueriers int, successFn func()) error

+ func (q *RequestQueue) GetConnectedQuerierWorkersMetric() float64

+ func (q *RequestQueue) GetNextRequestForQuerier(ctx context.Context, last UserIndex, querierID string) (Request, UserIndex, error)

+ func (q *RequestQueue) QuerierDisconnecting()

+ func (q *RequestQueue) RegisterQuerierConnection(querier string)

+ func (q *RequestQueue) Stop()

+ func (q *RequestQueue) UnregisterQuerierConnection(querier string)

+ type UserIndex struct

+ func FirstUser() UserIndex

+ func (ui UserIndex) ReuseLastUser() UserIndex