[VOL-3631] Parametrizing KV_STORE path for TechProfiles and Onu data
Change-Id: I9598f3aa42d848786eaad89e260a71f9563bfa0c
diff --git a/cmd/openonu-adapter/main.go b/cmd/openonu-adapter/main.go
index 486188d..df7c327 100644
--- a/cmd/openonu-adapter/main.go
+++ b/cmd/openonu-adapter/main.go
@@ -131,7 +131,7 @@
// Create the open ONU interface adapter
if a.iAdapter, err = a.startVolthaInterfaceAdapter(ctx, a.kip, a.coreProxy, a.adapterProxy, a.eventProxy,
- a.config); err != nil {
+ a.config, cm); err != nil {
logger.Fatalw("error-starting-volthaInterfaceAdapter for OpenOnt", log.Fields{"error": err})
}
@@ -249,9 +249,9 @@
func (a *adapter) startVolthaInterfaceAdapter(ctx context.Context, kip kafka.InterContainerProxy,
cp adapterif.CoreProxy, ap adapterif.AdapterProxy, ep adapterif.EventProxy,
- cfg *config.AdapterFlags) (*ac.OpenONUAC, error) {
+ cfg *config.AdapterFlags, cm *conf.ConfigManager) (*ac.OpenONUAC, error) {
var err error
- sAcONU := ac.NewOpenONUAC(ctx, a.kip, cp, ap, ep, a.kvClient, cfg)
+ sAcONU := ac.NewOpenONUAC(ctx, a.kip, cp, ap, ep, a.kvClient, cfg, cm)
if err = sAcONU.Start(ctx); err != nil {
logger.Fatalw("error-starting-OpenOnuAdapterCore", log.Fields{"error": err})