mudhorn/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2024-12-25 05:34:05 -08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Merge pull request #724 from prometheus/fabxc/storage-startup

Browse source 
Read from indexing queue during crash recovery.
This commit is contained in:
Fabian Reinartz 2015-05-23 16:50:47 +02:00
parent 837ffcea29 6e319532cf
commit a92134a947
2 changed files with 20 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
main.go
View file

@ -239,10 +239,14 @@ func (p *prometheus) reloadConfig() bool {
func (p *prometheus) Serve() {
// Start all components.
if err := p.storage.Start(); err != nil {
log.Error("Error opening memory series storage: ", err)
log.Errorln("Error opening memory series storage:", err)
os.Exit(1)
}
defer p.storage.Stop()
defer func() {
if err := p.storage.Stop(); err != nil {
log.Errorln("Error stopping storage:", err)
}
}()
// The storage has to be fully initialized before registering Prometheus.
registry.MustRegister(p)

20
storage/local/storage.go
View file

@ -194,7 +194,7 @@ func NewMemorySeriesStorage(o *MemorySeriesStorageOptions) Storage {
}
// Start implements Storage.
func (s *memorySeriesStorage) Start() error {
func (s *memorySeriesStorage) Start() (err error) {
var syncStrategy syncStrategy
switch s.options.SyncStrategy {
case Never:
@ -207,11 +207,22 @@ func (s *memorySeriesStorage) Start() error {
panic("unknown sync strategy")
}
p, err := newPersistence(s.options.PersistenceStoragePath, s.options.Dirty, s.options.PedanticChecks, syncStrategy)
var p *persistence
p, err = newPersistence(s.options.PersistenceStoragePath, s.options.Dirty, s.options.PedanticChecks, syncStrategy)
if err != nil {
return err
}
s.persistence = p
// Persistence must start running before loadSeriesMapAndHeads() is called.
go s.persistence.run()
defer func() {
if err != nil {
if e := p.close(); e != nil {
log.Errorln("Error closing persistence:", e)
}
}
}()
log.Info("Loading series map and head chunks...")
s.fpToSeries, s.numChunksToPersist, err = p.loadSeriesMapAndHeads()
@ -221,13 +232,10 @@ func (s *memorySeriesStorage) Start() error {
log.Infof("%d series loaded.", s.fpToSeries.length())
s.numSeries.Set(float64(s.fpToSeries.length()))
mapper, err := newFPMapper(s.fpToSeries, p)
s.mapper, err = newFPMapper(s.fpToSeries, p)
if err != nil {
return err
}
s.mapper = mapper
go s.persistence.run()
go s.handleEvictList()
go s.loop()