[VOL-1346] This commit addresses device discovery notifications
which will be principally used by the affinity router. In doing so
this commit also rename the core_adapter.proto to inter_container.proto.
Change-Id: Ib2a7b84efa50367d0ffbc482fba6096a225f3150
diff --git a/tests/kafka/kafka_client_test.go b/tests/kafka/kafka_client_test.go
index 76d63c6..12f0ae4 100644
--- a/tests/kafka/kafka_client_test.go
+++ b/tests/kafka/kafka_client_test.go
@@ -22,7 +22,7 @@
"github.com/google/uuid"
"github.com/opencord/voltha-go/common/log"
kk "github.com/opencord/voltha-go/kafka"
- ca "github.com/opencord/voltha-go/protos/core_adapter"
+ ic "github.com/opencord/voltha-go/protos/inter_container"
"github.com/stretchr/testify/assert"
"os"
"testing"
@@ -63,7 +63,7 @@
numMessageToSend = 1
}
-func waitForMessage(ch <-chan *ca.InterContainerMessage, doneCh chan string, maxMessages int) {
+func waitForMessage(ch <-chan *ic.InterContainerMessage, doneCh chan string, maxMessages int) {
totalTime = 0
totalMessageReceived = 0
mytime := time.Now()
@@ -92,17 +92,17 @@
func sendMessages(topic *kk.Topic, numMessages int, fn sendToKafka) error {
// Loop for numMessages
for i := 0; i < numMessages; i++ {
- msg := &ca.InterContainerMessage{}
- msg.Header = &ca.Header{
+ msg := &ic.InterContainerMessage{}
+ msg.Header = &ic.Header{
Id: uuid.New().String(),
- Type: ca.MessageType_REQUEST,
+ Type: ic.MessageType_REQUEST,
FromTopic: topic.Name,
ToTopic: topic.Name,
Timestamp: time.Now().UnixNano(),
}
var marshalledArg *any.Any
var err error
- body := &ca.InterContainerRequestBody{Rpc: "testRPC", Args: []*ca.Argument{}}
+ body := &ic.InterContainerRequestBody{Rpc: "testRPC", Args: []*ic.Argument{}}
if marshalledArg, err = ptypes.MarshalAny(body); err != nil {
log.Warnw("cannot-marshal-request", log.Fields{"error": err})
return err
@@ -116,7 +116,7 @@
}
func runWithPartionConsumer(topic *kk.Topic, numMessages int, doneCh chan string) error {
- var ch <-chan *ca.InterContainerMessage
+ var ch <-chan *ic.InterContainerMessage
var err error
if ch, err = partionClient.Subscribe(topic); err != nil {
return nil
@@ -130,7 +130,7 @@
}
func runWithGroupConsumer(topic *kk.Topic, numMessages int, doneCh chan string) error {
- var ch <-chan *ca.InterContainerMessage
+ var ch <-chan *ic.InterContainerMessage
var err error
if ch, err = groupClient.Subscribe(topic); err != nil {
return nil