From f9ea54198ff875f8745516f6e79c04f39b4dfe1e Mon Sep 17 00:00:00 2001 From: Edd Robinson Date: Wed, 3 Jan 2018 15:44:58 +0000 Subject: [PATCH] rename series directory --- tsdb/engine/tsm1/engine_test.go | 2 +- tsdb/index_test.go | 2 +- tsdb/shard_internal_test.go | 2 +- tsdb/store.go | 7 ++++--- 4 files changed, 7 insertions(+), 6 deletions(-) diff --git a/tsdb/engine/tsm1/engine_test.go b/tsdb/engine/tsm1/engine_test.go index 42dc2c1be7..4cf964ac57 100644 --- a/tsdb/engine/tsm1/engine_test.go +++ b/tsdb/engine/tsm1/engine_test.go @@ -1685,7 +1685,7 @@ func NewEngine(index string) (*Engine, error) { } // Setup series file. - seriesPath, err := ioutil.TempDir(dbPath, "series") + seriesPath, err := ioutil.TempDir(dbPath, tsdb.SeriesFileDirectory) if err != nil { return nil, err } diff --git a/tsdb/index_test.go b/tsdb/index_test.go index d8668adfd5..9b3d74cb06 100644 --- a/tsdb/index_test.go +++ b/tsdb/index_test.go @@ -146,7 +146,7 @@ func MustNewIndex(index string) *Index { panic(err) } - seriesPath, err := ioutil.TempDir(rootPath, "series") + seriesPath, err := ioutil.TempDir(rootPath, tsdb.SeriesFileDirectory) if err != nil { panic(err) } diff --git a/tsdb/shard_internal_test.go b/tsdb/shard_internal_test.go index d0e9c0fefc..f34f8555c3 100644 --- a/tsdb/shard_internal_test.go +++ b/tsdb/shard_internal_test.go @@ -221,7 +221,7 @@ func NewTempShard(index string) *TempShard { } // Create series file. - sfile := NewSeriesFile(filepath.Join(dir, "db0", SeriesFileName)) + sfile := NewSeriesFile(filepath.Join(dir, "db0", SeriesFileDirectory)) sfile.Logger = logger.New(os.Stdout) if err := sfile.Open(); err != nil { panic(err) diff --git a/tsdb/store.go b/tsdb/store.go index 7373255f10..5eaac6cac7 100644 --- a/tsdb/store.go +++ b/tsdb/store.go @@ -36,8 +36,9 @@ const ( statDatabaseMeasurements = "numMeasurements" // number of measurements in a database ) -// SeriesFileName is the name of the series file. -const SeriesFileName = "series" +// SeriesFileDirectory is the name of the directory containing series files for +// a database. +const SeriesFileDirectory = ".series" // Store manages shards and indexes for databases. type Store struct { @@ -353,7 +354,7 @@ func (s *Store) openSeriesFile(database string) (*SeriesFile, error) { return sfile, nil } - sfile := NewSeriesFile(filepath.Join(s.path, database, SeriesFileName)) + sfile := NewSeriesFile(filepath.Join(s.path, database, SeriesFileDirectory)) sfile.Logger = s.baseLogger if err := sfile.Open(); err != nil { return nil, err