inmem

package

Go to main page

Versions in this module

v1

v1.5.0

Mar 6, 2018

Changes in this version

type Index

+ func (i *Index) CreateSeriesListIfNotExists(shardID uint64, seriesIDSet *tsdb.SeriesIDSet, keys, names [][]byte, ...) error

+ func (i *Index) Database() string

+ func (i *Index) DiskSizeBytes() int64

+ func (i *Index) DropMeasurementIfSeriesNotExist(name []byte) error

+ func (i *Index) DropSeriesGlobal(key []byte, ts int64) error

+ func (i *Index) FieldSet() *tsdb.MeasurementFieldSet

+ func (i *Index) MeasurementIterator() (tsdb.MeasurementIterator, error)

+ func (i *Index) MeasurementSeriesIDIterator(name []byte) (tsdb.SeriesIDIterator, error)

+ func (i *Index) MeasurementSeriesKeysByExprIterator(name []byte, condition influxql.Expr) (tsdb.SeriesIDIterator, error)

+ func (i *Index) SeriesIDIterator(opt query.IteratorOptions) (tsdb.SeriesIDIterator, error)

+ func (i *Index) TagKeyIterator(name []byte) (tsdb.TagKeyIterator, error)

+ func (i *Index) TagKeySeriesIDIterator(name, key []byte) (tsdb.SeriesIDIterator, error)

+ func (i *Index) TagValueIterator(name, key []byte) (tsdb.TagValueIterator, error)

+ func (i *Index) TagValueSeriesIDIterator(name, key, value []byte) (tsdb.SeriesIDIterator, error)

type ShardIndex

+ func (idx *ShardIndex) DropMeasurementIfSeriesNotExist(name []byte) error

+ func (idx *ShardIndex) DropSeries(seriesID uint64, _ []byte, _ bool) error

+ func (idx *ShardIndex) SeriesIDSet() *tsdb.SeriesIDSet

+ func (idx *ShardIndex) SeriesN() int64

v1.4.3

Jan 30, 2018

Changes in this version

type Index

+ func (i *Index) TagKeyHasAuthorizedSeries(auth query.Authorizer, name []byte, key string) bool

type Measurement

+ func (m *Measurement) Authorized(auth query.Authorizer) bool

v1.4.2

Nov 15, 2017

v1.4.1

Nov 14, 2017

v1.3.9

Dec 19, 2017

v1.3.8

Dec 4, 2017

v1.3.6

Sep 28, 2017

v1.3.5

Aug 29, 2017

v1.3.4

Aug 23, 2017

v1.3.3

Aug 10, 2017

v1.3.2

Aug 4, 2017

Changes in this version

type Index

+ func (i *Index) MeasurementTagKeyValuesByExpr(name []byte, keys []string, expr influxql.Expr, keysSorted bool) ([][]string, error)

v1.3.1

Jul 20, 2017

v1.3.0

Jun 21, 2017

Changes in this version

+ const IndexName

+ func NewShardIndex(id uint64, database, path string, 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) *Index

+ func (i *Index) AssignShard(k string, shardID uint64)

+ func (i *Index) Close() error

+ func (i *Index) CreateMeasurementIndexIfNotExists(name []byte) *Measurement

+ func (i *Index) CreateSeriesIfNotExists(shardID uint64, key, name []byte, tags models.Tags, opt *tsdb.EngineOptions, ...) error

+ func (i *Index) DropMeasurement(name []byte) error

+ func (i *Index) DropSeries(key []byte) error

+ func (i *Index) ForEachMeasurementName(fn func(name []byte) error) error

