tsdb

Sep 18, 2024

Changes in this version

type ShardError

+ func (e ShardError) Unwrap() error

Jun 13, 2024

Changes in this version

type Engine

+ InUse func() (bool, error)

+ SetNewReadersBlocked func(blocked bool) error

type Shard

+ func (s *Shard) InUse() (bool, error)

+ func (s *Shard) SetNewReadersBlocked(blocked bool) error

type Store

+ func (s *Store) SetShardNewReadersBlocked(shardID uint64, blocked bool) error

+ func (s *Store) ShardInUse(shardID uint64) (bool, error)

Dec 6, 2022

Changes in this version

+ const AddMeasurementField

+ const DeleteMeasurement

+ const FieldsChangeFile

+ type ChangeType int

+ type FieldChange struct

+ ChangeType ChangeType

+ type FieldChanges []*FieldChange

+ func MeasurementsToFieldChangeDeletions(measurements []string) FieldChanges

type MeasurementFieldSet

+ func (fs *MeasurementFieldSet) ApplyChanges() error

+ func (fs *MeasurementFieldSet) ChangesPath() string

+ func (fs *MeasurementFieldSet) WriteToFile() error

Dec 7, 2022

Changes in this version

type MeasurementFieldSet

+ func (fs *MeasurementFieldSet) MeasurementNames() []string

Aug 2, 2022

Changes in this version

+ type ErrPreviousShardFail struct

+ func (e ErrPreviousShardFail) Error() string

+ func (e ErrPreviousShardFail) Is(err error) bool

+ func (e ErrPreviousShardFail) Unwrap() error

type Store

+ func (s *Store) OpenShard(sh *Shard, force bool) error

+ func (s *Store) SetShardOpenErrorForTest(shardID uint64, err error)

Jan 31, 2022

Changes in this version

+ const DefaultMaxConcurrentDeletes

type Config

+ MaxConcurrentDeletes int

Sep 13, 2021

Changes in this version

+ const MaxFieldValueLength

+ func ValidateFields(mf *MeasurementFields, point models.Point, skipSizeValidation bool) error

type Config

+ SkipFieldSizeValidation bool

+ type MeasurementSliceIterator interface

+ UnderlyingSlice func() [][]byte

Jul 9, 2021

Changes in this version

type MeasurementFieldSet

+ func (fs *MeasurementFieldSet) Close()

+ func (fs *MeasurementFieldSet) SetMeasurementFieldSetWriter(queueLength int)

+ type MeasurementFieldSetWriter struct

+ func (w *MeasurementFieldSetWriter) Close()

+ func (w *MeasurementFieldSetWriter) RequestSave() error

May 17, 2021

Changes in this version

+ const CollectdUser

+ const GraphiteUser

+ const HintedHandoffUser

+ const MonitorUser

+ const OpenTsdbUser

+ const SelectIntoUser

+ const UdpUser

+ const UnknownUser

type Config

+ IngressMetricByLogin bool

+ IngressMetricByMeasurement bool

type IndexSet

+ func (is IndexSet) MeasurementSeriesKeyByExprIterator(name []byte, expr influxql.Expr, auth query.FineAuthorizer) (SeriesKeyIterator, error)

+ type IngressMetrics struct

+ func (i *IngressMetrics) AddMetric(measurement, db, rp, login string, points, values, series int64)

+ func (i *IngressMetrics) ForEach(f func(m MetricKey, points, values, series int64))

+ type MetricKey struct

+ type MetricValue struct

+ type SeriesKeyIterator interface

+ Close func() error

+ Next func() ([]byte, error)

+ type StatsTracker struct

+ AddedMeasurementPoints func(measurement []byte, points, values int64)

+ AddedMeasurementSeries func(measurement []byte, newSeries int64)

+ AddedPoints func(points, values int64)

+ AddedSeries func(newSeries int64)

+ func NoopStatsTracker() StatsTracker

+ type StoreStatistics struct

+ PointsWritten int64

+ SeriesCreated int64

+ ValuesWritten int64

+ type WriteContext struct

+ UserId string

Apr 19, 2021

Changes in this version

type Config

+ StrictErrorHandling bool

Sep 30, 2020

Changes in this version

+ const StatPointsWritten

+ const StatValuesWritten

+ type ConetextKey int

type IndexSet

+ func (is IndexSet) MeasurementNamesByPredicate(auth query.Authorizer, expr influxql.Expr) ([][]byte, error)

type Shard

+ func (s *Shard) MeasurementNamesByPredicate(expr influxql.Expr) ([][]byte, error)

+ func (s *Shard) WritePointsWithContext(ctx context.Context, points []models.Point) error

type ShardStatistics

+ WriteValuesOK int64

type Shards

+ func (a Shards) FieldKeysByPredicate(expr influxql.Expr) (map[string][]string, error)

+ func (a Shards) MeasurementNamesByPredicate(expr influxql.Expr) ([][]byte, error)

type Store

+ func (s *Store) WriteToShardWithContext(ctx context.Context, shardID uint64, points []models.Point) error

Jul 8, 2020

Changes in this version

type Index

+ DropSeriesList func(seriesID []uint64, key [][]byte, cascade bool) error

Apr 11, 2020

Changes in this version

+ const DefaultSeriesFileMaxConcurrentSnapshotCompactions

type Config

+ SeriesFileMaxConcurrentSnapshotCompactions int

type SeriesFile

+ func (f *SeriesFile) FileSize() (n int64, err error)

+ func (f *SeriesFile) WithMaxCompactionConcurrency(maxCompactionConcurrency int)

type SeriesPartition

+ func (p *SeriesPartition) FileSize() (n int64, err error)

+ func (p *SeriesPartition) Index() *SeriesIndex

+ func (p *SeriesPartition) Segments() []*SeriesSegment

type SeriesSegment

+ func (s *SeriesSegment) CompactToPath(path string, index *SeriesIndex) error

+ func (s *SeriesSegment) Path() string

Mar 11, 2021

Changes in this version

type SeriesIDSetIterator

+ func NewSeriesIDSetIteratorWithCloser(ss *SeriesIDSet, closer io.Closer) SeriesIDSetIterator

+ type SeriesIDSetIterators []SeriesIDSetIterator

+ func (a SeriesIDSetIterators) Close() (err error)

Mar 26, 2019 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 13, 2019 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultSeriesIDSetCacheSize

type Config

+ SeriesIDSetCacheSize int

Jan 13, 2019 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Dec 12, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ var ErrMultipleIndexTypes = errors.New(...)

+ type CursorStats = cursors.CursorStats

Nov 14, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 7, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultCompactThroughput

+ const DefaultCompactThroughputBurst

+ type BooleanArray = cursors.BooleanArray

+ func NewBooleanArrayLen(sz int) *BooleanArray

+ type BooleanArrayCursor = cursors.BooleanArrayCursor

type Config

+ CompactThroughput toml.Size

+ CompactThroughputBurst toml.Size

+ ValidateKeys bool

type EngineOptions

+ CompactionDisabled bool

+ type FloatArray = cursors.FloatArray

+ func NewFloatArrayLen(sz int) *FloatArray

+ type FloatArrayCursor = cursors.FloatArrayCursor

+ type IntegerArray = cursors.IntegerArray

+ func NewIntegerArrayLen(sz int) *IntegerArray

+ type IntegerArrayCursor = cursors.IntegerArrayCursor

type SeriesIDSet

+ func (s *SeriesIDSet) AddMany(ids ...uint64)

+ func (s *SeriesIDSet) Clear()

+ func (s *SeriesIDSet) ClearNoLock()

+ func (s *SeriesIDSet) MergeInPlace(other *SeriesIDSet)

+ func (s *SeriesIDSet) SetCOW(b bool)

+ func (s *SeriesIDSet) Slice() []uint64

+ func (s *SeriesIDSet) UnmarshalBinaryUnsafe(data []byte) error

type Shard

+ CompactionDisabled bool

+ type StringArray = cursors.StringArray

+ func NewStringArrayLen(sz int) *StringArray

+ type StringArrayCursor = cursors.StringArrayCursor

+ type UnsignedArray = cursors.UnsignedArray

+ func NewUnsignedArrayLen(sz int) *UnsignedArray

+ type UnsignedArrayCursor = cursors.UnsignedArrayCursor

Feb 28, 2019 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 9, 2019 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Oct 24, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Sep 14, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 27, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 4, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ func IsValidSeriesEntryFlag(flag byte) bool

type Config

+ TSMWillNeed bool

type SeriesIDSet

+ func (s *SeriesIDSet) And(other *SeriesIDSet) *SeriesIDSet

+ func (s *SeriesIDSet) Clone() *SeriesIDSet

+ func (s *SeriesIDSet) CloneNoLock() *SeriesIDSet

+ func (s *SeriesIDSet) ForEachNoLock(f func(id uint64))

+ func (s *SeriesIDSet) Iterator() SeriesIDSetIterable

+ type SeriesIDSetIterable interface

+ HasNext func() bool

+ Next func() uint32

+ type SeriesIDSetIterator interface

+ SeriesIDSet func() *SeriesIDSet

+ func NewSeriesIDSetIterator(ss *SeriesIDSet) SeriesIDSetIterator

+ func NewSeriesIDSetIterators(itrs []SeriesIDIterator) []SeriesIDSetIterator

type SeriesIDSliceIterator

+ func (itr *SeriesIDSliceIterator) SeriesIDSet() *SeriesIDSet

type ShardGroup

+ FieldKeysByMeasurement func(name []byte) []string

type Shards

+ func (a Shards) FieldKeysByMeasurement(name []byte) []string

Aug 6, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 9, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jun 28, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ var ErrUnknownFieldType = errors.New("unknown field type")

+ type CompactionPlannerCreator func(cfg Config) interface

+ type CursorIterator interface

+ Next func(ctx context.Context, r *CursorRequest) (Cursor, error)

+ type CursorIterators []CursorIterator

