ClusterCockpit/cc-metric-store
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-store.git synced 2024-12-28 17:49:05 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add unit for archive reader/writer

Browse Source
This commit is contained in:
Thomas Roehl 2023-04-14 18:24:40 +02:00
parent 89acbe8db2
commit 051cba4666
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
archive.go
View File

@ -24,6 +24,7 @@ import (
type CheckpointMetrics struct { type CheckpointMetrics struct {
Frequency int64 `json:"frequency"` Frequency int64 `json:"frequency"`
Start int64 `json:"start"` Start int64 `json:"start"`
Unit string `json:"unit"`
Data []Float `json:"data"` Data []Float `json:"data"`
} }
@ -36,6 +37,7 @@ func (cm *CheckpointMetrics) MarshalJSON() ([]byte, error) {
buf = strconv.AppendInt(buf, cm.Frequency, 10) buf = strconv.AppendInt(buf, cm.Frequency, 10)
buf = append(buf, `,"start":`...) buf = append(buf, `,"start":`...)
buf = strconv.AppendInt(buf, cm.Start, 10) buf = strconv.AppendInt(buf, cm.Start, 10)
buf = append(buf, fmt.Sprintf(`,"unit":"%s"`, cm.Unit)...)
buf = append(buf, `,"data":[`...) buf = append(buf, `,"data":[`...)
for i, x := range cm.Data { for i, x := range cm.Data {
if i != 0 { if i != 0 {
@ -179,6 +181,7 @@ func (l *level) toCheckpointFile(from, to int64, m *MemoryStore) (*CheckpointFil
Frequency: b.frequency, Frequency: b.frequency,
Start: start, Start: start,
Data: data, Data: data,
Unit: b.unit,
} }
} }
@ -309,6 +312,7 @@ func (l *level) loadFile(cf *CheckpointFile, m *MemoryStore) error {
frequency: metric.Frequency, frequency: metric.Frequency,
start: metric.Start, start: metric.Start,
data: metric.Data[0:n:n], // Space is wasted here :( data: metric.Data[0:n:n], // Space is wasted here :(
unit: "",
prev: nil, prev: nil,
next: nil, next: nil,
archived: true, archived: true,