+ func (i *Index) ForEachMeasurementSeriesByExpr(name []byte, expr influxql.Expr, fn func(tags models.Tags) 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

+ func (i *Index) Measurement(name []byte) (*Measurement, error)

+ func (i *Index) MeasurementExists(name []byte) (bool, error)

+ func (i *Index) MeasurementNamesByExpr(expr influxql.Expr) ([][]byte, error)

+ func (i *Index) MeasurementNamesByRegex(re *regexp.Regexp) ([][]byte, error)

+ func (i *Index) MeasurementSeriesKeysByExpr(name []byte, condition influxql.Expr) ([][]byte, 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) RemoveShard(shardID uint64)

+ func (i *Index) Series(key []byte) (*Series, error)

+ func (i *Index) SeriesKeys() []string

+ func (i *Index) SeriesN() int64

+ func (i *Index) SeriesPointIterator(opt influxql.IteratorOptions) (influxql.Iterator, error)

+ func (i *Index) SeriesSketches() (estimator.Sketch, estimator.Sketch, error)

+ func (i *Index) SetFieldName(measurement []byte, name string)

+ func (i *Index) SetFieldSet(*tsdb.MeasurementFieldSet)

+ func (i *Index) SnapshotTo(path string) error

+ func (i *Index) TagKeyCardinality(name, key []byte) int

+ func (i *Index) TagSets(shardID uint64, name []byte, opt influxql.IteratorOptions) ([]*influxql.TagSet, error)

+ func (i *Index) TagValueN(name, key []byte) int

+ func (i *Index) TagsForSeries(key string) (models.Tags, error)

+ func (i *Index) Type() string

+ func (i *Index) UnassignShard(k string, shardID uint64) error

+ func (i *Index) WithLogger(zap.Logger)

+ type Measurement struct

+ Name string

+ func NewMeasurement(database, name string) *Measurement

+ func (m *Measurement) AddSeries(s *Series) bool

+ func (m *Measurement) AppendSeriesKeysByID(dst []string, ids []uint64) []string

+ func (m *Measurement) Cardinality(key string) int

+ func (m *Measurement) CardinalityBytes(key []byte) int

+ func (m *Measurement) DropSeries(series *Series)

+ func (m *Measurement) FieldNames() []string

+ func (m *Measurement) ForEachSeriesByExpr(condition influxql.Expr, fn func(tags models.Tags) error) error

+ func (m *Measurement) HasField(name string) bool

+ func (m *Measurement) HasSeries() bool

+ func (m *Measurement) HasTagKey(k string) bool

+ func (m *Measurement) HasTagKeyValue(k, v []byte) bool

+ func (m *Measurement) IDsForExpr(n *influxql.BinaryExpr) SeriesIDs

+ func (m *Measurement) SeriesByID(id uint64) *Series

+ func (m *Measurement) SeriesByIDMap() map[uint64]*Series

+ func (m *Measurement) SeriesByIDSlice(ids []uint64) []*Series

+ func (m *Measurement) SeriesByTagKeyValue(key string) map[string]SeriesIDs

+ func (m *Measurement) SeriesIDs() SeriesIDs

+ func (m *Measurement) SeriesIDsAllOrByExpr(expr influxql.Expr) (SeriesIDs, error)

+ func (m *Measurement) SeriesKeys() [][]byte

+ func (m *Measurement) SeriesKeysByID(ids SeriesIDs) [][]byte

+ func (m *Measurement) SetFieldName(name string)

+ func (m *Measurement) TagKeys() []string

+ func (m *Measurement) TagKeysByExpr(expr influxql.Expr) (map[string]struct{}, error)

+ func (m *Measurement) TagSets(shardID uint64, opt influxql.IteratorOptions) ([]*influxql.TagSet, error)

+ func (m *Measurement) TagValues(key string) []string

+ func (m *Measurement) WalkTagKeys(fn func(k string))

+ func (m *Measurement) WalkWhereForSeriesIds(expr influxql.Expr) (SeriesIDs, FilterExprs, error)

+ type Measurements []*Measurement

+ func (a Measurements) Intersect(other Measurements) Measurements

+ func (a Measurements) Len() int

+ func (a Measurements) Less(i, j int) bool

+ func (a Measurements) Swap(i, j int)

+ func (a Measurements) Union(other Measurements) Measurements

+ type Series struct

+ ID uint64

+ Key string

+ func NewSeries(key []byte, tags models.Tags) *Series

+ func (s *Series) AssignShard(shardID uint64)

+ func (s *Series) Assigned(shardID uint64) bool

+ func (s *Series) CopyTags()

+ func (s *Series) ForEachTag(fn func(models.Tag))

+ func (s *Series) GetTagString(key string) string

+ func (s *Series) Measurement() *Measurement

+ func (s *Series) SetMeasurement(m *Measurement)

+ func (s *Series) ShardN() int

+ func (s *Series) Tags() models.Tags

+ func (s *Series) UnassignShard(shardID uint64)

+ type SeriesIDs []uint64

+ func (a SeriesIDs) Equals(other SeriesIDs) bool

+ func (a SeriesIDs) Intersect(other SeriesIDs) SeriesIDs

+ func (a SeriesIDs) Len() int

+ func (a SeriesIDs) Less(i, j int) bool

+ func (a SeriesIDs) Reject(other SeriesIDs) SeriesIDs

+ func (a SeriesIDs) Swap(i, j int)

+ func (a SeriesIDs) Union(other SeriesIDs) SeriesIDs

+ type ShardIndex struct

+ func (i *ShardIndex) CreateSeriesIfNotExists(key, name []byte, tags models.Tags) error

+ func (i *ShardIndex) InitializeSeries(key, name []byte, tags models.Tags) error

+ func (i *ShardIndex) TagSets(name []byte, opt influxql.IteratorOptions) ([]*influxql.TagSet, error)

+ func (idx *ShardIndex) CreateSeriesListIfNotExists(keys, names [][]byte, tagsSlice []models.Tags) error

+ type TagFilter struct

+ Key string

+ Op influxql.Token

+ Regex *regexp.Regexp

+ Value string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL