Add some rmr library stats into metrics

[ric-plt/xapp-frame.git] / pkg / xapp / types.go

diff --git a/pkg/xapp/types.go b/pkg/xapp/types.go
index b67f9f1..6ae981a 100755 (executable)
--- a/pkg/xapp/types.go
+++ b/pkg/xapp/types.go
@@ -23,25 +23,80 @@ import (
        "unsafe"
 )
 
-// To be removed ...
-type RMRStatistics struct{}
-
 type RMRClient struct {
-       context       unsafe.Pointer
-       ready         int
-       wg            sync.WaitGroup
-       mux           sync.Mutex
-       stat          map[string]Counter
-       consumers     []MessageConsumer
-       readyCb       ReadyCB
-       readyCbParams interface{}
+       contextMux        sync.Mutex
+       context           unsafe.Pointer
+       ready             int
+       wg                sync.WaitGroup
+       mux               sync.Mutex
+       statc             map[string]Counter
+       statg             map[string]Gauge
+       consumers         []MessageConsumer
+       readyCb           ReadyCB
+       readyCbParams     interface{}
+       maxRetryOnFailure int
 }
 
 type RMRMeid struct {
-       PlmnID string
-       EnbID  string
+       PlmnID  string
+       EnbID   string
+       RanName string
+}
+
+func (meid *RMRMeid) String() string {
+       str := "meid("
+       pad := ""
+       if len(meid.PlmnID) > 0 {
+               str += pad + "PlmnID=" + meid.PlmnID
+               pad = " "
+       }
+       if len(meid.EnbID) > 0 {
+               str += pad + "EnbID=" + meid.EnbID
+               pad = " "
+       }
+       if len(meid.RanName) > 0 {
+               str += pad + "RanName=" + meid.RanName
+               pad = " "
+       }
+       str += ")"
+       return str
+}
+
+type MessageConsumerFunc func(*RMRParams) error
+
+func (fn MessageConsumerFunc) Consume(params *RMRParams) error {
+       return fn(params)
 }
 
 type MessageConsumer interface {
        Consume(params *RMRParams) error
 }
+
+type PortData struct {
+       Name              string
+       Port              int
+       MaxSize           int
+       ThreadType        int
+       LowLatency        bool
+       FastAck           bool
+       Policies          []int
+       MaxRetryOnFailure int
+}
+
+type SymptomDataParams struct {
+       Timeout       uint64
+       FromTime      uint64
+       ToTime        uint64
+       importantOnly bool
+}
+
+// @todo: read these from config or somewhere else
+const (
+       SERVICE_HTTP    = "SERVICE_%s_%s_HTTP_PORT"
+       SERVICE_RMR     = "SERVICE_%s_%s_RMR_PORT"
+       CONFIG_PATH     = "/ric/v1/config"
+       REGISTER_PATH   = "http://service-%s-appmgr-http.%s:8080/ric/v1/register"
+       DEREGISTER_PATH = "http://service-%s-appmgr-http.%s:8080/ric/v1/deregister"
+       DEFAULT_PLT_NS  = "ricplt"
+       DEFAULT_XAPP_NS = "ricxapp"
+)