rename series directory

pull/9265/head
Edd Robinson 2018-01-03 15:44:58 +00:00
parent 52630e69d7
commit f9ea54198f
4 changed files with 7 additions and 6 deletions

View File

@ -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
}

View File

@ -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)
}

View File

@ -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)

View File

@ -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