VOL-2098 Support for Kafka liveness testing
* Adds liveness channel to sarama_client and kafka_interadapter proxy.
The liveness channel will push true or false to the channel on
each successful or failed Kafka publish.
* Adds support to make a "liveness publish attempt", which publishes
an empty message on a _liveness channel.
* Adds ServiceStatusNotReady to Probe
* Suppresses multiple Probe.UpdateStatus of the same status
* Adds the ability to attach a Probe to the grpc server, so that
when the probe returns NotReady, the Server responds to requests
with UNAVAILABLE.
Change-Id: I996c719570a50f2f6f397887d10d489608269c3f
diff --git a/pkg/kafka/sarama_client_test.go b/pkg/kafka/sarama_client_test.go
new file mode 100644
index 0000000..6dd9fd8
--- /dev/null
+++ b/pkg/kafka/sarama_client_test.go
@@ -0,0 +1,38 @@
+/*
+ * Copyright 2018-present Open Networking Foundation
+
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+
+ * http://www.apache.org/licenses/LICENSE-2.0
+
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package kafka
+
+import (
+ "github.com/stretchr/testify/assert"
+ "testing"
+)
+
+func TestSaramaClientEnableLivenessChannel(t *testing.T) {
+ // Note: This doesn't actually start the client
+ client := NewSaramaClient()
+
+ ch := client.EnableLivenessChannel(true)
+
+ // The channel should have one "true" message on it
+ assert.NotEmpty(t, ch)
+
+ select {
+ case stuff := <-ch:
+ assert.True(t, stuff)
+ default:
+ t.Error("Failed to read from the channel")
+ }
+}