prometheus/cadvisor
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Use generic TimedStore for stats storage

Browse Source
This commit is contained in:
Victor Marmol 2015-04-23 11:43:32 -07:00
parent 8d2f81e73f
commit c72445a698
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
storage/memory/memory.go
View File

@ -39,14 +39,19 @@ func (self *containerStorage) AddStats(stats *info.ContainerStats) error {
defer self.lock.Unlock() defer self.lock.Unlock()
// Add the stat to storage. // Add the stat to storage.
self.recentStats.Add(stats) self.recentStats.Add(stats.Timestamp, stats)
return nil return nil
} }
func (self *containerStorage) RecentStats(start, end time.Time, maxStats int) ([]*info.ContainerStats, error) { func (self *containerStorage) RecentStats(start, end time.Time, maxStats int) ([]*info.ContainerStats, error) {
self.lock.RLock() self.lock.RLock()
defer self.lock.RUnlock() defer self.lock.RUnlock()
return self.recentStats.InTimeRange(start, end, maxStats), nil result := self.recentStats.InTimeRange(start, end, maxStats)
converted := make([]*info.ContainerStats, len(result))
for i, el := range result {
converted[i] = el.(*info.ContainerStats)
}
return converted, nil
} }
func newContainerStore(ref info.ContainerReference, maxAge time.Duration) *containerStorage { func newContainerStore(ref info.ContainerReference, maxAge time.Duration) *containerStorage {