directory
0.0.0-20241206182556-7190c600c311
Repository: https://github.com/aalayanahmad/go-upf.git
Documentation: pkg.go.dev
# Packages
No description provided by the author
No description provided by the author
No description provided by the author
// will be used by capturePackets to retrieve all required QoSFlow for monitoring
func GetQoSFlowMonitoringContent() error { srrInfos, err := GetSRRContent(uint8(1)) if err != nil { return err } var qfi_destination string //log.Println("retrieving values") for _, srrInfo := range srrInfos { //log.Println("in SRR info line") qfi := srrInfo.QFI //log.Println("qfi", qfi) ReqQoSMonit := srrInfo.RequestedQoSMonitoring //log.Println("requestMont", ReqQoSMonit) ReportingFrequency := srrInfo.ReportingFrequency //log.Println("ReportingFrequency", ReportingFrequency) PacketDelayThresholds := srrInfo.PacketDelayThresholds //log.Println("PacketDelayThresholds", PacketDelayThresholds) DownlinkPacketDelayThresholds := srrInfo.DownlinkPacketDelayThresholds //log.Println("DownlinkPacketDelayThresholds", DownlinkPacketDelayThresholds) UplinkPacketDelayThresholds := srrInfo.UplinkPacketDelayThresholds //log.Println("UplinkPacketDelayThresholds", UplinkPacketDelayThresholds) RoundTripPacketDelayThresholds := srrInfo.RoundTripPacketDelayThresholds //log.Println("RoundTripPacketDelayThresholds", RoundTripPacketDelayThresholds) MinimumWaitTime := srrInfo.MinimumWaitTime //log.Println("MinimumWaitTime", MinimumWaitTime) MeasurementPeriod := srrInfo.MeasurementPeriod //log.Println("MeasurementPeriod", MeasurementPeriod) if qfi == uint8(6) { qfi_destination = "10.100.200.12" //change according to destination1 IP } if qfi == uint8(8) { qfi_destination = "10.100.200.16" //change according to destination2 IP } QoSflow_RequestedMonitoring.Store(qfi_destination, ReqQoSMonit) //log.Println("stored RequestedMonitoring for", qfi_destination) QoSflow_ReportedFrequency.Store(qfi_destination, ReportingFrequency) //log.Println("stored ReportedFrequency for", qfi_destination) QoSflow_PacketDelayThresholds.Store(qfi_destination, PacketDelayThresholds) //log.Println("stored PacketDelayThresholds for", qfi_destination) QoSflow_DownlinkPacketDelayThresholds.Store(qfi_destination, DownlinkPacketDelayThresholds) //log.Println("stored DownlinkPacketDelayThresholds for", qfi_destination) QoSflow_UplinkPacketDelayThresholds.Store(qfi_destination, UplinkPacketDelayThresholds) //log.Println("stored UplinkPacketDelayThresholds for", qfi_destination) QoSflow_RoundTripPacketDelayThresholds.Store(qfi_destination, RoundTripPacketDelayThresholds) //log.Println("stored RoundTripPacketDelayThresholds for", qfi_destination) QoSflow_MinimumWaitTime.Store(qfi_destination, MinimumWaitTime) //log.Println("stored MinimumWaitTime for", qfi_destination) QoSflow_MeasurementPeriod.Store(qfi_destination, MeasurementPeriod) //log.Println("stored MeasurementPeriod for", qfi_destination) } return nil }.
No description provided by the author