RepoMirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus synced 2025-01-30 03:33:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Minor LevelDB watermark handling cleanups.

Browse Source
This commit is contained in:
Julius Volz 2013-06-06 18:16:28 +02:00 committed by Julius Volz
parent 84741b227d
commit 7b9ee95030
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
storage/metric/leveldb.go
View File

@ -492,22 +492,19 @@ func (l *LevelDBMetricPersistence) refreshHighWatermarks(groups map[model.Finger
mutationCount := 0 mutationCount := 0
for fingerprint, samples := range groups { for fingerprint, samples := range groups {
key := &dto.Fingerprint{} keyEncoded := coding.NewPBEncoder(fingerprint.ToDTO())
value := &dto.MetricHighWatermark{} value := &dto.MetricHighWatermark{}
raw := []byte{}
newestSampleTimestamp := samples[len(samples)-1].Timestamp newestSampleTimestamp := samples[len(samples)-1].Timestamp
keyEncoded := coding.NewPBEncoder(key)
key.Signature = proto.String(fingerprint.ToRowKey()) raw, err := l.MetricHighWatermarks.Get(keyEncoded)
raw, err = l.MetricHighWatermarks.Get(keyEncoded)
if err != nil { if err != nil {
return return err
} }
if raw != nil { if raw != nil {
err = proto.Unmarshal(raw, value) err = proto.Unmarshal(raw, value)
if err != nil { if err != nil {
return return err
} }
if newestSampleTimestamp.Before(time.Unix(*value.Timestamp, 0)) { if newestSampleTimestamp.Before(time.Unix(*value.Timestamp, 0)) {
@ -521,10 +518,10 @@ func (l *LevelDBMetricPersistence) refreshHighWatermarks(groups map[model.Finger
err = l.MetricHighWatermarks.Commit(batch) err = l.MetricHighWatermarks.Commit(batch)
if err != nil { if err != nil {
return return err
} }
return return nil
} }
func (l *LevelDBMetricPersistence) AppendSamples(samples model.Samples) (err error) { func (l *LevelDBMetricPersistence) AppendSamples(samples model.Samples) (err error) {