-func (a *App) processMessages(stdMessage messages.StdDefinedMessage) {
-
- for _, meas := range stdMessage.GetMeasurements() {
-
- fmt.Printf("New measurement: %+v\n", meas)
- //Create sliceMetric and check if metric exist and update existing one or create new one
- tmpSm := meas.CreateSliceMetric()
- a.MetricsPolicies.AddOrUpdateMetric(tmpSm)
-
- //Fetch policy ratio metrics from SDNR
- var duRRMPolicyRatio messages.ORanDuRestConf
- a.Client.Get(getUrlForDistributedUnitFunctions(SDNRUrl, tmpSm.DUId), &duRRMPolicyRatio)
-
- //Get DuId and check if we have metrics for it
- policyRatioDuId := duRRMPolicyRatio.DistributedUnitFunction.Id
- policies := duRRMPolicyRatio.DistributedUnitFunction.RRMPolicyRatio
- for _, policy := range policies {
- members:
- for _, member := range policy.RRMPolicyMembers {
- metric := a.MetricsPolicies.GetSliceMetric(policyRatioDuId, member.SliceDifferentiator, member.SliceServiceType)
- if metric != nil {
- a.MetricsPolicies.AddNewPolicy(addOrUpdatePolicyRatio(metric, policy))
- break members
- }
- }
- }
- }
-}