[VOL-3885] Adding retry mechanism when connecting to the kafka event cluster
Change-Id: I6411ed2e4172f9ab659a9d27c4e233c7a0f02b29
diff --git a/VERSION b/VERSION
index 2d2d681..30b26df 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-4.0.10
+4.0.11
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 (
diff --git a/pkg/events/events_proxy.go b/pkg/events/events_proxy.go
index c4014ee..2301f43 100644
--- a/pkg/events/events_proxy.go
+++ b/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)
+}