General capabilities for xapps

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

diff --git a/pkg/xapp/types.go b/pkg/xapp/types.go
old mode 100644 (file)
new mode 100755 (executable)
index 2e1eb09..571dcba
--- a/pkg/xapp/types.go
+++ b/pkg/xapp/types.go
@@ -26,9 +26,12 @@ import (
 // To be removed ...
 type RMRStatistics struct{}
 
+//
+//
+//
 type RMRClient struct {
        protPort      string
-       numWorkers    int
+       contextMux    sync.Mutex
        context       unsafe.Pointer
        ready         int
        wg            sync.WaitGroup
@@ -39,12 +42,46 @@ type RMRClient struct {
        readyCbParams interface{}
 }
 
+//
+//
+//
 type RMRMeid struct {
        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
 }