+ func CreateCursorIterators(ctx context.Context, shards []*Shard) (CursorIterators, error)

type CursorRequest

+ Name []byte

+ Tags models.Tags

type Engine

+ CreateCursorIterator func(ctx context.Context) (CursorIterator, error)

+ DeleteSeriesRangeWithPredicate func(itr SeriesIterator, ...) error

type EngineOptions

+ CompactionPlannerCreator CompactionPlannerCreator

+ DatabaseFilter func(database string) bool

+ FieldValidator FieldValidator

+ FileStoreObserver FileStoreObserver

+ MonitorDisabled bool

+ OnNewEngine func(Engine)

+ OpenLimiter limiter.Fixed

+ RetentionPolicyFilter func(database, rp string) bool

+ ShardFilter func(database, rp string, id uint64) bool

+ WALEnabled bool

+ type FieldValidator interface

+ Validate func(mf *MeasurementFields, point models.Point) error

+ type FileStoreObserver interface

+ FileFinishing func(path string) error

+ FileUnlinking func(path string) error

type Index

+ Bytes func() int

+ SeriesIDSet func() *SeriesIDSet

+ UniqueReferenceID func() uintptr

type IndexSet

+ func (is IndexSet) HasInmemIndex() bool

type MeasurementFieldSet

+ func (fs *MeasurementFieldSet) Bytes() int

+ type SeriesCursor interface

+ Close func() error

+ Next func() (*SeriesCursorRow, error)

+ type SeriesCursorRequest struct

+ Measurements MeasurementIterator

+ type SeriesCursorRow struct

+ Name []byte

+ Tags models.Tags

+ func (r *SeriesCursorRow) Compare(other *SeriesCursorRow) int

type SeriesIDSet

+ func (s *SeriesIDSet) Bytes() int

type SeriesPartition

+ func (p *SeriesPartition) Compacting() bool

type SeriesSegment

+ func (s *SeriesSegment) Data() []byte

type Shard

+ func (s *Shard) CreateCursorIterator(ctx context.Context) (CursorIterator, error)

+ func (s *Shard) CreateSeriesCursor(ctx context.Context, req SeriesCursorRequest, cond influxql.Expr) (SeriesCursor, error)

+ func (s *Shard) DeleteSeriesRangeWithPredicate(itr SeriesIterator, ...) error

type Shards

+ func (a Shards) CallType(name string, args []influxql.DataType) (influxql.DataType, error)

+ func (a Shards) CreateSeriesCursor(ctx context.Context, req SeriesCursorRequest, cond influxql.Expr) (_ SeriesCursor, err error)

type Store

+ func (s *Store) IndexBytes() int

Dec 19, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const InmemIndexName

+ const TSI1IndexName

+ var ErrIndexClosing = errors.New("index is closing")

+ func ParseSeriesKeyInto(data []byte, dstTags models.Tags) ([]byte, models.Tags)

type Index

+ DropSeriesGlobal func(key []byte) error

type Shard

+ func (s *Shard) Engine() (Engine, error)

+ func (s *Shard) SeriesFile() (*SeriesFile, error)

Jun 21, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 25, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ var ErrShardDeletion = errors.New("shard is being deleted")

Apr 12, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultMaxIndexLogFileSize

type Config

+ MaxIndexLogFileSize toml.Size

Mar 20, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type IndexSet

+ func (is IndexSet) HasField(measurement []byte, field string) bool

type MeasurementFieldSet

+ func (fs *MeasurementFieldSet) FieldsByString(name string) *MeasurementFields

Mar 6, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultSeriesPartitionCompactThreshold

+ const SeriesEntryFlagSize

+ const SeriesEntryHeaderSize

+ const SeriesEntryInsertFlag

+ const SeriesEntryTombstoneFlag

+ const SeriesFileDirectory

+ const SeriesFilePartitionN

+ const SeriesIDSize

+ const SeriesIndexElemSize

+ const SeriesIndexHeaderSize

+ const SeriesIndexLoadFactor

+ const SeriesIndexMagic

+ const SeriesIndexVersion

+ const SeriesSegmentHeaderSize

+ const SeriesSegmentMagic

+ const SeriesSegmentVersion

+ var ErrInvalidSeriesIndex = errors.New("invalid series index")

+ var ErrInvalidSeriesPartitionID = errors.New("tsdb: invalid series partition id")

+ var ErrInvalidSeriesSegment = errors.New("invalid series segment")

+ var ErrInvalidSeriesSegmentVersion = errors.New("invalid series segment version")

+ var ErrSeriesFileClosed = errors.New("tsdb: series file closed")

+ var ErrSeriesPartitionClosed = errors.New("tsdb: series partition closed")

+ var ErrSeriesPartitionCompactionCancelled = errors.New("tsdb: series partition compaction cancelled")

+ var ErrSeriesSegmentNotWritable = errors.New("series segment not writable")

+ var ErrShardNotIdle = errors.New("shard not idle")

+ var ErrUnknownFieldsFormat = errors.New("unknown field index format")

+ func AppendSeriesEntry(dst []byte, flag uint8, id uint64, key []byte) []byte

+ func AppendSeriesKey(dst []byte, name []byte, tags models.Tags) []byte

+ func CompareSeriesKeys(a, b []byte) int

+ func GenerateSeriesKeys(names [][]byte, tagsSlice []models.Tags) [][]byte

+ func IsValidSeriesSegmentFilename(filename string) bool

+ func JoinSeriesOffset(segmentID uint16, pos uint32) int64

+ func NewMeasurementSliceIterator(names [][]byte) *measurementSliceIterator

+ func NewSeriesPointIterator(indexSet IndexSet, fieldset *MeasurementFieldSet, opt query.IteratorOptions) (_ query.Iterator, err error)

+ func NewSeriesQueryAdapterIterator(sfile *SeriesFile, itr SeriesIDIterator, fieldset *MeasurementFieldSet, ...) query.Iterator

+ func NewTagKeySliceIterator(keys [][]byte) *tagKeySliceIterator

+ func NewTagValueSliceIterator(values [][]byte) *tagValueSliceIterator

+ func ParseSeriesKey(data []byte) (name []byte, tags models.Tags)

+ func ParseSeriesSegmentFilename(filename string) (uint16, error)

+ func ReadAllSeriesIDIterator(itr SeriesIDIterator) ([]uint64, error)

+ func ReadSeriesEntry(data []byte) (flag uint8, id uint64, key []byte, sz int64)

+ func ReadSeriesKey(data []byte) (key, remainder []byte)

+ func ReadSeriesKeyFromSegments(a []*SeriesSegment, offset int64) []byte

+ func ReadSeriesKeyLen(data []byte) (sz int, remainder []byte)

+ func ReadSeriesKeyMeasurement(data []byte) (name, remainder []byte)

+ func ReadSeriesKeyTag(data []byte) (key, value, remainder []byte)

+ func ReadSeriesKeyTagN(data []byte) (n int, remainder []byte)

+ func SeriesKeySize(name []byte, tags models.Tags) int

+ func SeriesKeysSize(names [][]byte, tagsSlice []models.Tags) int

+ func SeriesSegmentSize(id uint16) uint32

+ func SplitSeriesOffset(offset int64) (segmentID uint16, pos uint32)

type Engine

+ Digest func() (io.ReadCloser, int64, error)

+ Export func(w io.Writer, basePath string, start time.Time, end time.Time) error

+ MeasurementFieldSet func() *MeasurementFieldSet

+ ScheduleFullCompaction func() error

type EngineOptions

+ SeriesIDSets SeriesIDSets

type Index

+ Database func() string

+ DiskSizeBytes func() int64

+ DropMeasurementIfSeriesNotExist func(name []byte) error

+ FieldSet func() *MeasurementFieldSet

+ HasTagValue func(name, key, value []byte) (bool, error)

+ MeasurementIterator func() (MeasurementIterator, error)

+ MeasurementSeriesIDIterator func(name []byte) (SeriesIDIterator, error)

+ TagKeyIterator func(name []byte) (TagKeyIterator, error)

+ TagKeySeriesIDIterator func(name, key []byte) (SeriesIDIterator, error)

+ TagValueIterator func(name, key []byte) (TagValueIterator, error)

+ TagValueSeriesIDIterator func(name, key, value []byte) (SeriesIDIterator, error)

+ type IndexSet struct

+ Indexes []Index

+ SeriesFile *SeriesFile

+ func (is IndexSet) Database() string

+ func (is IndexSet) DedupeInmemIndexes() IndexSet

+ func (is IndexSet) FieldSet() *MeasurementFieldSet

+ func (is IndexSet) ForEachMeasurementTagKey(name []byte, fn func(key []byte) error) error

+ func (is IndexSet) HasTagKey(name, key []byte) (bool, error)

+ func (is IndexSet) HasTagValue(name, key, value []byte) (bool, error)

+ func (is IndexSet) MatchTagValueSeriesIDIterator(name, key []byte, value *regexp.Regexp, matches bool) (SeriesIDIterator, error)

+ func (is IndexSet) MeasurementIterator() (MeasurementIterator, error)

+ func (is IndexSet) MeasurementNamesByExpr(auth query.Authorizer, expr influxql.Expr) ([][]byte, error)

+ func (is IndexSet) MeasurementSeriesByExprIterator(name []byte, expr influxql.Expr) (SeriesIDIterator, error)

+ func (is IndexSet) MeasurementSeriesIDIterator(name []byte) (SeriesIDIterator, error)

+ func (is IndexSet) MeasurementSeriesKeysByExpr(name []byte, expr influxql.Expr) ([][]byte, error)

+ func (is IndexSet) MeasurementTagKeyValuesByExpr(auth query.Authorizer, name []byte, keys []string, expr influxql.Expr, ...) ([][]string, error)

+ func (is IndexSet) MeasurementTagKeysByExpr(name []byte, expr influxql.Expr) (map[string]struct{}, error)

