X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Ftypes.go;fp=pkg%2Fxapp%2Ftypes.go;h=387d39321f7872d9545b98d799c243be7e7ab01c;hb=b8b191fe31602c53414f8086381aef1a48e8be09;hp=571dcbaef592b951e745cc0369755fa5fa568d8f;hpb=0ea2b6f7104cf323f039ce2a116fbc00a04cb6b6;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/types.go b/pkg/xapp/types.go index 571dcba..387d393 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,22 @@ 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 + MaxRetryOnFailure int +}