mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2024-12-27 14:39:40 -08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

Add several needed persistence proxy methods to tiered storage.

Browse source
This commit is contained in:
Julius Volz 2013-03-21 17:59:42 +01:00
parent 081d250929
commit 3c9d6cb66c
1 changed files with 20 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
storage/metric/tiered.go
View file

@ -62,6 +62,11 @@ type Storage interface {
Drain() Drain()
Flush() Flush()
Close() Close()
// MetricPersistence proxy methods.
GetAllMetricNames() ([]string, error)
GetFingerprintsForLabelSet(model.LabelSet) (model.Fingerprints, error)
GetMetricForFingerprint(model.Fingerprint) (m *model.Metric, err error)
} }
func NewTieredStorage(appendToMemoryQueueDepth, appendToDiskQueueDepth, viewQueueDepth uint, flushMemoryInterval, writeMemoryInterval, memoryTTL time.Duration, root string) Storage { func NewTieredStorage(appendToMemoryQueueDepth, appendToDiskQueueDepth, viewQueueDepth uint, flushMemoryInterval, writeMemoryInterval, memoryTTL time.Duration, root string) Storage {
@ -520,3 +525,18 @@ func (t *tieredStorage) loadChunkAroundTime(iterator *levigo.Iterator, frontier
return return
} }
func (t *tieredStorage) GetAllMetricNames() ([]string, error) {
// TODO: handle memory persistence as well.
return t.diskStorage.GetAllMetricNames()
}
func (t *tieredStorage) GetFingerprintsForLabelSet(labelSet model.LabelSet) (model.Fingerprints, error) {
// TODO: handle memory persistence as well.
return t.diskStorage.GetFingerprintsForLabelSet(labelSet)
}
func (t *tieredStorage) GetMetricForFingerprint(f model.Fingerprint) (m *model.Metric, err error) {
// TODO: handle memory persistence as well.
return t.diskStorage.GetMetricForFingerprint(f)
}