Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + const IndexName + func NewShardIndex(id uint64, seriesIDSet *tsdb.SeriesIDSet, opt tsdb.EngineOptions) tsdb.Index + type FilterExprs map[uint64]influxql.Expr + func (fe FilterExprs) DeleteBoolLiteralTrues() + func (fe FilterExprs) Len() int + type Index struct + func NewIndex(database string, sfile *tsdb.SeriesFile) *Index + func (i *Index) Bytes() int + func (i *Index) Close() error + func (i *Index) CreateMeasurementIndexIfNotExists(name []byte) *measurement + func (i *Index) CreateSeriesListIfNotExists(seriesIDSet *tsdb.SeriesIDSet, measurements map[string]int, ...) error + func (i *Index) Database() string + func (i *Index) DiskSizeBytes() int64 + func (i *Index) DropMeasurement(name []byte) error + func (i *Index) DropMeasurementIfSeriesNotExist(name []byte) (bool, error) + func (i *Index) DropSeriesGlobal(key []byte) error + func (i *Index) FieldSet() *tsdb.MeasurementFieldSet + func (i *Index) ForEachMeasurementName(fn func(name []byte) error) error + func (i *Index) ForEachMeasurementTagKey(name []byte, fn func(key []byte) error) error + func (i *Index) HasTagKey(name, key []byte) (bool, error) + func (i *Index) HasTagValue(name, key, value []byte) (bool, error) + func (i *Index) Measurement(name []byte) (*measurement, error) + func (i *Index) MeasurementExists(name []byte) (bool, error) + func (i *Index) MeasurementIterator() (tsdb.MeasurementIterator, error) + func (i *Index) MeasurementNamesByExpr(auth query.Authorizer, expr influxql.Expr) ([][]byte, error) + func (i *Index) MeasurementNamesByRegex(re *regexp.Regexp) ([][]byte, error) + func (i *Index) MeasurementSeriesIDIterator(name []byte) (tsdb.SeriesIDIterator, error) + func (i *Index) MeasurementSeriesKeysByExpr(name []byte, condition influxql.Expr) ([][]byte, error) + func (i *Index) MeasurementSeriesKeysByExprIterator(name []byte, condition influxql.Expr) (tsdb.SeriesIDIterator, error) + func (i *Index) MeasurementTagKeyValuesByExpr(auth query.Authorizer, name []byte, keys []string, expr influxql.Expr, ...) ([][]string, error) + func (i *Index) MeasurementTagKeysByExpr(name []byte, expr influxql.Expr) (map[string]struct{}, error) + func (i *Index) MeasurementsByName(names [][]byte) ([]*measurement, error) + func (i *Index) MeasurementsSketches() (estimator.Sketch, estimator.Sketch, error) + func (i *Index) Open() (err error) + func (i *Index) Rebuild() + func (i *Index) Series(key []byte) (*series, error) + func (i *Index) SeriesIDIterator(opt query.IteratorOptions) (tsdb.SeriesIDIterator, error) + func (i *Index) SeriesKeys() []string + func (i *Index) SeriesSketches() (estimator.Sketch, estimator.Sketch, error) + func (i *Index) SetFieldName(measurement []byte, name string) + func (i *Index) SetFieldSet(fieldset *tsdb.MeasurementFieldSet) + func (i *Index) TagKeyCardinality(name, key []byte) int + func (i *Index) TagKeyHasAuthorizedSeries(auth query.Authorizer, name []byte, key string) bool + func (i *Index) TagKeyIterator(name []byte) (tsdb.TagKeyIterator, error) + func (i *Index) TagKeySeriesIDIterator(name, key []byte) (tsdb.SeriesIDIterator, error) + func (i *Index) TagSets(shardSeriesIDs *tsdb.SeriesIDSet, name []byte, opt query.IteratorOptions) ([]*query.TagSet, error) + func (i *Index) TagValueIterator(name, key []byte) (tsdb.TagValueIterator, error) + func (i *Index) TagValueN(name, key []byte) int + func (i *Index) TagValueSeriesIDIterator(name, key, value []byte) (tsdb.SeriesIDIterator, error) + func (i *Index) TagsForSeries(key string) (models.Tags, error) + func (i *Index) Type() string + func (i *Index) UniqueReferenceID() uintptr + func (i *Index) WithLogger(*zap.Logger) + type ShardIndex struct + func (idx *ShardIndex) CreateSeriesIfNotExists(key, name []byte, tags models.Tags) error + func (idx *ShardIndex) CreateSeriesListIfNotExists(keys, names [][]byte, tagsSlice []models.Tags) error + func (idx *ShardIndex) DropMeasurementIfSeriesNotExist(name []byte) (bool, error) + func (idx *ShardIndex) DropSeries(seriesID uint64, key []byte, _ bool) error + func (idx *ShardIndex) InitializeSeries(keys, names [][]byte, tags []models.Tags) error + func (idx *ShardIndex) SeriesIDSet() *tsdb.SeriesIDSet + func (idx *ShardIndex) SeriesN() int64 + func (idx *ShardIndex) TagSets(name []byte, opt query.IteratorOptions) ([]*query.TagSet, error) + type TagFilter struct + Key string + Op influxql.Token + Regex *regexp.Regexp + Value string