mirror of
https://github.com/SigNoz/signoz.git
synced 2025-12-17 15:36:48 +00:00
75 lines
2.6 KiB
Go
75 lines
2.6 KiB
Go
package formatter
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/SigNoz/signoz/pkg/query-service/converter"
|
|
"github.com/dustin/go-humanize"
|
|
)
|
|
|
|
type dataRateFormatter struct {
|
|
}
|
|
|
|
func NewDataRateFormatter() Formatter {
|
|
return &dataRateFormatter{}
|
|
}
|
|
|
|
func (*dataRateFormatter) Name() string {
|
|
return "data_rate"
|
|
}
|
|
|
|
func (f *dataRateFormatter) Format(value float64, unit string) string {
|
|
switch unit {
|
|
case "binBps":
|
|
return humanize.IBytes(uint64(value)) + "/s"
|
|
case "Bps", "By/s":
|
|
return humanize.Bytes(uint64(value)) + "/s"
|
|
case "binbps":
|
|
return humanize.IBytes(uint64(value*converter.BitPerSecond)) + "/s"
|
|
case "bps", "bit/s":
|
|
return humanize.Bytes(uint64(value*converter.BitPerSecond)) + "/s"
|
|
case "KiBs":
|
|
return humanize.IBytes(uint64(value*converter.KibibitPerSecond)) + "/s"
|
|
case "Kibits":
|
|
return humanize.IBytes(uint64(value*converter.KibibytePerSecond)) + "/s"
|
|
case "KBs", "kBy/s":
|
|
return humanize.IBytes(uint64(value*converter.KilobitPerSecond)) + "/s"
|
|
case "Kbits", "kbit/s":
|
|
return humanize.IBytes(uint64(value*converter.KilobytePerSecond)) + "/s"
|
|
case "MiBs":
|
|
return humanize.IBytes(uint64(value*converter.MebibitPerSecond)) + "/s"
|
|
case "Mibits":
|
|
return humanize.IBytes(uint64(value*converter.MebibytePerSecond)) + "/s"
|
|
case "MBs", "MBy/s":
|
|
return humanize.IBytes(uint64(value*converter.MegabitPerSecond)) + "/s"
|
|
case "Mbits", "Mbit/s":
|
|
return humanize.IBytes(uint64(value*converter.MegabytePerSecond)) + "/s"
|
|
case "GiBs":
|
|
return humanize.IBytes(uint64(value*converter.GibibitPerSecond)) + "/s"
|
|
case "Gibits":
|
|
return humanize.IBytes(uint64(value*converter.GibibytePerSecond)) + "/s"
|
|
case "GBs", "GBy/s":
|
|
return humanize.IBytes(uint64(value*converter.GigabitPerSecond)) + "/s"
|
|
case "Gbits", "Gbit/s":
|
|
return humanize.IBytes(uint64(value*converter.GigabytePerSecond)) + "/s"
|
|
case "TiBs":
|
|
return humanize.IBytes(uint64(value*converter.TebibitPerSecond)) + "/s"
|
|
case "Tibits":
|
|
return humanize.IBytes(uint64(value*converter.TebibytePerSecond)) + "/s"
|
|
case "TBs", "TBy/s":
|
|
return humanize.IBytes(uint64(value*converter.TerabitPerSecond)) + "/s"
|
|
case "Tbits", "Tbit/s":
|
|
return humanize.IBytes(uint64(value*converter.TerabytePerSecond)) + "/s"
|
|
case "PiBs":
|
|
return humanize.IBytes(uint64(value*converter.PebibitPerSecond)) + "/s"
|
|
case "Pibits":
|
|
return humanize.IBytes(uint64(value*converter.PebibytePerSecond)) + "/s"
|
|
case "PBs", "PBy/s":
|
|
return humanize.IBytes(uint64(value*converter.PetabitPerSecond)) + "/s"
|
|
case "Pbits", "Pbit/s":
|
|
return humanize.IBytes(uint64(value*converter.PetabytePerSecond)) + "/s"
|
|
}
|
|
// When unit is not matched, return the value as it is.
|
|
return fmt.Sprintf("%v", value)
|
|
}
|