Go queue v1.7.0: a new Delay queue for timers, retries, and TTLs

I just tagged v1.7.0 of github.com/adrianbrad/queue , a thread-safe generic queue package. The headline feature is a new Delay queue. What is Delay? Delay is a priority queue where each element becomes dequeuable at a deadline computed by a caller-supplied function at Offer time. Get returns ErrNoElementsAvailable until the head is due; GetWait sleeps until it is. type task struct { id int runAt time . Time } delayQueue := queue . NewDelay ( [] task { { id : 1 , runAt : time . Now () . Add ( 20