Function NewPriorityRequestQueue

pkg/scheduler/queue/user_request_queue.go:52–54

(queue *util.PriorityQueue, userID string, queueLength *prometheus.GaugeVec)

}

func NewPriorityRequestQueue(queue *util.PriorityQueue, userID string, queueLength *prometheus.GaugeVec) *PriorityRequestQueue {
	return &PriorityRequestQueue{queue: queue, userID: userID, queueLength: queueLength}
}

func (f *PriorityRequestQueue) enqueueRequest(r Request) {
	f.queue.Enqueue(r)