| commit | 86fce9a356e35fec539512c4c17c725179685ff1 | [log] [tgz] |
|---|---|---|
| author | Scott Baker <smbaker@gmail.com> | Thu Dec 12 09:47:17 2019 -0800 |
| committer | Scott Baker <smbaker@gmail.com> | Thu Dec 19 14:19:18 2019 -0800 |
| tree | 12846a33d653d6cee338bd455cc2c264cfb40fd7 | |
| parent | cbf583e03724ae29de6c473a8b5501d58e57e90d [diff] [blame] |
VOL-2204 Throw fatal error after a consumer stop Change-Id: I6e87a88ece2f7dc496d263ff0fc501bd8685cc72
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 3326191..4e04b30 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
@@ -768,6 +768,10 @@ return kp.kafkaClient.EnableLivenessChannel(enable) } +func (kp *InterContainerProxy) EnableHealthinessChannel(enable bool) chan bool { + return kp.kafkaClient.EnableHealthinessChannel(enable) +} + func (kp *InterContainerProxy) SendLiveness() error { return kp.kafkaClient.SendLiveness() }