commit | ee6a08798508583303a54cd9a2ea47a891691ea1 | [log] [tgz] |
---|---|---|
author | Scott Baker <smbaker@gmail.com> | Tue Oct 29 15:59:52 2019 -0700 |
committer | Scott Baker <smbaker@gmail.com> | Fri Nov 08 12:29:01 2019 -0800 |
tree | 2d5a7bdd60347a8d95be0749669ee0c95d0c7dc7 | |
parent | 566c75c3ee668680ea4f5da7ccc4e3bfe89975f8 [diff] [blame] |
VOL-2098 Monitor Kafka service readiness Change-Id: Ifb9658c8ea4f03374fe2921846149b1e55237327
diff --git a/vendor/github.com/opencord/voltha-lib-go/v2/pkg/kafka/kafka_inter_container_library.go b/vendor/github.com/opencord/voltha-lib-go/v2/pkg/kafka/kafka_inter_container_library.go index c576bc6..3326191 100644 --- a/vendor/github.com/opencord/voltha-lib-go/v2/pkg/kafka/kafka_inter_container_library.go +++ b/vendor/github.com/opencord/voltha-lib-go/v2/pkg/kafka/kafka_inter_container_library.go
@@ -764,6 +764,14 @@ return nil } +func (kp *InterContainerProxy) EnableLivenessChannel(enable bool) chan bool { + return kp.kafkaClient.EnableLivenessChannel(enable) +} + +func (kp *InterContainerProxy) SendLiveness() error { + return kp.kafkaClient.SendLiveness() +} + //formatRequest formats a request to send over kafka and returns an InterContainerMessage message on success //or an error on failure func encodeRequest(rpc string, toTopic *Topic, replyTopic *Topic, key string, kvArgs ...*KVArg) (*ic.InterContainerMessage, error) {