diff pkg/imports/queue.go @ 5584:7ed9e32706d0 surveysperbottleneckid

Merged delault
author Sascha Wilde <wilde@sha-bang.de>
date Fri, 01 Apr 2022 16:47:53 +0200
parents aaa9e658cabd
children 1222b777f51f
line wrap: on
line diff
--- a/pkg/imports/queue.go	Mon Feb 14 12:06:48 2022 +0100
+++ b/pkg/imports/queue.go	Fri Apr 01 16:47:53 2022 +0200
@@ -731,6 +731,16 @@
 	return iqueue.decideImport(ctx, id, accepted, reviewer)
 }
 
+func (q *importQueue) All(fn func(JobKind, JobCreator)) {
+	q.creatorsMu.Lock()
+	defer q.creatorsMu.Unlock()
+	for k, v := range q.creators {
+		fn(k, v)
+	}
+}
+
+func All(fn func(JobKind, JobCreator)) { iqueue.All(fn) }
+
 type logFeedback int64
 
 func (lf logFeedback) log(kind, format string, args ...interface{}) {