From 92a9d0a93669d81925710e4e0122dad8f4f90f59 Mon Sep 17 00:00:00 2001 From: Michael Avila Date: Thu, 11 Apr 2019 00:01:47 -0700 Subject: [PATCH] Add Close() to reprovider License: MIT Signed-off-by: Michael Avila --- provider/reprovider.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/provider/reprovider.go b/provider/reprovider.go index 55604b5d628..b623a6362ce 100644 --- a/provider/reprovider.go +++ b/provider/reprovider.go @@ -45,6 +45,11 @@ func (rp *Reprovider) Run() { go rp.handleAnnouncements() } +// Close stops thhe reprovider +func (rp *Reprovider) Close() error { + return rp.queue.Close() +} + // Trigger causes a reprovide func (rp *Reprovider) Trigger(ctx context.Context) error { select {