| commit | e701b8609e2de04c1fe420fdde9a06598ca2b473 | [log] [tgz] |
|---|---|---|
| author | Scott Baker <smbaker@gmail.com> | Thu Feb 20 16:19:16 2020 -0800 |
| committer | Scott Baker <smbaker@gmail.com> | Tue Feb 25 20:17:48 2020 -0800 |
| tree | 9e46dd62f06b7d5a60a661c670fb8a155ab05519 | |
| parent | fae935c6bd86688e562460b25fec0d5332b3302e [diff] [blame] |
VOL-2631 Cleanup Kafka Interadapter Proxy on shutdown; Exit gracefully rather than Fatal() on kafka shutdown Change-Id: Ic4506a8f4e5127d10a0db130a81584c0bf8c8428
diff --git a/vendor/github.com/opencord/voltha-lib-go/v3/pkg/db/kvstore/consulclient.go b/vendor/github.com/opencord/voltha-lib-go/v3/pkg/db/kvstore/consulclient.go index fdf39be..bdf2d10 100644 --- a/vendor/github.com/opencord/voltha-lib-go/v3/pkg/db/kvstore/consulclient.go +++ b/vendor/github.com/opencord/voltha-lib-go/v3/pkg/db/kvstore/consulclient.go
@@ -360,7 +360,7 @@ // Watch provides the watch capability on a given key. It returns a channel onto which the callee needs to // listen to receive Events. -func (c *ConsulClient) Watch(ctx context.Context, key string) chan *Event { +func (c *ConsulClient) Watch(ctx context.Context, key string, withPrefix bool) chan *Event { // Create a new channel ch := make(chan *Event, maxClientChannelBufferSize)