rancher/steve
1
0
Fork 0
mirror of https://github.com/rancher/steve.git synced 2025-07-01 17:22:13 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #3 from dramich/queue

Browse Source 
Drop things from the queue when completed
This commit is contained in:
Darren Shepherd 2020-04-15 17:47:35 -07:00 committed by GitHub
commit 12cc38a2d4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/clustercache/controller.go
View File

@ -216,6 +216,7 @@ func (h *clusterCache) List(gvr schema2.GroupVersionResource) []interface{} {
} }
func (h *clusterCache) start() { func (h *clusterCache) start() {
defer h.workqueue.ShutDown()
for { for {
eventObj, ok := h.workqueue.Get() eventObj, ok := h.workqueue.Get()
if ok { if ok {
@ -227,6 +228,7 @@ func (h *clusterCache) start() {
w := h.watchers[event.gvr] w := h.watchers[event.gvr]
h.RUnlock() h.RUnlock()
if w == nil { if w == nil {
h.workqueue.Done(eventObj)
continue continue
} }
@ -247,6 +249,7 @@ func (h *clusterCache) start() {
logrus.Errorf("failed to handle remove event: %v", err) logrus.Errorf("failed to handle remove event: %v", err)
} }
} }
h.workqueue.Done(eventObj)
} }
} }