X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Ftypes.go;h=b6fc49b2f366c5bf0858859b85453015a53ed771;hb=d9ff71cf313086a71c417273a20b378a98c681fc;hp=571dcbaef592b951e745cc0369755fa5fa568d8f;hpb=622bae3417eaaacfb798a82d530363f3c278e993;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/types.go b/pkg/xapp/types.go index 571dcba..b6fc49b 100755 --- a/pkg/xapp/types.go +++ b/pkg/xapp/types.go @@ -23,28 +23,19 @@ 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 + stat map[string]Counter + consumers []MessageConsumer + readyCb ReadyCB + readyCbParams interface{} + maxRetryOnFailure int } -// -// -// type RMRMeid struct { PlmnID string EnbID string @@ -70,18 +61,23 @@ 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 +}