TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2026-02-10 02:45:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

可以自行设定指标数据保留时间

Browse Source
This commit is contained in:
刘祥超
2022-03-28 09:37:28 +08:00
parent b2752ddd5a
commit d13176b8a5
5 changed files with 68 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
internal/rpc/services/service_metric_item.go
View File

@@ -22,7 +22,7 @@ func (this *MetricItemService) CreateMetricItem(ctx context.Context, req *pb.Cre
}
var tx = this.NullTx()
itemId, err := models.SharedMetricItemDAO.CreateItem(tx, req.Code, req.Category, req.Name, req.Keys, req.Period, req.PeriodUnit, req.Value, req.IsPublic)
itemId, err := models.SharedMetricItemDAO.CreateItem(tx, req.Code, req.Category, req.Name, req.Keys, req.Period, req.PeriodUnit, req.ExpiresPeriod, req.Value, req.IsPublic)
if err != nil {
return nil, err
}
@@ -37,7 +37,7 @@ func (this *MetricItemService) UpdateMetricItem(ctx context.Context, req *pb.Upd
}
var tx = this.NullTx()
err = models.SharedMetricItemDAO.UpdateItem(tx, req.MetricItemId, req.Name, req.Keys, req.Period, req.PeriodUnit, req.Value, req.IsOn, req.IsPublic)
err = models.SharedMetricItemDAO.UpdateItem(tx, req.MetricItemId, req.Name, req.Keys, req.Period, req.PeriodUnit, req.ExpiresPeriod, req.Value, req.IsOn, req.IsPublic)
if err != nil {
return nil, err
}
@@ -60,16 +60,17 @@ func (this *MetricItemService) FindEnabledMetricItem(ctx context.Context, req *p
return &pb.FindEnabledMetricItemResponse{MetricItem: nil}, nil
}
return &pb.FindEnabledMetricItemResponse{MetricItem: &pb.MetricItem{
Id: int64(item.Id),
IsOn: item.IsOn,
Code: item.Code,
Category: item.Category,
Name: item.Name,
Keys: item.DecodeKeys(),
Period: types.Int32(item.Period),
PeriodUnit: item.PeriodUnit,
Value: item.Value,
IsPublic: item.IsPublic,
Id: int64(item.Id),
IsOn: item.IsOn,
Code: item.Code,
Category: item.Category,
Name: item.Name,
Keys: item.DecodeKeys(),
Period: types.Int32(item.Period),
PeriodUnit: item.PeriodUnit,
ExpiresPeriod: types.Int32(item.ExpiresPeriod),
Value: item.Value,
IsPublic: item.IsPublic,
}}, nil
}
@@ -103,16 +104,17 @@ func (this *MetricItemService) ListEnabledMetricItems(ctx context.Context, req *
var pbItems = []*pb.MetricItem{}
for _, item := range items {
pbItems = append(pbItems, &pb.MetricItem{
Id: int64(item.Id),
IsOn: item.IsOn,
Code: item.Code,
Category: item.Category,
Name: item.Name,
Keys: item.DecodeKeys(),
Period: types.Int32(item.Period),
PeriodUnit: item.PeriodUnit,
Value: item.Value,
IsPublic: item.IsPublic,
Id: int64(item.Id),
IsOn: item.IsOn,
Code: item.Code,
Category: item.Category,
Name: item.Name,
Keys: item.DecodeKeys(),
Period: types.Int32(item.Period),
PeriodUnit: item.PeriodUnit,
ExpiresPeriod: types.Int32(item.ExpiresPeriod),
Value: item.Value,
IsPublic: item.IsPublic,
})
}