41 lines
1.1 KiB
Cheetah
41 lines
1.1 KiB
Cheetah
package tsm1
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/influxdata/influxdb/models"
|
|
"github.com/influxdata/influxdb/query"
|
|
"github.com/influxdata/influxdb/tsdb"
|
|
)
|
|
|
|
{{range .}}
|
|
|
|
// build{{.Name}}ArrayCursor creates an array cursor for a {{.name}} field.
|
|
func (q *arrayCursorIterator) build{{.Name}}ArrayCursor(ctx context.Context, name []byte, tags models.Tags, field string, opt query.IteratorOptions) (tsdb.{{.Name}}ArrayCursor, error) {
|
|
var err error
|
|
key := q.seriesFieldKeyBytes(name, tags, field)
|
|
cacheValues := q.e.Cache.Values(key)
|
|
keyCursor := q.e.KeyCursor(ctx, key, opt.SeekTime(), opt.Ascending)
|
|
if opt.Ascending {
|
|
if q.asc.{{.Name}} == nil {
|
|
q.asc.{{.Name}} = new{{.Name}}ArrayAscendingCursor()
|
|
}
|
|
err = q.asc.{{.Name}}.reset(opt.SeekTime(), opt.StopTime(), cacheValues, keyCursor)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return q.asc.{{.Name}}, nil
|
|
} else {
|
|
if q.desc.{{.Name}} == nil {
|
|
q.desc.{{.Name}} = new{{.Name}}ArrayDescendingCursor()
|
|
}
|
|
err = q.desc.{{.Name}}.reset(opt.SeekTime(), opt.StopTime(), cacheValues, keyCursor)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return q.desc.{{.Name}}, nil
|
|
}
|
|
}
|
|
|
|
{{end}}
|