Home
last modified time | relevance | path

Searched refs:SeriesFile (Results 1 – 25 of 136) sorted by relevance

123456

/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/tsdb/
H A Dseries_file.go36 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 Dseries_file_test.go235 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 Dseries_file.go36 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 Dseries_file_test.go235 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 Dseries_file.go34 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 Dseries_file_test.go135 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 Dseries_file.go34 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 Dseries_file_test.go185 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 Dindex_file_test.go17 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 Dtsi1_test.go286 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 Dpartition_test.go19 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 Dindex_file_test.go17 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 Dtsi1_test.go286 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 Dpartition_test.go19 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 Dindex_file_test.go19 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 Dtsi1_test.go286 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 Dpartition_test.go19 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 Dindex_test.go367 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 Dindex_file_test.go19 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 Dtsi1_test.go286 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 Dpartition_test.go19 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 Dindex_test.go369 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 Dinmem_test.go28 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 Dinmem_test.go28 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 Dinmem_test.go28 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()

123456