X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Ftypes.go;h=6ae981a9af48e968fbf4301bbd4b3ec23821a47c;hb=79f0680fd7bbf1c8a8c6e2a842cb18020e387a47;hp=571dcbaef592b951e745cc0369755fa5fa568d8f;hpb=622bae3417eaaacfb798a82d530363f3c278e993;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/types.go b/pkg/xapp/types.go index 571dcba..6ae981a 100755 --- a/pkg/xapp/types.go +++ b/pkg/xapp/types.go @@ -23,28 +23,20 @@ import ( "unsafe" ) -// To be removed ... -type RMRStatistics struct{} - -// -// -// type RMRClient struct { - protPort string - contextMux sync.Mutex - 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 @@ -70,18 +62,41 @@ func (meid *RMRMeid) String() string { 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" +)