commit 2ca7446fbca084ae64d38a6716e0ceee4185388a
author Matteo Scandolo <matteo.scandolo@gmail.com> Mon Mar 01 14:03:17 2021 -0800
committer Matteo Scandolo <matteo.scandolo@gmail.com> Mon Mar 01 15:43:40 2021 -0800
tree 29437679b4dfecc9cb1238d898190d7ebde7333d
parent 198de901f27ec1763708ed2eceebb63a0aa724aa

[VOL-3885] Adding retry mechanism when connecting to the kafka event cluster

Change-Id: I6411ed2e4172f9ab659a9d27c4e233c7a0f02b29

pkg/events/eventif/events_proxy_if.go

diff --git a/pkg/events/eventif/events_proxy_if.go b/pkg/events/eventif/events_proxy_if.go
index 7418ea1..35f821f 100644
--- a/pkg/events/eventif/events_proxy_if.go
+++ b/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 (