type RMRStatistics struct{}
type RMRClient struct {
+ protPort string
+ numWorkers int
context unsafe.Pointer
ready int
wg sync.WaitGroup
+ msgWg sync.WaitGroup
mux sync.Mutex
stat map[string]Counter
consumers []MessageConsumer
}
type RMRMeid struct {
- PlmnID string
- EnbID string
+ PlmnID string
+ EnbID string
+ RanName string
}
type MessageConsumer interface {
- Consume(mtype int, sid int, payload []byte, meid *RMRMeid) error
+ Consume(params *RMRParams) error
}