+ func (is IndexSet) TagKeyHasAuthorizedSeries(auth query.Authorizer, name, tagKey []byte) (bool, error)

+ func (is IndexSet) TagKeyIterator(name []byte) (TagKeyIterator, error)

+ func (is IndexSet) TagKeySeriesIDIterator(name, key []byte) (SeriesIDIterator, error)

+ func (is IndexSet) TagSets(sfile *SeriesFile, name []byte, opt query.IteratorOptions) ([]*query.TagSet, error)

+ func (is IndexSet) TagValueIterator(name, key []byte) (TagValueIterator, error)

+ func (is IndexSet) TagValueSeriesIDIterator(name, key, value []byte) (SeriesIDIterator, error)

+ func (is IndexSet) TagValuesByKeyAndExpr(auth query.Authorizer, name []byte, keys []string, expr influxql.Expr, ...) ([]map[string]struct{}, error)

type MeasurementFieldSet

+ func (fs *MeasurementFieldSet) IsEmpty() bool

+ func (fs *MeasurementFieldSet) Save() error

type MeasurementFields

+ func (m *MeasurementFields) ForEachField(fn func(name string, typ influxql.DataType) bool)

type MeasurementIterator

+ func MergeMeasurementIterators(itrs ...MeasurementIterator) MeasurementIterator

+ type MeasurementIterators []MeasurementIterator

+ func (a MeasurementIterators) Close() (err error)

+ type SeriesElem interface

+ Deleted func() bool

+ Expr func() influxql.Expr

+ Name func() []byte

+ Tags func() models.Tags

+ type SeriesFile struct

+ Logger *zap.Logger

+ func NewSeriesFile(path string) *SeriesFile

+ func (f *SeriesFile) Close() (err error)

+ func (f *SeriesFile) CreateSeriesListIfNotExists(names [][]byte, tagsSlice []models.Tags, buf []byte) (ids []uint64, err error)

+ func (f *SeriesFile) DeleteSeriesID(id uint64) error

+ func (f *SeriesFile) DisableCompactions()

+ func (f *SeriesFile) EnableCompactions()

+ func (f *SeriesFile) HasSeries(name []byte, tags models.Tags, buf []byte) bool

+ func (f *SeriesFile) IsDeleted(id uint64) bool

+ func (f *SeriesFile) Open() error

+ func (f *SeriesFile) Partitions() []*SeriesPartition

+ func (f *SeriesFile) Path() string

+ func (f *SeriesFile) Retain() func()

+ func (f *SeriesFile) Series(id uint64) ([]byte, models.Tags)

+ func (f *SeriesFile) SeriesCount() uint64

+ func (f *SeriesFile) SeriesID(name []byte, tags models.Tags, buf []byte) uint64

+ func (f *SeriesFile) SeriesIDIterator() SeriesIDIterator

+ func (f *SeriesFile) SeriesIDPartition(id uint64) *SeriesPartition

+ func (f *SeriesFile) SeriesIDPartitionID(id uint64) int

+ func (f *SeriesFile) SeriesKey(id uint64) []byte

+ func (f *SeriesFile) SeriesKeyPartition(key []byte) *SeriesPartition

+ func (f *SeriesFile) SeriesKeyPartitionID(key []byte) int

+ func (f *SeriesFile) SeriesKeys(ids []uint64) [][]byte

+ func (f *SeriesFile) SeriesKeysPartitionIDs(keys [][]byte) []int

+ func (f *SeriesFile) SeriesPartitionPath(i int) string

+ func (f *SeriesFile) Wait()

+ type SeriesIDElem struct

+ Expr influxql.Expr

+ SeriesID uint64

+ type SeriesIDElems []SeriesIDElem

+ func (a SeriesIDElems) Len() int

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

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

+ type SeriesIDIterator interface

+ Close func() error

+ Next func() (SeriesIDElem, error)

+ func DifferenceSeriesIDIterators(itr0, itr1 SeriesIDIterator) SeriesIDIterator

+ func FilterUndeletedSeriesIDIterator(sfile *SeriesFile, itr SeriesIDIterator) SeriesIDIterator

+ func IntersectSeriesIDIterators(itr0, itr1 SeriesIDIterator) SeriesIDIterator

+ func MergeSeriesIDIterators(itrs ...SeriesIDIterator) SeriesIDIterator

+ func UnionSeriesIDIterators(itr0, itr1 SeriesIDIterator) SeriesIDIterator

+ type SeriesIDIterators []SeriesIDIterator

+ func (a SeriesIDIterators) Close() (err error)

+ type SeriesIDSet struct

+ func NewSeriesIDSet() *SeriesIDSet

+ func (s *SeriesIDSet) Add(id uint64)

+ func (s *SeriesIDSet) AddNoLock(id uint64)

+ func (s *SeriesIDSet) AndNot(other *SeriesIDSet) *SeriesIDSet

+ func (s *SeriesIDSet) Cardinality() uint64

+ func (s *SeriesIDSet) Contains(id uint64) bool

+ func (s *SeriesIDSet) ContainsNoLock(id uint64) bool

+ func (s *SeriesIDSet) Diff(other *SeriesIDSet)

+ func (s *SeriesIDSet) Equals(other *SeriesIDSet) bool

+ func (s *SeriesIDSet) ForEach(f func(id uint64))

+ func (s *SeriesIDSet) Merge(others ...*SeriesIDSet)

+ func (s *SeriesIDSet) Remove(id uint64)

+ func (s *SeriesIDSet) RemoveNoLock(id uint64)

+ func (s *SeriesIDSet) String() string

+ func (s *SeriesIDSet) UnmarshalBinary(data []byte) error

+ func (s *SeriesIDSet) WriteTo(w io.Writer) (int64, error)

+ type SeriesIDSets interface

+ ForEach func(f func(ids *SeriesIDSet)) error

+ type SeriesIDSliceIterator struct

+ func NewSeriesIDSliceIterator(ids []uint64) *SeriesIDSliceIterator

+ func (itr *SeriesIDSliceIterator) Close() error

+ func (itr *SeriesIDSliceIterator) Next() (SeriesIDElem, error)

+ type SeriesIndex struct

+ func NewSeriesIndex(path string) *SeriesIndex

+ func (idx *SeriesIndex) Clone() *SeriesIndex

+ func (idx *SeriesIndex) Close() (err error)

+ func (idx *SeriesIndex) Count() uint64

+ func (idx *SeriesIndex) Delete(id uint64)

+ func (idx *SeriesIndex) FindIDByNameTags(segments []*SeriesSegment, name []byte, tags models.Tags, buf []byte) uint64

+ func (idx *SeriesIndex) FindIDBySeriesKey(segments []*SeriesSegment, key []byte) uint64

+ func (idx *SeriesIndex) FindIDListByNameTags(segments []*SeriesSegment, names [][]byte, tagsSlice []models.Tags, buf []byte) (ids []uint64, ok bool)

+ func (idx *SeriesIndex) FindOffsetByID(id uint64) int64

+ func (idx *SeriesIndex) InMemCount() uint64

+ func (idx *SeriesIndex) Insert(key []byte, id uint64, offset int64)

+ func (idx *SeriesIndex) IsDeleted(id uint64) bool

+ func (idx *SeriesIndex) OnDiskCount() uint64

+ func (idx *SeriesIndex) Open() (err error)

+ func (idx *SeriesIndex) Recover(segments []*SeriesSegment) error

+ type SeriesIndexHeader struct

+ Capacity int64

+ Count uint64

+ IDOffsetMap struct{ ... }

+ KeyIDMap struct{ ... }

+ MaxOffset int64

+ MaxSeriesID uint64

+ Version uint8

+ func NewSeriesIndexHeader() SeriesIndexHeader

+ func ReadSeriesIndexHeader(data []byte) (hdr SeriesIndexHeader, err error)

+ func (hdr *SeriesIndexHeader) WriteTo(w io.Writer) (n int64, err error)

+ type SeriesIterator interface

+ Close func() error

+ Next func() (SeriesElem, error)

+ func NewSeriesIteratorAdapter(sfile *SeriesFile, itr SeriesIDIterator) SeriesIterator

+ type SeriesPartition struct

+ CompactThreshold int

+ Logger *zap.Logger

+ func NewSeriesPartition(id int, path string) *SeriesPartition

+ func (p *SeriesPartition) AppendSeriesIDs(a []uint64) []uint64

+ func (p *SeriesPartition) Close() (err error)

+ func (p *SeriesPartition) CreateSeriesListIfNotExists(keys [][]byte, keyPartitionIDs []int, ids []uint64) error

+ func (p *SeriesPartition) DeleteSeriesID(id uint64) error

+ func (p *SeriesPartition) DisableCompactions()

+ func (p *SeriesPartition) EnableCompactions()

+ func (p *SeriesPartition) FindIDBySeriesKey(key []byte) uint64

+ func (p *SeriesPartition) ID() int

+ func (p *SeriesPartition) IndexPath() string

+ func (p *SeriesPartition) IsDeleted(id uint64) bool

+ func (p *SeriesPartition) Open() error

+ func (p *SeriesPartition) Path() string

+ func (p *SeriesPartition) Series(id uint64) ([]byte, models.Tags)

+ func (p *SeriesPartition) SeriesCount() uint64

+ func (p *SeriesPartition) SeriesKey(id uint64) []byte

+ type SeriesPartitionCompactor struct

+ func NewSeriesPartitionCompactor() *SeriesPartitionCompactor

+ func (c *SeriesPartitionCompactor) Compact(p *SeriesPartition) error

+ type SeriesSegment struct

+ func CloneSeriesSegments(a []*SeriesSegment) []*SeriesSegment

+ func CreateSeriesSegment(id uint16, path string) (*SeriesSegment, error)

+ func FindSegment(a []*SeriesSegment, id uint16) *SeriesSegment

+ func NewSeriesSegment(id uint16, path string) *SeriesSegment

+ func (s *SeriesSegment) AppendSeriesIDs(a []uint64) []uint64

