Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

remove unused function parameters

pull/9841/head
Jacob Marble 2018-05-10 08:29:43 -07:00
parent 62f5c66eea
commit 200fda999f
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tsdb/index/inmem/inmem.go
View File

@ -37,7 +37,7 @@ func init() {
tsdb.NewInmemIndex = func(name string, sfile *tsdb.SeriesFile) (interface{}, error) { return NewIndex(name, sfile), nil }
tsdb.RegisterIndex(IndexName, func(id uint64, database, path string, seriesIDSet *tsdb.SeriesIDSet, sfile *tsdb.SeriesFile, opt tsdb.EngineOptions) tsdb.Index {
return NewShardIndex(id, database, path, seriesIDSet, sfile, opt)
return NewShardIndex(id, seriesIDSet, opt)
})
}
@ -1208,7 +1208,7 @@ func (idx *ShardIndex) SeriesIDSet() *tsdb.SeriesIDSet {
}
// NewShardIndex returns a new index for a shard.
func NewShardIndex(id uint64, database, path string, seriesIDSet *tsdb.SeriesIDSet, sfile *tsdb.SeriesFile, opt tsdb.EngineOptions) tsdb.Index {
func NewShardIndex(id uint64, seriesIDSet *tsdb.SeriesIDSet, opt tsdb.EngineOptions) tsdb.Index {
return &ShardIndex{
Index: opt.InmemIndex.(*Index),
id: id,

10
tsdb/index/inmem/inmem_test.go
View File

@ -27,7 +27,7 @@ func BenchmarkShardIndex_CreateSeriesListIfNotExists_MaxValuesExceeded(b *testin
defer sfile.Close()
opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)}
opt.Config.MaxValuesPerTag = 10
si := inmem.NewShardIndex(1, "foo", "bar", tsdb.NewSeriesIDSet(), sfile.SeriesFile, opt)
si := inmem.NewShardIndex(1, tsdb.NewSeriesIDSet(), opt)
si.Open()
keys, names, tags := createData(0, 10)
si.CreateSeriesListIfNotExists(keys, names, tags)
@ -45,7 +45,7 @@ func BenchmarkShardIndex_CreateSeriesListIfNotExists_MaxValuesNotExceeded(b *tes
defer sfile.Close()
opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)}
opt.Config.MaxValuesPerTag = 100000
si := inmem.NewShardIndex(1, "foo", "bar", tsdb.NewSeriesIDSet(), sfile.SeriesFile, opt)
si := inmem.NewShardIndex(1, tsdb.NewSeriesIDSet(), opt)
si.Open()
keys, names, tags := createData(0, 10)
si.CreateSeriesListIfNotExists(keys, names, tags)
@ -62,7 +62,7 @@ func BenchmarkShardIndex_CreateSeriesListIfNotExists_NoMaxValues(b *testing.B) {
sfile := mustOpenSeriesFile()
defer sfile.Close()
opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)}
si := inmem.NewShardIndex(1, "foo", "bar", tsdb.NewSeriesIDSet(), sfile.SeriesFile, opt)
si := inmem.NewShardIndex(1, tsdb.NewSeriesIDSet(), opt)
si.Open()
keys, names, tags := createData(0, 10)
si.CreateSeriesListIfNotExists(keys, names, tags)
@ -81,7 +81,7 @@ func BenchmarkShardIndex_CreateSeriesListIfNotExists_MaxSeriesExceeded(b *testin
opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)}
opt.Config.MaxValuesPerTag = 0
opt.Config.MaxSeriesPerDatabase = 10
si := inmem.NewShardIndex(1, "foo", "bar", tsdb.NewSeriesIDSet(), sfile.SeriesFile, opt)
si := inmem.NewShardIndex(1, tsdb.NewSeriesIDSet(), opt)
si.Open()
keys, names, tags := createData(0, 10)
si.CreateSeriesListIfNotExists(keys, names, tags)
@ -98,7 +98,7 @@ func TestIndex_Bytes(t *testing.T) {
sfile := mustOpenSeriesFile()
defer sfile.Close()
opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)}
si := inmem.NewShardIndex(1, "foo", "bar", tsdb.NewSeriesIDSet(), sfile.SeriesFile, opt).(*inmem.ShardIndex)
si := inmem.NewShardIndex(1, tsdb.NewSeriesIDSet(), opt).(*inmem.ShardIndex)
indexBaseBytes, _ := si.Bytes()