Supporting of reading subscriptions from subscription manager while restarting rtmgr

[ric-plt/rtmgr.git] / pkg / rtmgr / types.go

diff --git a/pkg/rtmgr/types.go b/pkg/rtmgr/types.go
index 5ad23e0..2846173 100644 (file)
--- a/pkg/rtmgr/types.go
+++ b/pkg/rtmgr/types.go
@@ -53,6 +53,7 @@ type Endpoint struct {
        Socket     interface{}
        IsReady    bool
        Keepalive  bool
+       Whid       int
 }
 
 type RouteTableEntry struct {
@@ -60,6 +61,7 @@ type RouteTableEntry struct {
        TxList      EndpointList
        RxGroups    []EndpointList
        SubID       int32
+       RouteType   string
 }
 
 type XApp struct {
@@ -85,17 +87,56 @@ type PlatformComponents []struct {
        Port uint16 `json:"port"`
 }
 
+type E2TInstance struct {
+        Name string `json:"name"`
+        Fqdn string `json:"fqdn"`
+        Ranlist []string `json:"ranlist"`
+}
+
+type E2tIdentity struct {
+        E2taddress string `json:"e2tAddress"`
+        Rannames []string `json:"ranNames"`
+}
+
 type ConfigRtmgr struct {
        Pcs PlatformComponents `json:"PlatformComponents"`
 }
 
 type RicComponents struct {
        XApps []XApp
+       E2Ts  map [string]E2TInstance
+       MeidMap  []string
        Pcs   PlatformComponents
 }
 
 type Subscription struct {
        SubID int32
-       Fqdn  string
-       Port  uint16
+       Fqdn string
+       Port uint16
 }
+
+type PlatformRoutes []struct {
+       MessageType     string `json:"messagetype"`
+       SenderEndPoint  string `json:"senderendpoint"`
+       SubscriptionId  int32  `json:"subscriptionid"`
+       EndPoint        string `json:"endpoint"`
+       Meid            string `json:"meid"`
+}
+
+type RtmgrRoutes struct {
+       Prs PlatformRoutes      `json:"PlatformRoutes"`
+}
+
+type FqDn struct {
+       Address *string
+        Port *uint16
+}
+
+type XappList struct {
+        SubscriptionID  uint16
+       FqdnList []FqDn
+}
+
+var (
+       Rtmgr_ready bool
+)