+ func (s *SeriesSegment) CanWrite(data []byte) bool

+ func (s *SeriesSegment) Clone() *SeriesSegment

+ func (s *SeriesSegment) Close() (err error)

+ func (s *SeriesSegment) CloseForWrite() (err error)

+ func (s *SeriesSegment) Flush() error

+ func (s *SeriesSegment) ForEachEntry(fn func(flag uint8, id uint64, offset int64, key []byte) error) error

+ func (s *SeriesSegment) ID() uint16

+ func (s *SeriesSegment) InitForWrite() (err error)

+ func (s *SeriesSegment) MaxSeriesID() uint64

+ func (s *SeriesSegment) Open() error

+ func (s *SeriesSegment) Size() int64

+ func (s *SeriesSegment) Slice(pos uint32) []byte

+ func (s *SeriesSegment) WriteLogEntry(data []byte) (offset int64, err error)

+ type SeriesSegmentHeader struct

+ Version uint8

+ func NewSeriesSegmentHeader() SeriesSegmentHeader

+ func ReadSeriesSegmentHeader(data []byte) (hdr SeriesSegmentHeader, err error)

+ func (hdr *SeriesSegmentHeader) WriteTo(w io.Writer) (n int64, err error)

type Shard

+ func (s *Shard) Digest() (io.ReadCloser, int64, error)

+ func (s *Shard) Export(w io.Writer, basePath string, start time.Time, end time.Time) error

+ func (s *Shard) ScheduleFullCompaction() error

type Store

+ SeriesFileMaxSize int64

+ func (s *Store) ExportShard(id uint64, start time.Time, end time.Time, w io.Writer) error

+ func (s *Store) MeasurementsSketches(database string) (estimator.Sketch, estimator.Sketch, error)

+ func (s *Store) SeriesSketches(database string) (estimator.Sketch, estimator.Sketch, error)

+ func (s *Store) ShardDigest(id uint64) (io.ReadCloser, int64, error)

+ type TagKeyIterator interface

+ Close func() error

+ Next func() ([]byte, error)

+ func MergeTagKeyIterators(itrs ...TagKeyIterator) TagKeyIterator

+ type TagKeyIterators []TagKeyIterator

+ func (a TagKeyIterators) Close() (err error)

+ type TagValueIterator interface

+ Close func() error

+ Next func() ([]byte, error)

+ func MergeTagValueIterators(itrs ...TagValueIterator) TagValueIterator

+ type TagValueIterators []TagValueIterator

+ func (a TagValueIterators) Close() (err error)

Jan 30, 2018 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Engine

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

type EngineOptions

+ CompactionThroughputLimiter limiter.Rate

type Index

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

type Shard

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

Nov 15, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 14, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 13, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ type BooleanBatchCursor interface

+ Next func() (keys []int64, values []bool)

type Cursor

+ Close func()

+ Err func() error

+ SeriesKey func() string

+ type CursorRequest struct

+ Ascending bool

+ EndTime int64

+ Field string

+ Measurement string

+ Series string

+ StartTime int64

type Engine

+ CreateCursor func(ctx context.Context, r *CursorRequest) (Cursor, error)

+ Free func() error

+ IteratorCost func(measurement string, opt query.IteratorOptions) (query.IteratorCost, error)

+ type FloatBatchCursor interface

+ Next func() (keys []int64, values []float64)

type Index

+ Rebuild func()

+ type IntegerBatchCursor interface

+ Next func() (keys []int64, values []int64)

type MeasurementFields

+ func (m *MeasurementFields) FieldKeys() []string

type Shard

+ func (s *Shard) CreateCursor(ctx context.Context, r *CursorRequest) (Cursor, error)

+ func (s *Shard) Free() error

+ func (s *Shard) Index() Index

type ShardGroup

+ IteratorCost func(measurement string, opt query.IteratorOptions) (query.IteratorCost, error)

type Shards

+ func (a Shards) IteratorCost(measurement string, opt query.IteratorOptions) (query.IteratorCost, error)

type Store

+ func (s *Store) TagKeys(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]TagKeys, error)

+ type StringBatchCursor interface

+ Next func() (keys []int64, values []string)

+ type TagKeys struct

+ Keys []string

+ Measurement string

+ type TagKeysSlice []TagKeys

+ func (a TagKeysSlice) Len() int

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

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

+ type UnsignedBatchCursor interface

+ Next func() (keys []int64, values []uint64)

Dec 19, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Dec 4, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Oct 26, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Sep 28, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Shard

+ func (s *Shard) Backup(w io.Writer, basePath string, since time.Time) error

+ func (s *Shard) ForEachMeasurementName(fn func(name []byte) error) error

+ func (s *Shard) MeasurementNamesByRegex(re *regexp.Regexp) ([][]byte, error)

+ func (s *Shard) MeasurementSeriesKeysByExpr(name []byte, expr influxql.Expr) ([][]byte, error)

+ func (s *Shard) MeasurementTagKeyValuesByExpr(name []byte, key []string, expr influxql.Expr, keysSorted bool) ([][]string, error)

+ func (s *Shard) MeasurementTagKeysByExpr(name []byte, expr influxql.Expr) (map[string]struct{}, error)

Aug 29, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 23, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 10, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 4, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Engine

+ MeasurementTagKeyValuesByExpr func(name []byte, key []string, expr influxql.Expr, keysSorted bool) ([][]string, error)

type Index

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

Jul 20, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jun 21, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultIndex

+ const DefaultMaxConcurrentCompactions

+ var NewInmemIndex func(name string) (interface{}, error)

+ func MakeTagsKey(keys []string, tags models.Tags) []byte

+ func RegisterIndex(name string, fn NewIndexFunc)

+ func RegisteredIndexes() []string

type Config

+ Index string

+ MaxConcurrentCompactions int

+ WALFsyncDelay toml.Duration

+ func (c Config) Diagnostics() (*diagnostics.Diagnostics, error)

type Engine

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

+ CreateSeriesListIfNotExists func(keys, names [][]byte, tags []models.Tags) error

+ DiskSize func() int64

+ ForEachMeasurementName func(fn func(name []byte) error) error

+ ForEachMeasurementSeriesByExpr func(name []byte, expr influxql.Expr, fn func(tags models.Tags) error) error

+ ForEachMeasurementTagKey func(name []byte, fn func(key []byte) error) error

+ HasTagKey func(name, key []byte) (bool, error)

+ Import func(r io.Reader, basePath string) error

+ IsIdle func() bool

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

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

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

+ MeasurementSeriesKeysByExpr func(name []byte, condition influxql.Expr) ([][]byte, error)

+ MeasurementTagKeysByExpr func(name []byte, expr influxql.Expr) (map[string]struct{}, error)

+ MeasurementsSketches func() (estimator.Sketch, estimator.Sketch, error)

+ SeriesN func() int64

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

+ SeriesSketches func() (estimator.Sketch, estimator.Sketch, error)

+ SetCompactionsEnabled func(enabled bool)

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

type EngineOptions

+ CompactionLimiter limiter.Fixed

+ IndexVersion string

+ InmemIndex interface{}

+ type Index interface

+ AssignShard func(k string, shardID uint64)

+ Close func() error

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

+ CreateSeriesListIfNotExists func(keys, names [][]byte, tags []models.Tags) error

+ DropMeasurement func(name []byte) error

+ DropSeries func(key []byte) error

+ ForEachMeasurementName func(fn func(name []byte) error) error

+ ForEachMeasurementSeriesByExpr func(name []byte, expr influxql.Expr, fn func(tags models.Tags) error) error

+ ForEachMeasurementTagKey func(name []byte, fn func(key []byte) error) error

+ HasTagKey func(name, key []byte) (bool, error)

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

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

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

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

+ MeasurementSeriesKeysByExpr func(name []byte, condition influxql.Expr) ([][]byte, error)

+ MeasurementTagKeysByExpr func(name []byte, expr influxql.Expr) (map[string]struct{}, error)

+ MeasurementsSketches func() (estimator.Sketch, estimator.Sketch, error)

+ Open func() error

+ RemoveShard func(shardID uint64)

+ SeriesN func() int64

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

+ SeriesSketches func() (estimator.Sketch, estimator.Sketch, error)

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

+ SetFieldSet func(fs *MeasurementFieldSet)

+ SnapshotTo func(path string) error

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

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

+ Type func() string

+ UnassignShard func(k string, shardID uint64) error

+ WithLogger func(zap.Logger)

+ func MustOpenIndex(id uint64, database, path string, options EngineOptions) Index

+ func NewIndex(id uint64, database, path string, options EngineOptions) (Index, error)

+ type IndexFormat int

+ const InMemFormat

+ const TSI1Format

+ type LimitError struct

+ Reason string

+ func (e *LimitError) Error() string

+ type MeasurementFieldSet struct

+ func NewMeasurementFieldSet() *MeasurementFieldSet

+ func (fs *MeasurementFieldSet) CreateFieldsIfNotExists(name []byte) *MeasurementFields

+ func (fs *MeasurementFieldSet) Delete(name string)

+ func (fs *MeasurementFieldSet) DeleteWithLock(name string, fn func() error) error

+ func (fs *MeasurementFieldSet) Fields(name string) *MeasurementFields

type MeasurementFields

+ func (m *MeasurementFields) Clone() *MeasurementFields

+ func (m *MeasurementFields) FieldN() int

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

+ type NewIndexFunc func(id uint64, database, path string, options EngineOptions) Index

type PartialWriteError

+ DroppedKeys map[string]struct{}

type Shard

+ func (s *Shard) CloseFast() error

+ func (s *Shard) Database() string

+ func (s *Shard) ForEachMeasurementTagKey(name []byte, fn func(key []byte) error) error

+ func (s *Shard) ID() uint64

+ func (s *Shard) Import(r io.Reader, basePath string) error

+ func (s *Shard) IndexType() string

+ func (s *Shard) IsIdle() bool

+ func (s *Shard) MeasurementExists(name []byte) (bool, error)

