/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/tsdb/ |
H A D | series_file.go | 36 type SeriesFile struct { struct 48 func NewSeriesFile(path string) *SeriesFile { 54 return &SeriesFile{ 73 func (f *SeriesFile) Open() error { argument 105 func (f *SeriesFile) close() (err error) { argument 116 func (f *SeriesFile) Close() (err error) { argument 134 func (f *SeriesFile) Retain() func() { argument 145 func (f *SeriesFile) EnableCompactions() { argument 152 func (f *SeriesFile) DisableCompactions() { argument 159 func (f *SeriesFile) Wait() { argument [all …]
|
H A D | series_file_test.go | 235 sfile.SeriesFile = tsdb.NewSeriesFile(sfile.SeriesFile.Path()) 314 type SeriesFile struct { struct 315 *tsdb.SeriesFile anonMember 319 func NewSeriesFile() *SeriesFile { 324 return &SeriesFile{SeriesFile: tsdb.NewSeriesFile(dir)} 331 sFile.SeriesFile.Close() 355 func (f *SeriesFile) Close() error { argument 357 return f.SeriesFile.Close() 361 func (f *SeriesFile) Reopen() error { argument 365 f.SeriesFile = tsdb.NewSeriesFile(f.SeriesFile.Path()) [all …]
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/tsdb/ |
H A D | series_file.go | 36 type SeriesFile struct { struct 48 func NewSeriesFile(path string) *SeriesFile { 54 return &SeriesFile{ 73 func (f *SeriesFile) Open() error { argument 105 func (f *SeriesFile) close() (err error) { argument 116 func (f *SeriesFile) Close() (err error) { argument 134 func (f *SeriesFile) Retain() func() { argument 145 func (f *SeriesFile) EnableCompactions() { argument 152 func (f *SeriesFile) DisableCompactions() { argument 159 func (f *SeriesFile) Wait() { argument [all …]
|
H A D | series_file_test.go | 235 sfile.SeriesFile = tsdb.NewSeriesFile(sfile.SeriesFile.Path()) 314 type SeriesFile struct { struct 315 *tsdb.SeriesFile argument 319 func NewSeriesFile() *SeriesFile { 324 return &SeriesFile{SeriesFile: tsdb.NewSeriesFile(dir)} 331 sFile.SeriesFile.Close() 355 func (f *SeriesFile) Close() error { argument 357 return f.SeriesFile.Close() 361 func (f *SeriesFile) Reopen() error { argument 365 f.SeriesFile = tsdb.NewSeriesFile(f.SeriesFile.Path()) [all …]
|
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/tsdb/ |
H A D | series_file.go | 34 type SeriesFile struct { struct 44 func NewSeriesFile(path string) *SeriesFile { 45 return &SeriesFile{ 52 func (f *SeriesFile) Open() error { argument 78 func (f *SeriesFile) Close() (err error) { argument 104 func (f *SeriesFile) Retain() func() { argument 115 func (f *SeriesFile) EnableCompactions() { argument 122 func (f *SeriesFile) DisableCompactions() { argument 129 func (f *SeriesFile) Wait() { argument 165 func (f *SeriesFile) IsDeleted(id uint64) bool { argument [all …]
|
H A D | series_file_test.go | 135 type SeriesFile struct { struct 136 *tsdb.SeriesFile anonMember 140 func NewSeriesFile() *SeriesFile { 145 return &SeriesFile{SeriesFile: tsdb.NewSeriesFile(dir)} 149 func MustOpenSeriesFile() *SeriesFile { 159 func (f *SeriesFile) Close() error { argument 161 return f.SeriesFile.Close()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/tsdb/ |
H A D | series_file.go | 34 type SeriesFile struct { struct 44 func NewSeriesFile(path string) *SeriesFile { 45 return &SeriesFile{ 52 func (f *SeriesFile) Open() error { argument 81 func (f *SeriesFile) close() (err error) { argument 92 func (f *SeriesFile) Close() (err error) { argument 110 func (f *SeriesFile) Retain() func() { argument 121 func (f *SeriesFile) EnableCompactions() { argument 128 func (f *SeriesFile) DisableCompactions() { argument 135 func (f *SeriesFile) Wait() { argument [all …]
|
H A D | series_file_test.go | 185 type SeriesFile struct { struct 186 *tsdb.SeriesFile anonMember 190 func NewSeriesFile() *SeriesFile { 195 return &SeriesFile{SeriesFile: tsdb.NewSeriesFile(dir)} 202 sFile.SeriesFile.Close() 216 func MustOpenSeriesFile() *SeriesFile { 226 func (f *SeriesFile) Close() error { argument 228 return f.SeriesFile.Close() 232 func (f *SeriesFile) Reopen() error { argument 236 f.SeriesFile = tsdb.NewSeriesFile(f.SeriesFile.Path()) [all …]
|
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/tsdb/index/tsi1/ |
H A D | index_file_test.go | 17 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 39 f, err := GenerateIndexFile(sfile.SeriesFile, 10, 3, 4) 57 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 76 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 1, 2, 3)) 81 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 10, 5, 5)) 86 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 10, 7, 7)) 104 func CreateIndexFile(sfile *tsdb.SeriesFile, series []Series) (*tsi1.IndexFile, error) { argument 126 func GenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) (*tsi1.IndexFile, er… argument 147 func MustGenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) *tsi1.IndexFile { argument 164 func MustFindOrGenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) *tsi1.Inde… argument
|
H A D | tsi1_test.go | 286 type SeriesFile struct { struct 287 *tsdb.SeriesFile anonMember 291 func NewSeriesFile() *SeriesFile { 296 return &SeriesFile{SeriesFile: tsdb.NewSeriesFile(dir)} 300 func MustOpenSeriesFile() *SeriesFile { 309 func (f *SeriesFile) Close() error { argument 311 return f.SeriesFile.Close() 315 func (f *SeriesFile) Reopen() error { argument 316 if err := f.SeriesFile.Close(); err != nil { 319 f.SeriesFile = tsdb.NewSeriesFile(f.SeriesFile.Path())
|
H A D | partition_test.go | 19 p := NewPartition(sfile.SeriesFile) 45 p = NewPartition(sfile.SeriesFile) 78 p := MustOpenPartition(sfile.SeriesFile) 91 func NewPartition(sfile *tsdb.SeriesFile) *Partition { argument 96 func MustOpenPartition(sfile *tsdb.SeriesFile) *Partition { argument 116 sfile, path := p.SeriesFile(), p.Path()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/tsdb/index/tsi1/ |
H A D | index_file_test.go | 17 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 39 f, err := GenerateIndexFile(sfile.SeriesFile, 10, 3, 4) 82 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 101 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 1, 2, 3)) 106 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 10, 5, 5)) 111 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 10, 7, 7)) 129 func CreateIndexFile(sfile *tsdb.SeriesFile, series []Series) (*tsi1.IndexFile, error) { argument 151 func GenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) (*tsi1.IndexFile, er… argument 172 func MustGenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) *tsi1.IndexFile { argument 189 func MustFindOrGenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) *tsi1.Inde… argument
|
H A D | tsi1_test.go | 286 type SeriesFile struct { struct 287 *tsdb.SeriesFile anonMember 291 func NewSeriesFile() *SeriesFile { 296 return &SeriesFile{SeriesFile: tsdb.NewSeriesFile(dir)} 300 func MustOpenSeriesFile() *SeriesFile { 309 func (f *SeriesFile) Close() error { argument 311 return f.SeriesFile.Close() 315 func (f *SeriesFile) Reopen() error { argument 316 if err := f.SeriesFile.Close(); err != nil { 319 f.SeriesFile = tsdb.NewSeriesFile(f.SeriesFile.Path())
|
H A D | partition_test.go | 19 p := NewPartition(sfile.SeriesFile) 45 p = NewPartition(sfile.SeriesFile) 78 p := MustOpenPartition(sfile.SeriesFile) 91 func NewPartition(sfile *tsdb.SeriesFile) *Partition { argument 96 func MustOpenPartition(sfile *tsdb.SeriesFile) *Partition { argument 116 sfile, path := p.SeriesFile(), p.Path()
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/tsdb/index/tsi1/ |
H A D | index_file_test.go | 19 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 39 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 89 f, err := GenerateIndexFile(sfile.SeriesFile, 10, 3, 4) 132 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 151 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 1, 2, 3)) 156 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 10, 5, 5)) 161 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 10, 7, 7)) 179 func CreateIndexFile(sfile *tsdb.SeriesFile, series []Series) (*tsi1.IndexFile, error) { argument 201 func GenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) (*tsi1.IndexFile, er… argument 222 func MustGenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) *tsi1.IndexFile { argument [all …]
|
H A D | tsi1_test.go | 286 type SeriesFile struct { struct 287 *tsdb.SeriesFile anonMember 291 func NewSeriesFile() *SeriesFile { 296 return &SeriesFile{SeriesFile: tsdb.NewSeriesFile(dir)} 300 func MustOpenSeriesFile() *SeriesFile { 309 func (f *SeriesFile) Close() error { argument 311 return f.SeriesFile.Close() 315 func (f *SeriesFile) Reopen() error { argument 316 if err := f.SeriesFile.Close(); err != nil { 319 f.SeriesFile = tsdb.NewSeriesFile(f.SeriesFile.Path())
|
H A D | partition_test.go | 19 p := NewPartition(sfile.SeriesFile) 45 p = NewPartition(sfile.SeriesFile) 78 p := MustOpenPartition(sfile.SeriesFile) 91 func NewPartition(sfile *tsdb.SeriesFile) *Partition { argument 96 func MustOpenPartition(sfile *tsdb.SeriesFile) *Partition { argument 116 sfile, path := p.SeriesFile(), p.Path()
|
H A D | index_test.go | 367 itr := tsdb.NewSeriesIteratorAdapter(idx.SeriesFile.SeriesFile, sitr) 535 SeriesFile *SeriesFile member 540 idx := &Index{SeriesFile: NewSeriesFile()} 541 idx.Index = tsi1.NewIndex(idx.SeriesFile.SeriesFile, "db0", tsi1.WithPath(MustTempDir())) 567 if err := idx.SeriesFile.Open(); err != nil { 576 if err := idx.SeriesFile.Close(); err != nil { 590 if err := idx.SeriesFile.Reopen(); err != nil { 595 idx.Index = tsi1.NewIndex(idx.SeriesFile.SeriesFile, "db0", tsi1.WithPath(idx.Index.Path())) 661 idx := tsi1.NewIndex(sfile.SeriesFile, "foo", 835 idx := &Index{SeriesFile: NewSeriesFile()} [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/tsdb/index/tsi1/ |
H A D | index_file_test.go | 19 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 39 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 89 f, err := GenerateIndexFile(sfile.SeriesFile, 10, 3, 4) 132 f, err := CreateIndexFile(sfile.SeriesFile, []Series{ 151 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 1, 2, 3)) 156 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 10, 5, 5)) 161 benchmarkIndexFile_TagValueSeries(b, MustFindOrGenerateIndexFile(sfile.SeriesFile, 10, 7, 7)) 179 func CreateIndexFile(sfile *tsdb.SeriesFile, series []Series) (*tsi1.IndexFile, error) { argument 201 func GenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) (*tsi1.IndexFile, er… argument 222 func MustGenerateIndexFile(sfile *tsdb.SeriesFile, measurementN, tagN, valueN int) *tsi1.IndexFile { argument [all …]
|
H A D | tsi1_test.go | 286 type SeriesFile struct { struct 287 *tsdb.SeriesFile anonMember 291 func NewSeriesFile() *SeriesFile { 296 return &SeriesFile{SeriesFile: tsdb.NewSeriesFile(dir)} 300 func MustOpenSeriesFile() *SeriesFile { 309 func (f *SeriesFile) Close() error { argument 311 return f.SeriesFile.Close() 315 func (f *SeriesFile) Reopen() error { argument 316 if err := f.SeriesFile.Close(); err != nil { 319 f.SeriesFile = tsdb.NewSeriesFile(f.SeriesFile.Path())
|
H A D | partition_test.go | 19 p := NewPartition(sfile.SeriesFile) 45 p = NewPartition(sfile.SeriesFile) 78 p := MustOpenPartition(sfile.SeriesFile) 91 func NewPartition(sfile *tsdb.SeriesFile) *Partition { argument 96 func MustOpenPartition(sfile *tsdb.SeriesFile) *Partition { argument 116 sfile, path := p.SeriesFile(), p.Path()
|
H A D | index_test.go | 369 itr := tsdb.NewSeriesIteratorAdapter(idx.SeriesFile.SeriesFile, sitr) 521 SeriesFile *SeriesFile member 526 idx := &Index{SeriesFile: NewSeriesFile()} 527 idx.Index = tsi1.NewIndex(idx.SeriesFile.SeriesFile, "db0", tsi1.WithPath(MustTempDir())) 553 if err := idx.SeriesFile.Open(); err != nil { 562 if err := idx.SeriesFile.Close(); err != nil { 576 if err := idx.SeriesFile.Reopen(); err != nil { 581 idx.Index = tsi1.NewIndex(idx.SeriesFile.SeriesFile, "db0", tsi1.WithPath(idx.Index.Path())) 647 idx := tsi1.NewIndex(sfile.SeriesFile, "foo", 821 idx := &Index{SeriesFile: NewSeriesFile()} [all …]
|
/dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/influxdata/influxdb/tsdb/index/inmem/ |
H A D | inmem_test.go | 28 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 46 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 64 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 81 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 100 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 120 *tsdb.SeriesFile anonMember 129 return &seriesFileWrapper{SeriesFile: tsdb.NewSeriesFile(dir)} 144 return f.SeriesFile.Close()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/influxdata/influxdb/tsdb/index/inmem/ |
H A D | inmem_test.go | 28 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 46 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 64 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 81 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 100 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 121 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 161 *tsdb.SeriesFile anonMember 170 return &seriesFileWrapper{SeriesFile: tsdb.NewSeriesFile(dir)} 185 return f.SeriesFile.Close()
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/tsdb/index/inmem/ |
H A D | inmem_test.go | 28 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 46 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 64 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 81 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 100 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 121 opt := tsdb.EngineOptions{InmemIndex: inmem.NewIndex("foo", sfile.SeriesFile)} 161 *tsdb.SeriesFile anonMember 170 return &seriesFileWrapper{SeriesFile: tsdb.NewSeriesFile(dir)} 185 return f.SeriesFile.Close()
|