[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/rw_core/main.go b/rw_core/main.go
index 472072a..dbb82b0 100644
--- a/rw_core/main.go
+++ b/rw_core/main.go
@@ -23,7 +23,7 @@
"github.com/opencord/voltha-go/common/log"
"github.com/opencord/voltha-go/db/kvstore"
"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/opencord/voltha-go/rw_core/config"
c "github.com/opencord/voltha-go/rw_core/core"
"os"
@@ -43,7 +43,7 @@
kafkaClient kafka.Client
core *c.Core
//For test
- receiverChannels []<-chan *ca.InterContainerMessage
+ receiverChannels []<-chan *ic.InterContainerMessage
}
func init() {
@@ -73,7 +73,7 @@
kafka.ProducerReturnOnErrors(true),
kafka.ProducerReturnOnSuccess(true),
kafka.ProducerMaxRetries(6),
- kafka.ProducerRetryBackoff(time.Millisecond * 30)), nil
+ kafka.ProducerRetryBackoff(time.Millisecond*30)), nil
}
return nil, errors.New("unsupported-client-type")
}
@@ -83,7 +83,7 @@
rwCore.config = cf
rwCore.halted = false
rwCore.exitChannel = make(chan int, 1)
- rwCore.receiverChannels = make([]<-chan *ca.InterContainerMessage, 0)
+ rwCore.receiverChannels = make([]<-chan *ic.InterContainerMessage, 0)
return &rwCore
}