+ func (s *Shard) MeasurementFields(name []byte) *MeasurementFields

+ func (s *Shard) MeasurementNamesByExpr(cond influxql.Expr) ([][]byte, error)

+ func (s *Shard) MeasurementsSketches() (estimator.Sketch, estimator.Sketch, error)

+ func (s *Shard) RetentionPolicy() string

+ func (s *Shard) SeriesN() int64

+ func (s *Shard) SeriesSketches() (estimator.Sketch, estimator.Sketch, error)

+ func (s *Shard) SetCompactionsEnabled(enabled bool)

+ func (s *Shard) TagKeyCardinality(name, key []byte) int

type Store

+ func (s *Store) ImportShard(id uint64, r io.Reader) error

+ func (s *Store) MeasurementNames(database string, cond influxql.Expr) ([][]byte, error)

+ func (s *Store) MeasurementSeriesCounts(database string) (measuments int, series int)

+ func (s *Store) MeasurementsCardinality(database string) (int64, error)

+ func (s *Store) SeriesCardinality(database string) (int64, error)

+ type TagValuesSlice []TagValues

+ func (a TagValuesSlice) Len() int

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

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

May 8, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 17, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 14, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 8, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 24, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 14, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 8, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 6, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 2, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 24, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Engine

+ LastModified func() time.Time

+ WithLogger func(zap.Logger)

type Shard

+ func (s *Shard) LastModified() time.Time

+ func (s *Shard) MapType(measurement, field string) influxql.DataType

+ func (s *Shard) MeasurementsByRegex(re *regexp.Regexp) []string

+ func (s *Shard) WithLogger(log zap.Logger)

+ type ShardGroup interface

+ CreateIterator func(measurement string, opt influxql.IteratorOptions) (influxql.Iterator, error)

+ ExpandSources func(sources influxql.Sources) (influxql.Sources, error)

+ FieldDimensions func(measurements []string) (fields map[string]influxql.DataType, dimensions map[string]struct{}, err error)

+ MapType func(measurement, field string) influxql.DataType

+ MeasurementsByRegex func(re *regexp.Regexp) []string

type Shards

+ func (a Shards) CreateIterator(measurement string, opt influxql.IteratorOptions) (influxql.Iterator, error)

+ func (a Shards) ExpandSources(sources influxql.Sources) (influxql.Sources, error)

+ func (a Shards) FieldDimensions(measurements []string) (fields map[string]influxql.DataType, dimensions map[string]struct{}, err error)

+ func (a Shards) MapType(measurement, field string) influxql.DataType

+ func (a Shards) MeasurementsByRegex(re *regexp.Regexp) []string

type Store

+ func (s *Store) ShardGroup(ids []uint64) ShardGroup

+ func (s *Store) WithLogger(log zap.Logger)

Jan 23, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 13, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 28, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 27, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Measurement

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

Feb 17, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Series

+ func (s *Series) CopyTags()

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

Feb 16, 2017 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Series

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

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

Dec 6, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 11, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultMaxValuesPerTag

type Config

+ MaxValuesPerTag int

type DatabaseIndex

+ func (d *DatabaseIndex) Dereference(b []byte)

+ func (d *DatabaseIndex) SeriesBytes(key []byte) *Series

type EngineOptions

+ ShardID uint64

type Measurement

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

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

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

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

type MeasurementFields

+ func (m *MeasurementFields) FieldBytes(name []byte) *Field

+ type PartialWriteError struct

+ Dropped int

+ Reason string

+ func (e PartialWriteError) Error() string

type Series

+ ID uint64

+ func (s *Series) Dereference(b []byte)

type ShardStatistics

+ WritePointsDropped int64

Nov 8, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Oct 31, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Oct 5, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Sep 26, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Shard

+ func (s *Shard) UnloadIndex()

Sep 7, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultMaxSeriesPerDatabase

+ var ErrShardDisabled = errors.New("shard is disabled")

type Config

+ MaxSeriesPerDatabase int

+ TraceLoggingEnabled bool

type DatabaseIndex

+ func (d *DatabaseIndex) MeasurementsByExpr(expr influxql.Expr) (Measurements, bool, error)

+ func (d *DatabaseIndex) SeriesShardN(shardID uint64) int

+ func (d *DatabaseIndex) Statistics(tags map[string]string) []models.Statistic

type Engine

+ CreateSnapshot func() (string, error)

+ Restore func(r io.Reader, basePath string) error

+ SetEnabled func(enabled bool)

+ Statistics func(tags map[string]string) []models.Statistic

+ type IndexStatistics struct

+ NumMeasurements int64

+ NumSeries int64

+ type KeyValue struct

+ Key string

+ Value string

+ type KeyValues []KeyValue

+ func (a KeyValues) Len() int

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

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

type Measurement

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

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

+ func (m *Measurement) TagKeysByExpr(expr influxql.Expr) (stringSet, bool, error)

type MeasurementFields

+ func (m *MeasurementFields) FieldSet() map[string]influxql.DataType

type Shard

+ EnableOnOpen bool

+ func (s *Shard) CreateSnapshot() (string, error)

+ func (s *Shard) Restore(r io.Reader, basePath string) error

+ func (s *Shard) SetEnabled(enabled bool)

+ func (s *Shard) Statistics(tags map[string]string) []models.Statistic

+ type ShardStatistics struct

+ BytesWritten int64

+ DiskBytes int64

+ FieldsCreated int64

+ SeriesCreated int64

+ WritePointsErr int64

+ WritePointsOK int64

+ WriteReq int64

+ WriteReqErr int64

+ WriteReqOK int64

type Store

+ func (s *Store) CreateShardSnapshot(id uint64) (string, error)

+ func (s *Store) Measurements(database string, cond influxql.Expr) ([]string, error)

+ func (s *Store) RestoreShard(id uint64, r io.Reader) error

+ func (s *Store) SetShardEnabled(shardID uint64, enabled bool) error

+ func (s *Store) Statistics(tags map[string]string) []models.Statistic

+ func (s *Store) TagValues(database string, cond influxql.Expr) ([]TagValues, error)

+ type TagValues struct

+ Measurement string

+ Values []KeyValue

Aug 29, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 22, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jul 18, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jun 20, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jun 6, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 11, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type DatabaseIndex

+ func (d *DatabaseIndex) RemoveShard(shardID uint64)

+ func (d *DatabaseIndex) SeriesKeys() []string

+ func (d *DatabaseIndex) UnassignShard(k string, shardID uint64)

type Engine

+ ContainsSeries func(keys []string) (map[string]bool, error)

+ DeleteSeriesRange func(keys []string, min, max int64) error

type Measurement

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

type Series

+ func (s *Series) ShardN() int

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

type Shard

+ func (s *Shard) ContainsSeries(seriesKeys []string) (map[string]bool, error)

+ func (s *Shard) DeleteSeriesRange(seriesKeys []string, min, max int64) error

+ func (s *Shard) SetLogOutput(w io.Writer)

type Store

+ func (s *Store) IteratorCreator(shards []uint64) (influxql.IteratorCreator, error)

+ func (s *Store) SetLogOutput(w io.Writer)

May 9, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

May 5, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 20, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Apr 7, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Engine

+ MeasurementFields func(measurement string) *MeasurementFields

type MeasurementFields

+ func NewMeasurementFields() *MeasurementFields

+ func (m *MeasurementFields) Field(name string) *Field

type Series

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

Apr 4, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ var ErrEngineClosed = errors.New("engine is closed")

type DatabaseIndex

+ func (d *DatabaseIndex) AssignShard(k string, shardID uint64)

type MeasurementIterator

+ func (itr *MeasurementIterator) Stats() influxql.IteratorStats

type Series

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

type Shard

+ func (s *Shard) ExpandSources(sources influxql.Sources) (influxql.Sources, error)

type Store

+ func (s *Store) IteratorCreators() influxql.IteratorCreators

Mar 31, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 22, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ var ErrUnknownEngineFormat = errors.New("unknown engine format")

+ func DecodeStorePath(shardOrWALPath string) (database, retentionPolicy string)

+ func NewFieldKeysIterator(sh *Shard, opt influxql.IteratorOptions) (influxql.Iterator, error)

+ func NewSeriesIterator(sh *Shard, opt influxql.IteratorOptions) (influxql.Iterator, error)

+ func NewShardError(id uint64, err error) error

+ func NewTagKeysIterator(sh *Shard, opt influxql.IteratorOptions) (influxql.Iterator, error)

+ func NewTagValuesIterator(sh *Shard, opt influxql.IteratorOptions) (influxql.Iterator, error)

type DatabaseIndex

+ func (d *DatabaseIndex) MeasurementsByRegex(re *regexp.Regexp) Measurements

type Engine

+ CreateIterator func(opt influxql.IteratorOptions) (influxql.Iterator, error)

+ SeriesKeys func(opt influxql.IteratorOptions) (influxql.SeriesList, error)

+ type FloatCursorIterator struct

+ func NewFloatCursorIterator(name string, tagMap map[string]string, cur Cursor, ...) *FloatCursorIterator

+ func (itr *FloatCursorIterator) Close() error

+ func (itr *FloatCursorIterator) Next() *influxql.FloatPoint

+ type MeasurementIterator struct

+ func NewMeasurementIterator(sh *Shard, opt influxql.IteratorOptions) (*MeasurementIterator, error)

+ func (itr *MeasurementIterator) Close() error

+ func (itr *MeasurementIterator) Next() *influxql.FloatPoint

type Shard

+ func (s *Shard) CreateIterator(opt influxql.IteratorOptions) (influxql.Iterator, error)

+ func (s *Shard) FieldDimensions(sources influxql.Sources) (fields, dimensions map[string]struct{}, err error)

+ func (s *Shard) SeriesKeys(opt influxql.IteratorOptions) (influxql.SeriesList, error)

+ type ShardError struct

+ Err error

+ func (e ShardError) Error() string

