Stop the watcher on-exit

boxofrad · boxofrad · commit 90438124ba4b · 2022-09-16T12:15:39.000+01:00
diff --git a/pkg/consuldp/consul_dataplane.go b/pkg/consuldp/consul_dataplane.go
@@ -121,6 +121,7 @@ func (cdp *ConsulDataplane) Run(ctx context.Context) error {
 		return err
 	}
 	go watcher.Run()
+	defer watcher.Stop()
 
 	state, err := watcher.State()
 	if err != nil {

Original file line number	Diff line number	Diff line change
`@@ -121,6 +121,7 @@ func (cdp *ConsulDataplane) Run(ctx context.Context) error {`
`121`	`121`	`return err`
`122`	`122`	`}`
`123`	`123`	`go watcher.Run()`
	`124`	`+ defer watcher.Stop()`
`124`	`125`
`125`	`126`	`state, err := watcher.State()`
`126`	`127`	`if err != nil {`