TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-07 10:40:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

提供按小时、按天查询带宽峰值的API

Browse Source
This commit is contained in:
刘祥超
2022-08-28 15:56:16 +08:00
parent 1b36bad60a
commit 896e54ebe8
3 changed files with 162 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
internal/rpc/services/service_server_bandwidth_stat.go
View File

@@ -161,3 +161,39 @@ func (this *ServerBandwidthStatService) FindServerBandwidthStats(ctx context.Con
ServerBandwidthStats: pbStats,
}, nil
}
// FindHourlyServerBandwidthStats 获取最近N小时峰值带宽
func (this *ServerBandwidthStatService) FindHourlyServerBandwidthStats(ctx context.Context, req *pb.FindHourlyServerBandwidthStatsRequest) (*pb.FindHourlyServerBandwidthStatsResponse, error) {
_, err := this.ValidateAdmin(ctx)
if err != nil {
return nil, err
}
var tx = this.NullTx()
stats, err := models.SharedServerBandwidthStatDAO.FindHourlyBandwidthStats(tx, req.ServerId, req.Hours)
if err != nil {
return nil, err
}
return &pb.FindHourlyServerBandwidthStatsResponse{
Stats: stats,
}, nil
}
// FindDailyServerBandwidthStats 获取最近N天峰值带宽
func (this *ServerBandwidthStatService) FindDailyServerBandwidthStats(ctx context.Context, req *pb.FindDailyServerBandwidthStatsRequest) (*pb.FindDailyServerBandwidthStatsResponse, error) {
_, err := this.ValidateAdmin(ctx)
if err != nil {
return nil, err
}
var tx = this.NullTx()
stats, err := models.SharedServerBandwidthStatDAO.FindDailyBandwidthStats(tx, req.ServerId, req.Days)
if err != nil {
return nil, err
}
return &pb.FindDailyServerBandwidthStatsResponse{
Stats: stats,
}, nil
}