"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
+ stat map[string]Counter
+ 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"
+)