From 4144638be469b7f58d85053e58ea3281ae06d94b Mon Sep 17 00:00:00 2001 From: Vincent Demeester Date: Sat, 16 Apr 2016 14:46:35 +0200 Subject: [PATCH] Support stop chan on docker provider Signed-off-by: Vincent Demeester --- provider/docker.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/provider/docker.go b/provider/docker.go index 65506a740..722a86a11 100644 --- a/provider/docker.go +++ b/provider/docker.go @@ -130,6 +130,15 @@ func (provider *Docker) Provide(configurationChan chan<- types.ConfigMessage, po eventHandler.Handle("die", startStopHandle) errChan := events.MonitorWithHandler(ctx, dockerClient, options, eventHandler) + pool.Go(func(stop chan bool) { + for { + select { + case <-stop: + cancel() + return + } + } + }) if err := <-errChan; err != nil { return err }