| commit | 0fef6982a8d2b81b7e4e81b74d9a698998d88c80 | [log] [tgz] |
|---|---|---|
| author | Scott Baker <smbaker@gmail.com> | Thu Dec 12 09:49:42 2019 -0800 |
| committer | Scott Baker <smbaker@gmail.com> | Mon Dec 16 10:37:06 2019 -0800 |
| tree | 396a800ed7f9fb40c852964414e28f71bf2fb41e | |
| parent | d8a69c38f07f798a61bc0682ea7ba47285c36ede [diff] [blame] |
VOL-2204 Report health status of Kafka service Change-Id: I993b89f500bcbaa26da77f193575f5f20c3fb7c9
diff --git a/pkg/kafka/kafka_inter_container_library.go b/pkg/kafka/kafka_inter_container_library.go index 3326191..4e04b30 100644 --- a/pkg/kafka/kafka_inter_container_library.go +++ b/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() }