| 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/eventif/events_proxy_if.go b/vendor/github.com/opencord/voltha-lib-go/v4/pkg/events/eventif/events_proxy_if.go index 7418ea1..35f821f 100644 --- a/vendor/github.com/opencord/voltha-lib-go/v4/pkg/events/eventif/events_proxy_if.go +++ b/vendor/github.com/opencord/voltha-lib-go/v4/pkg/events/eventif/events_proxy_if.go
@@ -29,6 +29,8 @@ subCategory EventSubCategory, raisedTs int64) error SendRPCEvent(ctx context.Context, id string, deviceEvent *voltha.RPCEvent, category EventCategory, subCategory *EventSubCategory, raisedTs int64) error + EnableLivenessChannel(ctx context.Context, enable bool) chan bool + SendLiveness(ctx context.Context) error } const (