+ type Shards []*Shard

+ func (a Shards) Len() int

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

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

type Store

+ func (s *Store) DeleteMeasurement(database, name string) error

+ func (s *Store) DeleteRetentionPolicy(database, name string) error

+ func (s *Store) DeleteSeries(database string, sources []influxql.Source, condition influxql.Expr) error

+ func (s *Store) ExecuteShowFieldKeysStatement(stmt *influxql.ShowFieldKeysStatement, database string) (models.Rows, error)

+ func (s *Store) ExecuteShowTagValuesStatement(stmt *influxql.ShowTagValuesStatement, database string) (models.Rows, error)

+ func (s *Store) ExpandSources(sources influxql.Sources) (influxql.Sources, error)

+ func (s *Store) ShardIteratorCreator(id uint64) influxql.IteratorCreator

+ func (s *Store) Shards(ids []uint64) []*Shard

Mar 15, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 9, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Mar 3, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 18, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Feb 4, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Config

+ DataLoggingEnabled bool

+ Enabled bool

type Engine

+ Backup func(w io.Writer, basePath string, since time.Time) error

+ type MapItems []MapItem

+ func (a MapItems) Len() int

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

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

type MapperOutput

+ CursorKey string

type MapperOutputJSON

+ CursorKey string

type QueryExecutor

+ MetaClient interface{ ... }

type Store

+ func (s *Store) BackupShard(id uint64, since time.Time, w io.Writer) error

+ func (s *Store) ShardRelativePath(id uint64) (string, error)

type TagsCursor

+ func (c *TagsCursor) Seeked() bool

+ func (c *TagsCursor) Unread(key int64, value interface{})

Feb 2, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 28, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 23, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jan 13, 2016 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Dec 8, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultCacheMaxMemorySize

+ const DefaultCacheSnapshotMemorySize

+ const DefaultCacheSnapshotWriteColdDuration

+ const DefaultCompactFullWriteColdDuration

+ const DefaultCompactMinFileCount

+ const DefaultMaxPointsPerBlock

type Config

+ CacheMaxMemorySize uint64

+ CacheSnapshotMemorySize uint64

+ CacheSnapshotWriteColdDuration toml.Duration

+ CompactFullWriteColdDuration toml.Duration

+ CompactMinFileCount int

+ MaxPointsPerBlock int

Dec 8, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Dec 7, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 17, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultFlushMemorySizeThreshold

+ const DefaultIndexCompactionAge

+ const DefaultIndexCompactionFullAge

+ const DefaultIndexMinCompactionFileCount

+ const DefaultIndexMinCompactionInterval

+ const DefaultMaxMemorySizeThreshold

+ const EOF

+ const MaintenanceCheckInterval

+ var ErrStoreClosed = fmt.Errorf("store is closed")

+ func IsNumeric(c *influxql.Call) bool

+ func MapCount(input *MapInput) interface

+ func MapCountDistinct(input *MapInput) interface

+ func MapDistinct(input *MapInput) interface

+ func MapEcho(input *MapInput) interface

+ func MapFirst(input *MapInput, fieldName string) interface

+ func MapLast(input *MapInput, fieldName string) interface

+ func MapMax(input *MapInput, fieldName string) interface

+ func MapMean(input *MapInput) interface

+ func MapMin(input *MapInput, fieldName string) interface

+ func MapRawQuery(input *MapInput) interface

+ func MapSpread(input *MapInput) interface

+ func MapStddev(input *MapInput) interface

+ func MapSum(input *MapInput) interface

+ func MapTopBottom(input *MapInput, limit int, fields []string, argCount int, callName string) interface

+ func ReduceCountDistinct(values []interface{}) interface

+ func ReduceDistinct(values []interface{}) interface

+ func ReduceFirst(values []interface{}) interface

+ func ReduceLast(values []interface{}) interface

+ func ReduceMax(values []interface{}) interface

+ func ReduceMean(values []interface{}) interface

+ func ReduceMedian(values []interface{}) interface

+ func ReduceMin(values []interface{}) interface

+ func ReducePercentile(values []interface{}, percentile float64) interface

+ func ReduceSpread(values []interface{}) interface

+ func ReduceStddev(values []interface{}) interface

+ func ReduceSum(values []interface{}) interface

+ func ReduceTopBottom(values []interface{}, limit int, fields []string, callName string) interface

+ func RegisteredEngines() []string

+ type AggregateMapper struct

+ func NewAggregateMapper(sh *Shard, stmt *influxql.SelectStatement) *AggregateMapper

+ func (m *AggregateMapper) Close()

+ func (m *AggregateMapper) Fields() []string

+ func (m *AggregateMapper) NextChunk() (interface{}, error)

+ func (m *AggregateMapper) Open() error

+ func (m *AggregateMapper) TagSets() []string

type Config

+ Engine string

+ IndexCompactionAge time.Duration

+ IndexCompactionFullAge time.Duration

+ IndexMinCompactionFileCount int

+ IndexMinCompactionInterval time.Duration

+ QueryLogEnabled bool

+ WALFlushMemorySizeThreshold int

+ WALMaxMemorySizeThreshold int

+ func (c *Config) Validate() error

type Cursor

+ Ascending func() bool

+ SeekTo func(seek int64) (key int64, value interface{})

+ type CursorSet struct

+ Cursors []*TagsCursor

+ Key string

+ Measurement string

+ Tags map[string]string

+ type CursorSets []CursorSet

+ func (a CursorSets) Keys() []string

+ func (a CursorSets) Len() int

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

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

type DatabaseIndex

+ func (d *DatabaseIndex) MeasurementsByName(names []string) []*Measurement

+ func (db *DatabaseIndex) ExpandWildcards(stmt *influxql.SelectStatement) (*influxql.SelectStatement, error)

+ func (db *DatabaseIndex) RewriteSelectStatement(stmt *influxql.SelectStatement) (*influxql.SelectStatement, error)

+ func (di *DatabaseIndex) ExpandSources(sources influxql.Sources) (influxql.Sources, error)

type Engine

+ Format func() EngineFormat

+ PerformMaintenance func()

+ type EngineFormat int

+ const B1Format

+ const BZ1Format

+ const TSM1Format

type FieldCodec

+ func (f *FieldCodec) FieldByName(name string) *Field

+ func (f *FieldCodec) Fields() (a []*Field)

+ type FilterExprs map[uint64]influxql.Expr

+ func (fe FilterExprs) DeleteBoolLiteralTrues()

+ func (fe FilterExprs) Len() int

+ type InterfaceValues []interface

+ func (d InterfaceValues) Len() int

+ func (d InterfaceValues) Less(i, j int) bool

+ func (d InterfaceValues) Swap(i, j int)

+ type IntoWriteRequest struct

+ Database string

+ Points []models.Point

+ RetentionPolicy string

+ type MapInput struct

+ Items []MapItem

+ TMin int64

+ type MapItem struct

+ Fields map[string]interface{}

+ Tags map[string]string

+ Timestamp int64

+ Value interface{}

type MapperOutput

+ func (mo *MapperOutput) MarshalJSON() ([]byte, error)

+ type MapperOutputJSON struct

+ Fields []string

+ Name string

+ Tags map[string]string

+ Values json.RawMessage

type MapperValue

+ func (mv *MapperValue) MarshalJSON() ([]byte, error)

+ type MapperValueJSON struct

+ AggData [][]byte

+ RawData []byte

+ Tags map[string]string

+ Time int64

type Measurement

+ func (m *Measurement) DimensionTagSets(stmt *influxql.SelectStatement) ([]*influxql.TagSet, error)

+ func (m *Measurement) SelectFields(stmt *influxql.SelectStatement) []string

+ func (m *Measurement) SelectTags(stmt *influxql.SelectStatement) []string

+ func (m *Measurement) WhereFields(stmt *influxql.SelectStatement) []string

+ type MeasurementTagKeys struct

+ Measurement string

+ TagKeys []string

type Measurements

+ func (a Measurements) SelectFields(stmt *influxql.SelectStatement) []string

+ func (a Measurements) SelectTags(stmt *influxql.SelectStatement) []string

+ func (a Measurements) WhereFields(stmt *influxql.SelectStatement) []string

+ type MeasurementsTagKeys []*MeasurementTagKeys

+ func (a MeasurementsTagKeys) Len() int

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

+ func (a MeasurementsTagKeys) Size() int

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

+ type NumberType int8

+ const Float64Type

+ const Int64Type

+ type PositionPoint struct

+ Fields map[string]interface{}

+ Tags map[string]string

+ Time int64

+ Value interface{}

+ type PositionPoints []PositionPoint

type QueryExecutor

+ IntoWriter interface{ ... }

+ QueryLogEnabled bool

+ func (q *QueryExecutor) PlanShowTagKeys(stmt *influxql.ShowTagKeysStatement, database string, chunkSize int) (Executor, error)

type RawMapper

+ ChunkSize int

+ func (m *RawMapper) Fields() []string

+ type SelectInfo struct

+ SelectFields []string

+ SelectTags []string

+ WhereFields []string

type Shard

+ func (s *Shard) PerformMaintenance()

type ShowMeasurementsMapper

+ ChunkSize int

+ type ShowTagKeysExecutor struct

+ func NewShowTagKeysExecutor(stmt *influxql.ShowTagKeysStatement, mappers []Mapper, chunkSize int) *ShowTagKeysExecutor

+ func (e *ShowTagKeysExecutor) Execute() <-chan *models.Row

+ type ShowTagKeysMapper struct

+ func NewShowTagKeysMapper(shard *Shard, stmt *influxql.ShowTagKeysStatement, chunkSize int) *ShowTagKeysMapper

+ func (m *ShowTagKeysMapper) Close()

+ func (m *ShowTagKeysMapper) Fields() []string

+ func (m *ShowTagKeysMapper) NextChunk() (interface{}, error)

+ func (m *ShowTagKeysMapper) Open() error

