tsdb

package

Go to main page

Versions in this module

v1

v1.0.0-beta3

Jul 18, 2016

v1.0.0-beta1

Jun 6, 2016

v0

v0.12.0

Apr 4, 2016

Changes in this version

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

+ 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) AssignShard(k string, shardID uint64)

+ 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

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

type Series

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

type Shard

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

+ func (s *Shard) ExpandSources(sources influxql.Sources) (influxql.Sources, 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) IteratorCreators() influxql.IteratorCreators

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

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

v0.11.0-rc1

Mar 15, 2016

v0.10.3

Mar 9, 2016

v0.10.2

Mar 3, 2016

v0.10.0

Feb 4, 2016

Changes in this version

+ const DefaultCacheMaxMemorySize

+ const DefaultCacheSnapshotMemorySize

+ const DefaultCacheSnapshotWriteColdDuration

+ const DefaultCompactFullWriteColdDuration

+ const DefaultMaxPointsPerBlock

type Config

+ CacheMaxMemorySize uint64

+ CacheSnapshotMemorySize uint64

+ CacheSnapshotWriteColdDuration toml.Duration

+ CompactFullWriteColdDuration toml.Duration

+ DataLoggingEnabled bool

+ Enabled bool

+ MaxPointsPerBlock int

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{})

v0.10.0-rc2

Feb 2, 2016

v0.10.0-beta2

Jan 23, 2016

v0.10.0-beta1

Jan 13, 2016

v0.9.6-rc1

Dec 7, 2015

v0.9.5

Nov 17, 2015

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

+ WALLoggingEnabled bool

+ 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) TagValues(key string) []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{ ... }

+ MonitorStatementExecutor interface{ ... }

+ QueryLogEnabled bool

+ 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) PlanShowTagKeys(stmt *influxql.ShowTagKeysStatement, database string, chunkSize int) (Executor, error)

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

type RawMapper

+ ChunkSize int

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

+ type SelectInfo struct

+ SelectFields []string

+ SelectTags []string

+ WhereFields []string

type Shard

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

+ func (s *Shard) PerformMaintenance()

+ 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 *models.Row

+ type ShowMeasurementsMapper struct

+ ChunkSize int

+ func NewShowMeasurementsMapper(shard *Shard, stmt *influxql.ShowMeasurementsStatement) *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)

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

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

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

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

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

v0.9.5-rc3

Nov 16, 2015

v0.9.3

Aug 26, 2015

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 struct

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

+ func (lm *LocalMapper) Close()

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

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

+ func (lm *LocalMapper) Open() 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

v0.9.2

Jul 24, 2015

Changes in this version

+ const DefaultMaxWALSize

+ const DefaultWALFlushInterval

+ const DefaultWALPartitionFlushDelay

+ const IgnoredChunkSize

+ const MaxGroupByPoints

+ const SelectColumnCountWithOneValue

+ const WALPartitionN

+ 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")

+ var ErrWALPartitionNotFound = errors.New("wal partition 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

+ func WALPartition(key []byte) uint8

+ 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 Config struct

+ Dir string

+ MaxWALSize int

+ WALFlushInterval toml.Duration

+ WALPartitionFlushDelay toml.Duration

+ func NewConfig() Config

+ 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 NewErrAuthorize(qe *QueryExecutor, q *influxql.Query, u, db, m string) *ErrAuthorize

+ func (e ErrAuthorize) Error() string

+ type Executor interface

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

+ type FieldCodec struct

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

+ func (f *FieldCodec) DecodeByName(name string, 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 Mapper interface

+ Close func()

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

+ Open func() error

+ TagSets func() []string

+ type MapperResponse struct

+ Data []byte

+ TagSets []string

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

+ func (m *Measurement) ValidateGroupBy(stmt *influxql.SelectStatement) 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{ ... }

+ ShardMapper interface{ ... }

+ func NewQueryExecutor(store *Store) *QueryExecutor

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

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

+ 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 Series struct

+ Key string

+ Tags map[string]string

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

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

+ type Shard struct

+ LogOutput io.Writer

+ MaxWALSize int

+ WALFlushInterval time.Duration

+ WALPartitionFlushDelay time.Duration

+ 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) Flush(partitionFlushDelay time.Duration) error

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

+ func (s *Shard) Open() error

+ func (s *Shard) Path() string

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

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

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

+ type StatefulMapper struct

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

+ type Store struct

+ Logger *log.Logger

+ MaxWALSize int

+ WALFlushInterval time.Duration

+ WALPartitionFlushDelay time.Duration

+ func NewStore(path string) *Store

+ func (s *Store) Close() error

+ func (s *Store) CreateMapper(shardID uint64, query string, chunkSize int) (Mapper, 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) Flush() 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

v0.9.1-rc2

Jul 1, 2015

v0.9.0-rc33

Jun 10, 2015

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