priorityqueue

Jan 21, 2026

Changes in this version

type LDAPAuthRequestQueue

+ func (q *LDAPAuthRequestQueue) PopWithContext(ctx context.Context, poolName string) *bktype.LDAPAuthRequest

type LDAPRequestQueue

+ func (q *LDAPRequestQueue) PopWithContext(ctx context.Context, poolName string) *bktype.LDAPRequest

type LuaRequestQueue

+ func (q *LuaRequestQueue) PopWithContext(ctx context.Context, backendName string) *bktype.LuaRequest

Nov 3, 2025

Changes in this version

type LDAPAuthRequestQueue

+ func (q *LDAPAuthRequestQueue) SetMaxQueueLength(poolName string, n int)

type LDAPRequestQueue

+ func (q *LDAPRequestQueue) SetMaxQueueLength(poolName string, n int)

type LuaRequestQueue

+ func (q *LuaRequestQueue) SetMaxQueueLength(backendName string, n int)

May 16, 2025

Changes in this version

+ const PriorityHigh

+ const PriorityLow

+ const PriorityMedium

+ var LDAPAuthQueue = NewLDAPAuthRequestQueue()

+ var LDAPQueue = NewLDAPRequestQueue()

+ var LuaQueue = NewLuaRequestQueue()

+ type LDAPAuthRequestItem struct

+ Index int

+ InsertTime time.Time

+ Priority int

+ Request *bktype.LDAPAuthRequest

+ type LDAPAuthRequestPriorityQueue []*LDAPAuthRequestItem

+ func (pq *LDAPAuthRequestPriorityQueue) Len() int

+ func (pq *LDAPAuthRequestPriorityQueue) Less(i, j int) bool

+ func (pq *LDAPAuthRequestPriorityQueue) Pop() any

+ func (pq *LDAPAuthRequestPriorityQueue) Push(x any)

+ func (pq *LDAPAuthRequestPriorityQueue) Swap(i, j int)

+ type LDAPAuthRequestQueue struct

+ func NewLDAPAuthRequestQueue() *LDAPAuthRequestQueue

+ func (q *LDAPAuthRequestQueue) AddPoolName(poolName string)

+ func (q *LDAPAuthRequestQueue) GetPoolNames() []string

+ func (q *LDAPAuthRequestQueue) Pop() *bktype.LDAPAuthRequest

+ func (q *LDAPAuthRequestQueue) Push(request *bktype.LDAPAuthRequest, priority int)

+ type LDAPRequestItem struct

+ Index int

+ InsertTime time.Time

+ Priority int

+ Request *bktype.LDAPRequest

+ type LDAPRequestPriorityQueue []*LDAPRequestItem

+ func (pq *LDAPRequestPriorityQueue) Len() int

+ func (pq *LDAPRequestPriorityQueue) Less(i, j int) bool

+ func (pq *LDAPRequestPriorityQueue) Pop() any

+ func (pq *LDAPRequestPriorityQueue) Push(x any)

+ func (pq *LDAPRequestPriorityQueue) Swap(i, j int)

+ type LDAPRequestQueue struct

+ func NewLDAPRequestQueue() *LDAPRequestQueue

+ func (q *LDAPRequestQueue) AddPoolName(poolName string)

+ func (q *LDAPRequestQueue) GetPoolNames() []string

+ func (q *LDAPRequestQueue) Pop() *bktype.LDAPRequest

+ func (q *LDAPRequestQueue) Push(request *bktype.LDAPRequest, priority int)

+ type LuaRequestItem struct

+ Index int

+ InsertTime time.Time

+ Priority int

+ Request *bktype.LuaRequest

+ type LuaRequestPriorityQueue []*LuaRequestItem

+ func (pq *LuaRequestPriorityQueue) Len() int

+ func (pq *LuaRequestPriorityQueue) Less(i, j int) bool

+ func (pq *LuaRequestPriorityQueue) Pop() any

+ func (pq *LuaRequestPriorityQueue) Push(x any)

+ func (pq *LuaRequestPriorityQueue) Swap(i, j int)

+ type LuaRequestQueue struct

+ func NewLuaRequestQueue() *LuaRequestQueue

+ func (q *LuaRequestQueue) AddBackendName(backendName string)

+ func (q *LuaRequestQueue) GetBackendNames() []string

+ func (q *LuaRequestQueue) Pop() *bktype.LuaRequest

+ func (q *LuaRequestQueue) Push(request *bktype.LuaRequest, priority int)