| commit | b3ba79c5e310c12bc1a0f7b9e97f8909ad3a87c6 | [log] [tgz] |
|---|---|---|
| author | Matteo Scandolo <matteo.scandolo@gmail.com> | Mon Mar 01 10:53:23 2021 -0800 |
| committer | Matteo Scandolo <matteo.scandolo@gmail.com> | Fri Mar 05 14:01:46 2021 -0800 |
| tree | 129c9c4b55aa114e6c697931c1501f2df2d08c36 | |
| parent | ff2d73a81fb09765ab6d542ce568005effc56542 [diff] [blame] |
[VOL-3885] Adding retry mechanism when connecting to the kafka event cluster Change-Id: I38267923ba006ea099b25863e98ff286efa9bbd6
diff --git a/vendor/github.com/opencord/voltha-lib-go/v4/pkg/events/events_proxy.go b/vendor/github.com/opencord/voltha-lib-go/v4/pkg/events/events_proxy.go index c4014ee..2301f43 100644 --- a/vendor/github.com/opencord/voltha-lib-go/v4/pkg/events/events_proxy.go +++ b/vendor/github.com/opencord/voltha-lib-go/v4/pkg/events/events_proxy.go
@@ -187,3 +187,11 @@ return nil } + +func (ep *EventProxy) EnableLivenessChannel(ctx context.Context, enable bool) chan bool { + return ep.kafkaClient.EnableLivenessChannel(ctx, enable) +} + +func (ep *EventProxy) SendLiveness(ctx context.Context) error { + return ep.kafkaClient.SendLiveness(ctx) +}