+ func (m *ShowTagKeysMapper) SetRemote(remote Mapper) error

+ func (m *ShowTagKeysMapper) TagSets() []string

+ type TagSetCursor struct

+ SelectFields []string

+ func NewTagSetCursor(m string, t map[string]string, c []*TagsCursor, ascending bool) *TagSetCursor

+ func (tsc *TagSetCursor) Fields() map[string]interface{}

+ func (tsc *TagSetCursor) Init(seek int64)

+ func (tsc *TagSetCursor) Next(tmin, tmax int64) (int64, interface{})

+ func (tsc *TagSetCursor) Tags() map[string]string

+ type TagSetCursors []*TagSetCursor

+ func (a TagSetCursors) Keys() []string

+ func (a TagSetCursors) Len() int

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

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

+ type TagsCursor struct

+ func NewTagsCursor(c Cursor, filter influxql.Expr, tags map[string]string) *TagsCursor

+ func (c *TagsCursor) Next() (int64, interface{})

+ func (c *TagsCursor) SeekTo(seek int64) (int64, interface{})

+ type UnmarshalFunc func([]byte) (interface{}, error)

+ func InitializeUnmarshaller(c *influxql.Call) (UnmarshalFunc, error)

Nov 16, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 13, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Nov 12, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Sep 14, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

type Config

+ WALLoggingEnabled bool

type Cursor

+ Direction func() Direction

+ type Direction bool

+ const Forward

+ const Reverse

+ func (d Direction) Forward() bool

+ func (d Direction) Reverse() bool

+ func (d Direction) String() string

type Mapper

+ SetRemote func(m Mapper) error

type Measurement

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

type QueryExecutor

+ MonitorStatementExecutor interface{ ... }

+ func (q *QueryExecutor) PlanSelect(stmt *influxql.SelectStatement, chunkSize int) (Executor, error)

+ func (q *QueryExecutor) PlanShowMeasurements(stmt *influxql.ShowMeasurementsStatement, database string, chunkSize int) (Executor, error)

+ func (q *QueryExecutor) SetLogger(l *log.Logger)

+ type SelectExecutor struct

+ func NewSelectExecutor(stmt *influxql.SelectStatement, mappers []Mapper, chunkSize int) *SelectExecutor

+ func (e *SelectExecutor) Execute() <-chan *influxql.Row

+ type SelectMapper struct

+ func NewSelectMapper(shard *Shard, stmt influxql.Statement, chunkSize int) *SelectMapper

+ func (lm *SelectMapper) Close()

+ func (lm *SelectMapper) Fields() []string

+ func (lm *SelectMapper) NextChunk() (interface{}, error)

+ func (lm *SelectMapper) Open() error

+ func (lm *SelectMapper) SetRemote(m Mapper) error

+ func (lm *SelectMapper) TagSets() []string

type Shard

+ func (s *Shard) DiskSize() (int64, error)

+ func (s *Shard) ReadOnlyTx() (Tx, error)

+ func (s *Shard) WriteTo(w io.Writer) (int64, error)

+ type ShowMeasurementsExecutor struct

+ func NewShowMeasurementsExecutor(stmt *influxql.ShowMeasurementsStatement, mappers []Mapper, chunkSize int) *ShowMeasurementsExecutor

+ func (e *ShowMeasurementsExecutor) Execute() <-chan *influxql.Row

+ type ShowMeasurementsMapper struct

+ func NewShowMeasurementsMapper(shard *Shard, stmt *influxql.ShowMeasurementsStatement, chunkSize int) *ShowMeasurementsMapper

+ func (m *ShowMeasurementsMapper) Close()

+ func (m *ShowMeasurementsMapper) Fields() []string

+ func (m *ShowMeasurementsMapper) NextChunk() (interface{}, error)

+ func (m *ShowMeasurementsMapper) Open() error

+ func (m *ShowMeasurementsMapper) SetRemote(remote Mapper) error

+ func (m *ShowMeasurementsMapper) TagSets() []string

type Store

+ func (s *Store) Databases() []string

+ func (s *Store) DiskSize() (int64, error)

Sep 10, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 26, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultCompactionThreshold

+ const DefaultEngine

+ const DefaultFlushColdInterval

+ const DefaultMaxSeriesSize

+ const DefaultPartitionSizeThreshold

+ const DefaultReadySeriesSize

+ var ErrFormatNotFound = errors.New("format not found")

+ func DedupeEntries(a [][]byte) [][]byte

+ func MakeKey(name []byte, tags Tags) []byte

+ func MarshalTags(tags map[string]string) []byte

+ func MeasurementFromSeriesKey(key string) string

+ func ProcessAggregateDerivative(results [][]interface{}, isNonNegative bool, interval time.Duration) [][]interface

+ func RegisterEngine(name string, fn NewEngineFunc)

+ type ByteSlices [][]byte

+ func (a ByteSlices) Len() int

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

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

type Config

+ WALCompactionThreshold float64

+ WALDir string

+ WALEnableLogging bool

+ WALFlushColdInterval toml.Duration

+ WALMaxSeriesSize int

+ WALPartitionSizeThreshold uint64

+ WALReadySeriesSize int

+ type Cursor interface

+ Next func() (key, value []byte)

+ Seek func(seek []byte) (key, value []byte)

+ func MultiCursor(cursors ...Cursor) Cursor

type DatabaseIndex

+ func (d *DatabaseIndex) Names() []string

+ func (d *DatabaseIndex) Series(key string) *Series

+ func (d *DatabaseIndex) SeriesN() int

+ func (s *DatabaseIndex) CreateMeasurementIndexIfNotExists(name string) *Measurement

+ func (s *DatabaseIndex) CreateSeriesIndexIfNotExists(measurementName string, series *Series) *Series

+ func (s *DatabaseIndex) TagsForSeries(key string) map[string]string

+ type Engine interface

+ Begin func(writable bool) (Tx, error)

+ Close func() error

+ DeleteMeasurement func(name string, seriesKeys []string) error

+ DeleteSeries func(keys []string) error

+ LoadMetadataIndex func(index *DatabaseIndex, measurementFields map[string]*MeasurementFields) error

+ Open func() error

+ SeriesCount func() (n int, err error)

+ SetLogOutput func(io.Writer)

+ WritePoints func(points []Point, measurementFieldsToSave map[string]*MeasurementFields, ...) error

+ func NewEngine(path string, walPath string, options EngineOptions) (Engine, error)

+ type EngineOptions struct

+ Config Config

+ EngineVersion string

+ MaxWALSize int

+ WALFlushInterval time.Duration

+ WALPartitionFlushDelay time.Duration

+ func NewEngineOptions() EngineOptions

type Executor

+ func NewExecutor(stmt *influxql.SelectStatement, mappers []Mapper, chunkSize int) *Executor

+ type Field struct

+ ID uint8

+ Name string

+ Type influxql.DataType

type FieldCodec

+ func NewFieldCodec(fields map[string]*Field) *FieldCodec

+ type FieldCreate struct

+ Field *Field

+ Measurement string

type LocalMapper

+ func NewLocalMapper(shard *Shard, stmt influxql.Statement, chunkSize int) *LocalMapper

+ func (lm *LocalMapper) Fields() []string

+ func (lm *LocalMapper) NextChunk() (interface{}, error)

+ func (lm *LocalMapper) TagSets() []string

type Mapper

+ Fields func() []string

+ type MapperOutput struct

+ Fields []string

+ Name string

+ Tags map[string]string

+ Values []*MapperValue

+ type MapperValue struct

+ Tags map[string]string

+ Time int64

+ Value interface{}

+ type MapperValues []*MapperValue

+ func (a MapperValues) Len() int

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

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

type Measurement

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

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

+ type MeasurementFields struct

+ Codec *FieldCodec

+ Fields map[string]*Field

+ func (m *MeasurementFields) CreateFieldIfNotExists(name string, typ influxql.DataType) error

+ func (m *MeasurementFields) MarshalBinary() ([]byte, error)

+ func (m *MeasurementFields) UnmarshalBinary(buf []byte) error

+ type NewEngineFunc func(path string, walPath string, options EngineOptions) Engine

+ type Points []Point

+ func (a Points) Len() int

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

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

type QueryExecutor

+ Store *Store

+ func (q *QueryExecutor) Plan(stmt *influxql.SelectStatement, chunkSize int) (*Executor, error)

+ type RawQueryDerivativeProcessor struct

+ DerivativeInterval time.Duration

+ IsNonNegative bool

+ LastValueFromPreviousChunk *MapperValue

+ func (rqdp *RawQueryDerivativeProcessor) Process(input []*MapperValue) []*MapperValue

type Series

+ func NewSeries(key string, tags map[string]string) *Series

+ func (s *Series) InitializeShards()

+ type SeriesCreate struct

+ Measurement string

+ Series *Series

+ 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 Shard

+ func (s *Shard) DeleteMeasurement(name string, seriesKeys []string) error

+ func (s *Shard) DeleteSeries(keys []string) error

type Store

+ EngineOptions EngineOptions

+ func (s *Store) DatabaseIndexN() int

+ func (s *Store) ShardN() int

type Tags

+ func (t Tags) HashKey() []byte

+ type Tx interface

+ Commit func() error

+ Cursor func(series string) Cursor

+ Rollback func() error

+ Size func() int64

Aug 25, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 21, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Aug 19, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jul 24, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const IgnoredChunkSize

+ const MaxGroupByPoints

+ const SelectColumnCountWithOneValue

+ type AggMapper struct

+ func NewAggMapper(shard *Shard, stmt *influxql.SelectStatement) *AggMapper

+ func (am *AggMapper) Close()

+ func (am *AggMapper) NextChunk() (interface{}, error)

+ func (am *AggMapper) Open() error

+ func (am *AggMapper) TagSets() []string

+ type AggregateExecutor struct

+ func NewAggregateExecutor(stmt *influxql.SelectStatement, mappers []Mapper) *AggregateExecutor

