From: Juha Hyttinen <juha.hyttinen@nokia.com>
Date: Mon, 5 Oct 2020 16:24:01 +0000 (+0300)
Subject: Fixed RmrClientParam field visibility
X-Git-Tag: v0.5.5^0
X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=commitdiff_plain;h=bbc70229a4f7343a2af02ce026174f995070e926;p=ric-plt%2Fxapp-frame.git

Fixed RmrClientParam field visibility

Change-Id: Ifd9ac0139af46168ee902fa4223447418c893979
Signed-off-by: Juha Hyttinen <juha.hyttinen@nokia.com>
---

diff --git a/pkg/xapp/rmr.go b/pkg/xapp/rmr.go
index 530f223..ee6b622 100755
--- a/pkg/xapp/rmr.go
+++ b/pkg/xapp/rmr.go
@@ -128,26 +128,26 @@ func (params *RMRParams) String() string {
 //
 //-----------------------------------------------------------------------------
 type RMRClientParams struct {
-	protPort   string
-	maxSize    int
-	threadType int
-	statDesc   string
-	lowLatency bool
-	fastAck    bool
+	ProtPort   string
+	MaxSize    int
+	ThreadType int
+	StatDesc   string
+	LowLatency bool
+	FastAck    bool
 }
 
 func (params *RMRClientParams) String() string {
-	return fmt.Sprintf("protPort=%s maxSize=%d threadType=%d statDesc=%s lowLatency=%t fastAck=%t",
-		params.protPort, params.maxSize, params.threadType, params.statDesc, params.lowLatency, params.fastAck)
+	return fmt.Sprintf("ProtPort=%s MaxSize=%d ThreadType=%d StatDesc=%s LowLatency=%t FastAck=%t",
+		params.ProtPort, params.MaxSize, params.ThreadType, params.StatDesc, params.LowLatency, params.FastAck)
 }
 
 //-----------------------------------------------------------------------------
 //
 //-----------------------------------------------------------------------------
 func NewRMRClientWithParams(params *RMRClientParams) *RMRClient {
-	p := C.CString(params.protPort)
-	m := C.int(params.maxSize)
-	c := C.int(params.threadType)
+	p := C.CString(params.ProtPort)
+	m := C.int(params.MaxSize)
+	c := C.int(params.ThreadType)
 	defer C.free(unsafe.Pointer(p))
 	ctx := C.rmr_init(p, m, c)
 	if ctx == nil {
@@ -156,30 +156,30 @@ func NewRMRClientWithParams(params *RMRClientParams) *RMRClient {
 
 	Logger.Info("new rmrClient with parameters: %s", params.String())
 
-	if params.lowLatency {
+	if params.LowLatency {
 		C.rmr_set_low_latency(ctx)
 	}
-	if params.fastAck {
+	if params.FastAck {
 		C.rmr_set_fack(ctx)
 	}
 
 	return &RMRClient{
-		protPort:  params.protPort,
+		protPort:  params.ProtPort,
 		context:   ctx,
 		consumers: make([]MessageConsumer, 0),
-		stat:      Metric.RegisterCounterGroup(RMRCounterOpts, params.statDesc),
+		stat:      Metric.RegisterCounterGroup(RMRCounterOpts, params.StatDesc),
 	}
 }
 
 func NewRMRClient() *RMRClient {
 	return NewRMRClientWithParams(
 		&RMRClientParams{
-			protPort:   viper.GetString("rmr.protPort"),
-			maxSize:    viper.GetInt("rmr.maxSize"),
-			threadType: viper.GetInt("rmr.threadType"),
-			statDesc:   "RMR",
-			lowLatency: viper.GetBool("rmr.lowLatency"),
-			fastAck:    viper.GetBool("rmr.fastAck"),
+			ProtPort:   viper.GetString("rmr.protPort"),
+			MaxSize:    viper.GetInt("rmr.maxSize"),
+			ThreadType: viper.GetInt("rmr.threadType"),
+			StatDesc:   "RMR",
+			LowLatency: viper.GetBool("rmr.lowLatency"),
+			FastAck:    viper.GetBool("rmr.fastAck"),
 		})
 }