Function NewFIFORequestQueue

pkg/scheduler/queue/user_request_queue.go:23–25

(queue chan Request, userID string, queueLength *prometheus.GaugeVec)

}

func NewFIFORequestQueue(queue chan Request, userID string, queueLength *prometheus.GaugeVec) *FIFORequestQueue {
	return &FIFORequestQueue{queue: queue, userID: userID, queueLength: queueLength}
}

func (f *FIFORequestQueue) enqueueRequest(r Request) {
	f.queue <- r