+ func (ae *AggregateExecutor) Execute() <-chan *influxql.Row

type ErrAuthorize

+ func NewErrAuthorize(qe *QueryExecutor, q *influxql.Query, u, db, m string) *ErrAuthorize

+ type Executor interface

+ Execute func() <-chan *influxql.Row

type FieldCodec

+ func (f *FieldCodec) DecodeByName(name string, b []byte) (interface{}, error)

+ type Mapper interface

+ Close func()

+ NextChunk func() (interface{}, error)

+ Open func() error

+ TagSets func() []string

+ type MapperResponse struct

+ Data []byte

+ TagSets []string

type Measurement

+ func (m *Measurement) ValidateGroupBy(stmt *influxql.SelectStatement) error

type QueryExecutor

+ ShardMapper interface{ ... }

+ type RawExecutor struct

+ func NewRawExecutor(stmt *influxql.SelectStatement, mappers []Mapper, chunkSize int) *RawExecutor

+ func (re *RawExecutor) Execute() <-chan *influxql.Row

+ type RawMapper struct

+ func NewRawMapper(shard *Shard, stmt *influxql.SelectStatement, chunkSize int) *RawMapper

+ func (rm *RawMapper) Close()

+ func (rm *RawMapper) NextChunk() (interface{}, error)

+ func (rm *RawMapper) Open() error

+ func (rm *RawMapper) TagSets() []string

+ type StatefulMapper struct

+ func (srm *StatefulMapper) NextChunk() (*mapperOutput, error)

type Store

+ func (s *Store) CreateMapper(shardID uint64, query string, chunkSize int) (Mapper, error)

Jul 17, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jul 2, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultMaxWALSize

+ const DefaultWALFlushInterval

+ const DefaultWALPartitionFlushDelay

+ const WALPartitionN

+ var ErrWALPartitionNotFound = errors.New("wal partition not found")

+ func WALPartition(key []byte) uint8

type Config

+ MaxWALSize int

+ WALFlushInterval toml.Duration

+ WALPartitionFlushDelay toml.Duration

type Shard

+ LogOutput io.Writer

+ MaxWALSize int

+ WALFlushInterval time.Duration

+ WALPartitionFlushDelay time.Duration

+ func (s *Shard) Flush() error

+ func (s *Shard) FlushPartition(partitionID uint8) error

+ func (s *Shard) SeriesCount() (n int, err error)

type Store

+ MaxWALSize int

+ WALFlushInterval time.Duration

+ WALPartitionFlushDelay time.Duration

+ func (s *Store) Flush() error

Jul 1, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jun 26, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jun 11, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Changes in this version

+ const DefaultRetentionAutoCreate

+ const DefaultRetentionCheckEnabled

+ const DefaultRetentionCheckPeriod

+ const DefaultRetentionCreatePeriod

+ var ErrFieldNotFound = errors.New("field not found")

+ var ErrFieldOverflow = errors.New("field overflow")

+ var ErrFieldTypeConflict = errors.New("field type conflict")

+ var ErrFieldUnmappedID = errors.New("field ID not mapped")

+ var ErrInvalidQuery = errors.New("invalid query")

+ var ErrNotExecuted = errors.New("not executed")

+ var ErrShardNotFound = fmt.Errorf("shard not found")

+ func ErrDatabaseNotFound(name string) error

+ func ErrMeasurementNotFound(name string) error

+ func IsRetryable(err error) bool

+ func NewSnapshotWriter(meta []byte, store *Store) (*snapshot.Writer, error)

+ func NopWriteToCloser(w io.WriterTo) interface

+ type Config struct

+ Dir string

+ RetentionAutoCreate bool

+ RetentionCheckEnabled bool

+ RetentionCheckPeriod toml.Duration

+ RetentionCreatePeriod toml.Duration

+ func NewConfig() Config

+ func (c *Config) ShardGroupPreCreateCheckPeriod() time.Duration

+ type DatabaseIndex struct

+ func NewDatabaseIndex() *DatabaseIndex

+ func (d *DatabaseIndex) Measurement(name string) *Measurement

+ func (d *DatabaseIndex) MeasurementSeriesCounts() (nMeasurements int, nSeries int)

+ func (db *DatabaseIndex) DropMeasurement(name string)

+ func (db *DatabaseIndex) DropSeries(keys []string)

+ func (db *DatabaseIndex) Measurements() Measurements

+ type ErrAuthorize struct

+ func (e ErrAuthorize) Error() string

+ type FieldCodec struct

+ func (f *FieldCodec) DecodeByID(targetID uint8, b []byte) (interface{}, error)

+ func (f *FieldCodec) DecodeFields(b []byte) (map[uint8]interface{}, error)

+ func (f *FieldCodec) DecodeFieldsWithNames(b []byte) (map[string]interface{}, error)

+ func (f *FieldCodec) EncodeFields(values map[string]interface{}) ([]byte, error)

+ func (f *FieldCodec) FieldIDByName(s string) (uint8, error)

+ type Fields map[string]interface

+ func (p Fields) MarshalBinary() []byte

+ type LocalMapper struct

+ func (l *LocalMapper) Begin(c *influxql.Call, startingTime int64, chunkSize int) error

+ func (l *LocalMapper) Close()

+ func (l *LocalMapper) IsEmpty(tmax int64) bool

+ func (l *LocalMapper) Next() (seriesKey string, timestamp int64, value interface{})

+ func (l *LocalMapper) NextInterval() (interface{}, error)

+ func (l *LocalMapper) Open() error

+ type Measurement struct

+ Name string

+ func NewMeasurement(name string, idx *DatabaseIndex) *Measurement

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

+ func (m *Measurement) DropSeries(seriesID uint64)

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

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

+ func (m *Measurement) HasSeries() bool

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

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

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

+ func (m *Measurement) TagSets(stmt *influxql.SelectStatement, dimensions []string) ([]*influxql.TagSet, error)

+ type Measurements []*Measurement

+ func (a Measurements) Len() int

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

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

+ type Monitor struct

+ Store interface{}

+ func (m *Monitor) Close() error

+ func (m *Monitor) Open() error

+ type Point interface

+ AddField func(name string, value interface{})

+ AddTag func(key, value string)

+ Data func() []byte

+ Fields func() Fields

+ HashID func() uint64

+ Key func() []byte

+ Name func() string

+ SetData func(buf []byte)

+ SetName func(string)

+ SetTags func(tags Tags)

+ SetTime func(t time.Time)

+ String func() string

+ Tags func() Tags

+ Time func() time.Time

+ UnixNano func() int64

+ func NewPoint(name string, tags Tags, fields Fields, time time.Time) Point

+ func ParsePoints(buf []byte) ([]Point, error)

+ func ParsePointsString(buf string) ([]Point, error)

+ func ParsePointsWithPrecision(buf []byte, defaultTime time.Time, precision string) ([]Point, error)

+ type PointBatcher struct

+ func NewPointBatcher(sz int, d time.Duration) *PointBatcher

+ func (b *PointBatcher) Flush()

+ func (b *PointBatcher) In() chan<- Point

+ func (b *PointBatcher) Out() <-chan []Point

+ func (b *PointBatcher) Start()

+ func (b *PointBatcher) Stats() *PointBatcherStats

+ func (b *PointBatcher) Stop()

+ type PointBatcherStats struct

+ BatchTotal uint64

+ PointTotal uint64

+ SizeTotal uint64

+ TimeoutTotal uint64

+ type QueryExecutor struct

+ Logger *log.Logger

+ MetaStatementExecutor interface{ ... }

+ MetaStore interface{ ... }

+ Stats *influxdb.Stats

+ func NewQueryExecutor(store *Store) *QueryExecutor

+ func (q *QueryExecutor) Authorize(u *meta.UserInfo, query *influxql.Query, database string) error

+ func (q *QueryExecutor) Begin() (influxql.Tx, error)

+ func (q *QueryExecutor) DiagnosticsAsRows() []*influxql.Row

+ func (q *QueryExecutor) ExecuteQuery(query *influxql.Query, database string, chunkSize int) (<-chan *influxql.Result, error)

+ type Series struct

+ Key string

+ Tags map[string]string

+ func (s *Series) MarshalBinary() ([]byte, error)

+ func (s *Series) UnmarshalBinary(buf []byte) error

+ type Shard struct

+ func NewShard(index *DatabaseIndex, path string) *Shard

+ func (s *Shard) Close() error

+ func (s *Shard) DB() *bolt.DB

+ func (s *Shard) FieldCodec(measurementName string) *FieldCodec

+ func (s *Shard) Open() error

+ func (s *Shard) Path() string

+ func (s *Shard) ValidateAggregateFieldsInStatement(measurementName string, stmt *influxql.SelectStatement) error

+ func (s *Shard) WritePoints(points []Point) error

+ type Store struct

+ Logger *log.Logger

+ func NewStore(path string) *Store

+ func (s *Store) Close() error

+ func (s *Store) CreateShard(database, retentionPolicy string, shardID uint64) error

+ func (s *Store) DatabaseIndex(name string) *DatabaseIndex

+ func (s *Store) DeleteDatabase(name string, shardIDs []uint64) error

+ func (s *Store) DeleteShard(shardID uint64) error

+ func (s *Store) Measurement(database, name string) *Measurement

+ func (s *Store) Open() error

+ func (s *Store) Path() string

+ func (s *Store) Shard(shardID uint64) *Shard

+ func (s *Store) ShardIDs() []uint64

+ func (s *Store) ValidateAggregateFieldsInStatement(shardID uint64, measurementName string, stmt *influxql.SelectStatement) error

+ func (s *Store) WriteToShard(shardID uint64, points []Point) error

+ type TagFilter struct

+ Key string

+ Op influxql.Token

+ Regex *regexp.Regexp

+ Value string

+ type Tags map[string]string

Jun 10, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb

Jun 7, 2015 GO-2022-0780

  GO-2022-0780: Improper Authentication in InfluxDB in github.com/influxdata/influxdb