tsm1

Mar 6, 2018

Changes in this version

+ const BlockUnsigned

+ const TmpTSMFileExtension

+ func BlockTypeToInfluxQLDataType(typ byte) influxql.DataType

+ func Digest(dir string, w io.WriteCloser) error

+ func DigestWithOptions(dir string, opts DigestOptions, w io.WriteCloser) error

+ func MetricsGroupFromContext(ctx context.Context) *metrics.Group

+ func NewContextWithMetricsGroup(ctx context.Context) context.Context

+ func SeriesFieldKeyBytes(seriesKey, field string) []byte

+ type BatchDeleter interface

+ Commit func() error

+ DeleteRange func(keys [][]byte, min, max int64) error

+ Rollback func() error

+ type BatchDeleters []BatchDeleter

+ func (a BatchDeleters) Commit() error

+ func (a BatchDeleters) DeleteRange(keys [][]byte, min, max int64) error

+ func (a BatchDeleters) Rollback() error

type BlockIterator

+ func (b *BlockIterator) Err() error

type BooleanValues

+ func (a BooleanValues) FindRange(min, max int64) (int, int)

type Cache

+ func (c *Cache) Count() int

+ func (c *Cache) Free()

+ func (c *Cache) Split(n int) []*Cache

type CompactionPlanner

+ ForceFull func()

type Compactor

+ RateLimit limiter.Rate

type DefaultPlanner

+ func (c *DefaultPlanner) ForceFull()

+ type DigestOptions struct

+ MaxKey []byte

+ MaxTime int64

+ MinKey []byte

+ MinTime int64

+ type DigestReader struct

+ func NewDigestReader(r io.ReadCloser) (*DigestReader, error)

+ func (w *DigestReader) Close() error

+ func (w *DigestReader) ReadTimeSpan() (string, *DigestTimeSpan, error)

+ type DigestTimeRange struct

+ CRC uint32

+ Max int64

+ Min int64

+ N int

+ type DigestTimeSpan struct

+ Ranges []DigestTimeRange

+ func (a DigestTimeSpan) Len() int

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

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

+ func (t *DigestTimeSpan) Add(min, max int64, n int, crc uint32)

+ type DigestWriter struct

+ F writeFlushCloser

+ func NewDigestWriter(w io.WriteCloser) (*DigestWriter, error)

+ func (w *DigestWriter) Close() error

+ func (w *DigestWriter) Flush() error

+ func (w *DigestWriter) WriteTimeSpan(key string, t *DigestTimeSpan) error

type Engine

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

+ func (e *Engine) Digest() (io.ReadCloser, int64, error)

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

+ func (e *Engine) Free() error

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

+ func (e *Engine) MeasurementFieldSet() *tsdb.MeasurementFieldSet

+ func (e *Engine) ScheduleFullCompaction() error

type EngineStatistics

+ TSMCompactionsQueue [3]int64

+ TSMFullCompactionsQueue int64

+ TSMOptimizeCompactionsQueue int64

type FileStore

+ func (f *FileStore) Apply(fn func(r TSMFile) error) error

+ func (f *FileStore) Cost(key []byte, min, max int64) query.IteratorCost

+ func (f *FileStore) Free() error

+ func (f *FileStore) TSMReader(path string) *TSMReader

type FloatValues

+ func (a FloatValues) FindRange(min, max int64) (int, int)

type IndexWriter

+ func NewDiskIndexWriter(f *os.File) IndexWriter

+ Close func() error

+ Remove func() error

type IntegerValues

+ func (a IntegerValues) FindRange(min, max int64) (int, int)

type KeyCursor

+ func (c *KeyCursor) ReadUnsignedBlock(buf *[]UnsignedValue) ([]UnsignedValue, error)

type KeyIterator

+ Err func() error

+ EstimatedIndexSize func() int

type StringValues

+ func (a StringValues) FindRange(min, max int64) (int, int)

type TSMFile

+ BatchDelete func() BatchDeleter

+ Free func() error

+ OverlapsKeyRange func(min, max []byte) bool

+ OverlapsTimeRange func(min, max int64) bool

+ ReadUnsignedBlockAt func(entry *IndexEntry, values *[]UnsignedValue) ([]UnsignedValue, error)

+ Seek func(key []byte) int

type TSMIndex

+ Close func() error

+ ContainsKey func(key []byte) bool

+ Seek func(key []byte) int

type TSMReader

+ func (r *TSMReader) BatchDelete() BatchDeleter

+ func (t *TSMReader) Free() error

+ func (t *TSMReader) OverlapsKeyRange(min, max []byte) bool

+ func (t *TSMReader) OverlapsTimeRange(min, max int64) bool

+ func (t *TSMReader) ReadUnsignedBlockAt(entry *IndexEntry, vals *[]UnsignedValue) ([]UnsignedValue, error)

+ func (t *TSMReader) Seek(key []byte) int

type TSMWriter

+ func NewTSMWriterWithDiskBuffer(w io.Writer) (TSMWriter, error)

+ Remove func() error

type TimeRange

+ func (t TimeRange) Overlaps(min, max int64) bool

type Tombstoner

+ FilterFn func(k []byte) bool

+ func (t *Tombstoner) Flush() error

+ func (t *Tombstoner) Rollback() error

+ type UnsignedValue struct

+ func DecodeUnsignedBlock(block []byte, a *[]UnsignedValue) ([]UnsignedValue, error)

+ func (v UnsignedValue) Size() int

+ func (v UnsignedValue) String() string

+ func (v UnsignedValue) UnixNano() int64

+ func (v UnsignedValue) Value() interface{}

+ type UnsignedValues []UnsignedValue

+ func (a UnsignedValues) Deduplicate() UnsignedValues

+ func (a UnsignedValues) Encode(buf []byte) ([]byte, error)

+ func (a UnsignedValues) Exclude(min, max int64) UnsignedValues

+ func (a UnsignedValues) FindRange(min, max int64) (int, int)

+ func (a UnsignedValues) Include(min, max int64) UnsignedValues

+ func (a UnsignedValues) Len() int

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

+ func (a UnsignedValues) MaxTime() int64

+ func (a UnsignedValues) Merge(b UnsignedValues) UnsignedValues

+ func (a UnsignedValues) MinTime() int64

+ func (a UnsignedValues) Size() int

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

type Value

+ func NewUnsignedValue(t int64, v uint64) Value

type Values

+ func (a Values) FindRange(min, max int64) (int, int)

type WALSegmentReader

+ func (r *WALSegmentReader) Reset(rc io.ReadCloser)

Aug 23, 2017

Changes in this version

type FileStore

+ func (f *FileStore) ReplaceWithCallback(oldFiles, newFiles []string, updatedFn func(r []TSMFile)) error

Aug 4, 2017

Changes in this version

+ func ErrCacheMemorySizeLimitExceeded(n, limit uint64) error

type BooleanEncoder

+ func (e *BooleanEncoder) Flush()

+ func (e *BooleanEncoder) Reset()

type BooleanValues

+ func (a BooleanValues) Encode(buf []byte) ([]byte, error)

type Cache

+ func (c *Cache) ApplyEntryFn(f func(key string, entry *entry) error) error

type CacheLoader

+ func (cl *CacheLoader) WithLogger(log zap.Logger)

type CacheStatistics

+ WriteDropped int64

type CompactionPlanner

+ FullyCompacted func() bool

+ Release func(group []CompactionGroup)

type Compactor

+ func (c *Compactor) DisableCompactions()

+ func (c *Compactor) DisableSnapshots()

+ func (c *Compactor) EnableCompactions()

+ func (c *Compactor) EnableSnapshots()

type DefaultPlanner

+ func NewDefaultPlanner(fs fileStore, writeColdDuration time.Duration) *DefaultPlanner

+ func (c *DefaultPlanner) FullyCompacted() bool

+ func (c *DefaultPlanner) Release(groups []CompactionGroup)

type DeleteRangeWALEntry

+ func (w *DeleteRangeWALEntry) MarshalSize() int

type DeleteWALEntry

+ func (w *DeleteWALEntry) MarshalSize() int

type Engine

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

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

+ func (e *Engine) DiskSize() int64

+ func (e *Engine) ForEachMeasurementName(fn func(name []byte) error) error

+ func (e *Engine) ForEachMeasurementSeriesByExpr(name []byte, condition influxql.Expr, fn func(tags models.Tags) error) error

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

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

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

+ func (e *Engine) IsIdle() bool

+ func (e *Engine) LastModified() time.Time

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

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

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

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

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

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

+ func (e *Engine) MeasurementsSketches() (estimator.Sketch, estimator.Sketch, error)

+ func (e *Engine) SeriesN() int64

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

+ func (e *Engine) SeriesSketches() (estimator.Sketch, estimator.Sketch, error)

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

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

+ func (e *Engine) WithLogger(log zap.Logger)

type EngineStatistics

+ CacheCompactionsActive int64

+ TSMCompactionsActive [3]int64

+ TSMFullCompactionsActive int64

+ TSMOptimizeCompactionsActive int64

type FileStore

+ OnReplace func(r []TSMFile)

+ func (f *FileStore) DiskSizeBytes() int64

+ func (f *FileStore) WithLogger(log zap.Logger)

type FloatEncoder

+ func (s *FloatEncoder) Flush()

+ func (s *FloatEncoder) Reset()

+ func (s *FloatEncoder) Write(v float64)

type FloatValues

+ func (a FloatValues) Encode(buf []byte) ([]byte, error)

type IntegerEncoder

+ func (e *IntegerEncoder) Flush()

+ func (e *IntegerEncoder) Reset()

type IntegerValues

+ func (a IntegerValues) Encode(buf []byte) ([]byte, error)

type StringEncoder

+ func (e *StringEncoder) Flush()

+ func (e *StringEncoder) Reset()

type StringValues

+ func (a StringValues) Encode(buf []byte) ([]byte, error)

type TSMIndex

+ OverlapsKeyRange func(min, max string) bool

+ OverlapsTimeRange func(min, max int64) bool

type TSMReader

+ func (t *TSMReader) ReadBytes(e *IndexEntry, b []byte) (uint32, []byte, error)

type TSMWriter

+ Flush func() error

type TimeEncoder

+ Reset func()

type Value

+ func NewBooleanValue(t int64, v bool) Value

+ func NewFloatValue(t int64, v float64) Value

+ func NewIntegerValue(t int64, v int64) Value

+ func NewStringValue(t int64, v string) Value

type WAL

+ func (l *WAL) DiskSizeBytes() int64

+ func (l *WAL) WithLogger(log zap.Logger)

+ func (l *WAL) WriteMulti(values map[string][]Value) (int, error)

type WALEntry

+ MarshalSize func() int

type WALSegmentWriter

+ func (w *WALSegmentWriter) Flush() error

type WriteWALEntry

+ func (w *WriteWALEntry) MarshalSize() int

Sep 26, 2016

Changes in this version

+ var ErrFileInUse = fmt.Errorf("file still in use")

+ var ErrMaxBlocksExceeded = fmt.Errorf("max blocks exceeded")

+ func SeriesAndFieldFromCompositeKey(key string) (string, string)

type BooleanValues

+ func (a BooleanValues) Exclude(min, max int64) BooleanValues

+ func (a BooleanValues) Include(min, max int64) BooleanValues

+ func (a BooleanValues) MaxTime() int64

+ func (a BooleanValues) Merge(b BooleanValues) BooleanValues

+ func (a BooleanValues) MinTime() int64

+ func (a BooleanValues) Size() int

type Cache

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

+ type CacheStatistics struct

+ CacheAgeMs int64

+ CachedBytes int64

+ DiskSizeBytes int64

+ MemSizeBytes int64

+ SnapshotCount int64

+ WALCompactionTimeMs int64

+ WriteErr int64

+ WriteOK int64

type CompactionPlanner

+ PlanOptimize func() []CompactionGroup

type Compactor

+ func (c *Compactor) Close()

+ func (c *Compactor) Open()

type DefaultPlanner

+ func (c *DefaultPlanner) PlanOptimize() []CompactionGroup

type Engine

+ func (e *Engine) CreateSnapshot() (string, error)

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

+ func (e *Engine) SetCompactionsEnabled(enabled bool)

+ func (e *Engine) SetEnabled(enabled bool)

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

+ type EngineStatistics struct

+ CacheCompactionDuration int64

+ CacheCompactionErrors int64

+ CacheCompactions int64

+ TSMCompactionDuration [3]int64

+ TSMCompactionErrors [3]int64

+ TSMCompactions [3]int64

+ TSMFullCompactionDuration int64

+ TSMFullCompactionErrors int64

+ TSMFullCompactions int64

+ TSMOptimizeCompactionDuration int64

+ TSMOptimizeCompactionErrors int64

+ TSMOptimizeCompactions int64

type FileStore

+ func (f *FileStore) CreateSnapshot() (string, error)

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

+ type FileStoreStatistics struct

+ DiskBytes int64

+ FileCount int64

type FloatValues

+ func (a FloatValues) Exclude(min, max int64) FloatValues

+ func (a FloatValues) Include(min, max int64) FloatValues

+ func (a FloatValues) MaxTime() int64

+ func (a FloatValues) Merge(b FloatValues) FloatValues

+ func (a FloatValues) MinTime() int64

+ func (a FloatValues) Size() int

type IntegerValues

+ func (a IntegerValues) Exclude(min, max int64) IntegerValues

+ func (a IntegerValues) Include(min, max int64) IntegerValues

+ func (a IntegerValues) MaxTime() int64

+ func (a IntegerValues) Merge(b IntegerValues) IntegerValues

+ func (a IntegerValues) MinTime() int64

+ func (a IntegerValues) Size() int

type StringValues

+ func (a StringValues) Exclude(min, max int64) StringValues

+ func (a StringValues) Include(min, max int64) StringValues

+ func (a StringValues) MaxTime() int64

+ func (a StringValues) Merge(b StringValues) StringValues

+ func (a StringValues) MinTime() int64

+ func (a StringValues) Size() int

type TSMFile

+ InUse func() bool

+ Ref func()

+ Rename func(path string) error

+ Unref func()

type TSMReader

+ func (t *TSMReader) InUse() bool

+ func (t *TSMReader) Ref()

+ func (t *TSMReader) Rename(path string) error

+ func (t *TSMReader) Unref()

type Tombstoner

+ func (t *Tombstoner) Walk(fn func(t Tombstone) error) error

type Values

+ func (a Values) Exclude(min, max int64) Values

+ func (a Values) Include(min, max int64) Values

+ func (a Values) Merge(b Values) Values

type WAL

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

+ type WALStatistics struct

+ CurrentBytes int64

+ OldBytes int64

+ WriteErr int64

+ WriteOK int64

May 11, 2016

Changes in this version

+ var ErrWALCorrupt = fmt.Errorf("corrupted WAL entry")

+ type BitReader struct

+ func NewBitReader(data []byte) *BitReader

+ func (r *BitReader) CanReadBitFast() bool

+ func (r *BitReader) ReadBit() (bool, error)

+ func (r *BitReader) ReadBitFast() bool

+ func (r *BitReader) ReadBits(nbits uint) (uint64, error)

+ func (r *BitReader) Reset(data []byte)

type BooleanDecoder

+ func (e *BooleanDecoder) SetBytes(b []byte)

type BooleanValues

+ func (a BooleanValues) Filter(min, max int64) BooleanValues

type Cache

+ func (c *Cache) DeleteRange(keys []string, min, max int64)

+ func (c *Cache) SetMaxSize(size uint64)

type CacheLoader

+ func (cl *CacheLoader) SetLogOutput(w io.Writer)

+ type DeleteRangeWALEntry struct

+ Keys []string

+ Max int64

+ Min int64

+ func (w *DeleteRangeWALEntry) Encode(b []byte) ([]byte, error)

+ func (w *DeleteRangeWALEntry) MarshalBinary() ([]byte, error)

+ func (w *DeleteRangeWALEntry) Type() WalEntryType

+ func (w *DeleteRangeWALEntry) UnmarshalBinary(b []byte) error

type Engine

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

+ func (e *Engine) DeleteSeriesRange(seriesKeys []string, min, max int64) error

type FileStore

+ func (f *FileStore) DeleteRange(keys []string, min, max int64) error

+ func (f *FileStore) SetLogOutput(w io.Writer)

type FloatDecoder

+ func (it *FloatDecoder) SetBytes(b []byte) error

type FloatValues

+ func (a FloatValues) Filter(min, max int64) FloatValues

type IndexWriter

+ func NewIndexWriter() IndexWriter

+ Add func(key string, blockType byte, minTime, maxTime int64, offset int64, size uint32)

+ Entries func(key string) []IndexEntry

+ KeyCount func() int

+ Keys func() []string

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

+ Size func() uint32

+ WriteTo func(w io.Writer) error

type IntegerValues

+ func (a IntegerValues) Filter(min, max int64) IntegerValues

type StringDecoder

+ func (e *StringDecoder) SetBytes(b []byte) error

type StringValues

+ func (a StringValues) Filter(min, max int64) StringValues

type TSMFile

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

+ TombstoneRange func(key string) []TimeRange

type TSMIndex

+ DeleteRange func(keys []string, minTime, maxTime int64)

+ TombstoneRange func(key string) []TimeRange

type TSMReader

+ func (t *TSMReader) DeleteRange(keys []string, minTime, maxTime int64) error

+ func (t *TSMReader) TombstoneRange(key string) []TimeRange

type TimeDecoder

+ func (d *TimeDecoder) Init(b []byte)

+ type TimeRange struct

+ Max int64

+ Min int64

+ type Tombstone struct

+ Key string

+ Max int64

+ Min int64

type Tombstoner

+ func (t *Tombstoner) AddRange(keys []string, min, max int64) error

type Values

+ func (a Values) Filter(min, max int64) Values

type WAL

+ func (l *WAL) DeleteRange(keys []string, min, max int64) (int, error)

+ func (l *WAL) SetLogOutput(w io.Writer)

type WalEntryType

+ const DeleteRangeWALEntryType

Apr 7, 2016

Changes in this version

+ var ErrMaxKeyLengthExceeded = fmt.Errorf("max key length exceeded")

type Cache

+ func (c *Cache) RLock()

+ func (c *Cache) RUnlock()

type FileStore

+ func (f *FileStore) WalkKeys(fn func(key string, typ byte) error) error

type IntegerDecoder

+ func (d *IntegerDecoder) SetBytes(b []byte)

type TSMFile

+ KeyAt func(idx int) (string, byte)

+ KeyCount func() int

+ ReadEntries func(key string, entries *[]IndexEntry)

type TSMIndex

+ ReadEntries func(key string, entries *[]IndexEntry)

type TSMReader

+ func (t *TSMReader) ReadEntries(key string, entries *[]IndexEntry)

Mar 22, 2016

Changes in this version

+ const BlockBoolean

+ const BlockInteger

+ var ErrSnapshotInProgress = fmt.Errorf("snapshot in progress")

+ type BooleanDecoder interface

+ Error func() error

+ Next func() bool

+ Read func() bool

+ func NewBooleanDecoder(b []byte) BooleanDecoder

+ type BooleanEncoder interface

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

+ Write func(b bool)

+ func NewBooleanEncoder() BooleanEncoder

+ type BooleanValue struct

+ func DecodeBooleanBlock(block []byte, a []BooleanValue) ([]BooleanValue, error)

+ func (b *BooleanValue) Size() int

+ func (b *BooleanValue) UnixNano() int64

+ func (b *BooleanValue) Value() interface{}

+ func (f *BooleanValue) String() string

+ type BooleanValues []BooleanValue

+ func (a BooleanValues) Deduplicate() BooleanValues

+ func (a BooleanValues) Len() int

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

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

type Cache

+ func (c *Cache) UpdateAge()

+ func (c *Cache) UpdateCompactTime(d time.Duration)

type Engine

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

+ func (e *Engine) Index() *tsdb.DatabaseIndex

+ func (e *Engine) MeasurementFields(name string) *tsdb.MeasurementFields

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

type FileStore

+ func (f *FileStore) Files() []TSMFile

+ type FloatValues []FloatValue

+ func (a FloatValues) Deduplicate() FloatValues

+ func (a FloatValues) Len() int

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

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

type IndexEntry

+ func (e *IndexEntry) AppendTo(b []byte) []byte

+ type IntegerDecoder interface

+ Error func() error

+ Next func() bool

+ Read func() int64

+ func NewIntegerDecoder(b []byte) IntegerDecoder

+ type IntegerEncoder interface

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

+ Write func(v int64)

+ func NewIntegerEncoder() IntegerEncoder

+ type IntegerValue struct

+ func DecodeIntegerBlock(block []byte, a []IntegerValue) ([]IntegerValue, error)

+ func (f *IntegerValue) String() string

+ func (v *IntegerValue) Size() int

+ func (v *IntegerValue) UnixNano() int64

+ func (v *IntegerValue) Value() interface{}

+ type IntegerValues []IntegerValue

+ func (a IntegerValues) Deduplicate() IntegerValues

+ func (a IntegerValues) Len() int

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

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

type KeyCursor

+ func (c *KeyCursor) ReadBooleanBlock(buf []BooleanValue) ([]BooleanValue, error)

+ func (c *KeyCursor) ReadFloatBlock(buf []FloatValue) ([]FloatValue, error)

+ func (c *KeyCursor) ReadIntegerBlock(buf []IntegerValue) ([]IntegerValue, error)

+ func (c *KeyCursor) ReadStringBlock(buf []StringValue) ([]StringValue, error)

+ type StringValues []StringValue

+ func (a StringValues) Deduplicate() StringValues

+ func (a StringValues) Len() int

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

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

type TSMFile

+ ReadBooleanBlockAt func(entry *IndexEntry, values []BooleanValue) ([]BooleanValue, error)

+ ReadFloatBlockAt func(entry *IndexEntry, values []FloatValue) ([]FloatValue, error)

+ ReadIntegerBlockAt func(entry *IndexEntry, values []IntegerValue) ([]IntegerValue, error)

+ ReadStringBlockAt func(entry *IndexEntry, values []StringValue) ([]StringValue, error)

type TSMReader

+ func (t *TSMReader) ReadBooleanBlockAt(entry *IndexEntry, vals []BooleanValue) ([]BooleanValue, error)

+ func (t *TSMReader) ReadFloatBlockAt(entry *IndexEntry, vals []FloatValue) ([]FloatValue, error)

+ func (t *TSMReader) ReadIntegerBlockAt(entry *IndexEntry, vals []IntegerValue) ([]IntegerValue, error)

+ func (t *TSMReader) ReadStringBlockAt(entry *IndexEntry, vals []StringValue) ([]StringValue, error)

Mar 9, 2016

Changes in this version

+ func BlockCount(block []byte) int

+ func CountTimestamps(b []byte) int

+ type BlockIterator struct

+ func (b *BlockIterator) Next() bool

+ func (b *BlockIterator) PeekNext() string

+ func (b *BlockIterator) Read() (string, time.Time, time.Time, []byte, error)

type Cache

+ func (c *Cache) Deduplicate()

+ type CompactionGroup []string

type CompactionPlanner

+ PlanLevel func(level int) []CompactionGroup

type Compactor

+ Size int

+ func (c *Compactor) CompactFast(tsmFiles []string) ([]string, error)

+ func (c *Compactor) CompactFull(tsmFiles []string) ([]string, error)

type DefaultPlanner

+ func (c *DefaultPlanner) PlanLevel(level int) []CompactionGroup

type Engine

+ Cache *Cache

+ CacheFlushMemorySizeThreshold uint64

+ CacheFlushWriteColdDuration time.Duration

+ CompactionPlan CompactionPlanner

+ Compactor *Compactor

+ FileStore *FileStore

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

+ func (e *Engine) KeyCursor(key string) *KeyCursor

+ func (e *Engine) ShouldCompactCache(lastWriteTime time.Time) bool

+ func (e *Engine) WriteSnapshot() error

type FileStore

+ Logger *log.Logger

+ func (f *FileStore) BlockCount(path string, idx int) int

type KeyCursor

+ func (c *KeyCursor) Close()

type TSMFile

+ BlockIterator func() *BlockIterator

+ TombstoneFiles func() []FileStat

type TSMIndex

+ KeyAt func(index int) string

+ Write func(w io.Writer) error

type TSMReader

+ func (t *TSMReader) BlockIterator() *BlockIterator

+ func (t *TSMReader) KeyAt(idx int) string

+ func (t *TSMReader) KeyCount() int

+ func (t *TSMReader) TombstoneFiles() []FileStat

type TSMWriter

+ WriteBlock func(key string, minTime, maxTime time.Time, block []byte) error

type Tombstoner

+ func (t *Tombstoner) TombstoneFiles() []FileStat

Dec 8, 2015

Changes in this version

+ const CompactionTempExtension

+ const TSMFileExtension

+ var ErrCacheInvalidCheckpoint = fmt.Errorf("invalid checkpoint")

+ var ErrCacheMemoryExceeded = fmt.Errorf("cache maximum memory size exceeded")

+ var ErrNoValues = fmt.Errorf("no values written")

+ var ErrTSMClosed = fmt.Errorf("tsm file closed")

+ var MaxTime = time.Unix(0, math.MaxInt64)

+ var MinTime = time.Unix(0, 0)

+ func BlockType(block []byte) (byte, error)

+ func NewDevEngine(path string, walPath string, opt tsdb.EngineOptions) tsdb.Engine

+ func ParseTSMFileName(name string) (int, int, error)

type BoolValue

+ func DecodeBoolBlock(block []byte, a []*BoolValue) ([]*BoolValue, error)

+ func (f *BoolValue) String() string

+ type Cache struct

+ func NewCache(maxSize uint64) *Cache

+ func (c *Cache) ClearSnapshot(snapshot *Cache)

+ func (c *Cache) Delete(keys []string)

+ func (c *Cache) Keys() []string

+ func (c *Cache) Lock()

+ func (c *Cache) MaxSize() uint64

+ func (c *Cache) Size() uint64

+ func (c *Cache) Snapshot() *Cache

+ func (c *Cache) Store() map[string]*entry

+ func (c *Cache) Unlock()

+ func (c *Cache) Values(key string) Values

+ func (c *Cache) Write(key string, values []Value) error

+ func (c *Cache) WriteMulti(values map[string][]Value) error

+ type CacheLoader struct

+ Logger *log.Logger

+ func NewCacheLoader(files []string) *CacheLoader

+ func (cl *CacheLoader) Load(cache *Cache) error

+ type CompactionPlanner interface

+ Plan func(lastWrite time.Time) []string

+ type Compactor struct

+ Cancel chan struct{}

+ Dir string

+ FileStore interface{ ... }

+ func (c *Compactor) Clone() *Compactor

+ func (c *Compactor) Compact(tsmFiles []string) ([]string, error)

+ func (c *Compactor) WriteSnapshot(cache *Cache) ([]string, error)

+ type DefaultPlanner struct

+ CompactFullWriteColdDuration time.Duration

+ FileStore interface{ ... }

+ MinCompactionFileCount int

+ func (c *DefaultPlanner) Plan(lastWrite time.Time) []string

+ type DeleteWALEntry struct

+ Keys []string

+ func (w *DeleteWALEntry) Encode(dst []byte) ([]byte, error)

+ func (w *DeleteWALEntry) MarshalBinary() ([]byte, error)

+ func (w *DeleteWALEntry) Type() WalEntryType

+ func (w *DeleteWALEntry) UnmarshalBinary(b []byte) error

+ type DevEngine struct

+ Cache *Cache

+ CacheFlushMemorySizeThreshold uint64

+ CacheFlushWriteColdDuration time.Duration

+ CompactionPlan CompactionPlanner

+ Compactor *Compactor

+ FileStore *FileStore

+ MaxPointsPerBlock int

+ WAL *WAL

+ func (e *DevEngine) Begin(writable bool) (tsdb.Tx, error)

+ func (e *DevEngine) Close() error

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

+ func (e *DevEngine) DeleteSeries(seriesKeys []string) error

+ func (e *DevEngine) Format() tsdb.EngineFormat

+ func (e *DevEngine) KeyCursor(key string) *KeyCursor

+ func (e *DevEngine) LoadMetadataIndex(_ *tsdb.Shard, index *tsdb.DatabaseIndex, ...) error

+ func (e *DevEngine) Open() error

+ func (e *DevEngine) Path() string

+ func (e *DevEngine) PerformMaintenance()

+ func (e *DevEngine) SeriesCount() (n int, err error)

+ func (e *DevEngine) SetLogOutput(w io.Writer)

+ func (e *DevEngine) ShouldCompactCache(lastWriteTime time.Time) bool

+ func (e *DevEngine) WritePoints(points []models.Point, ...) error

+ func (e *DevEngine) WriteSnapshot() error

+ func (e *DevEngine) WriteTo(w io.Writer) (n int64, err error)

type EmptyValue

+ func (e *EmptyValue) String() string

+ type FileStat struct

+ HasTombstone bool

+ LastModified time.Time

+ MaxKey string

+ MaxTime time.Time

+ MinKey string

+ MinTime time.Time

+ Path string

+ Size uint32

+ func (f FileStat) ContainsKey(key string) bool

+ func (f FileStat) OverlapsKeyRange(min, max string) bool

+ func (f FileStat) OverlapsTimeRange(min, max time.Time) bool

+ type FileStore struct

+ func NewFileStore(dir string) *FileStore

+ func (f *FileStore) Add(files ...TSMFile)

+ func (f *FileStore) Close() error

+ func (f *FileStore) Count() int

+ func (f *FileStore) CurrentGeneration() int

+ func (f *FileStore) Delete(keys []string) error

+ func (f *FileStore) KeyCursor(key string) *KeyCursor

+ func (f *FileStore) Keys() []string

+ func (f *FileStore) LastModified() time.Time

+ func (f *FileStore) NextGeneration() int

+ func (f *FileStore) Open() error

+ func (f *FileStore) Read(key string, t time.Time) ([]Value, error)

+ func (f *FileStore) Remove(paths ...string)

+ func (f *FileStore) Replace(oldFiles, newFiles []string) error

+ func (f *FileStore) Stats() []FileStat

+ func (f *FileStore) Type(key string) (byte, error)

type FloatValue

+ func DecodeFloatBlock(block []byte, a []*FloatValue) ([]*FloatValue, error)

+ func (f *FloatValue) String() string

type IndexEntry

+ func (e *IndexEntry) OverlapsTimeRange(min, max time.Time) bool

+ func (e *IndexEntry) String() string

type Int64Value

+ func DecodeInt64Block(block []byte, a []*Int64Value) ([]*Int64Value, error)

+ type KeyCursor struct

+ func (c *KeyCursor) Next(ascending bool) ([]Value, error)

+ func (c *KeyCursor) SeekTo(t time.Time, ascending bool) ([]Value, error)

+ type KeyIterator interface

+ Close func() error

+ Next func() bool

+ Read func() (string, []Value, error)

+ func NewCacheKeyIterator(cache *Cache) KeyIterator

+ func NewTSMKeyIterator(readers ...*TSMReader) (KeyIterator, error)

+ type SegmentInfo struct

type StringValue

+ func DecodeStringBlock(block []byte, a []*StringValue) ([]*StringValue, error)

+ type TSMFile interface

+ Close func() error

+ Contains func(key string) bool

+ ContainsValue func(key string, t time.Time) bool

+ Delete func(keys []string) error

+ Entries func(key string) []*IndexEntry

+ HasTombstones func() bool

+ KeyRange func() (string, string)

+ Keys func() []string

+ Path func() string

+ Read func(key string, t time.Time) ([]Value, error)

+ ReadAt func(entry *IndexEntry, values []Value) ([]Value, error)

+ Remove func() error

+ Size func() uint32

+ Stats func() FileStat

+ TimeRange func() (time.Time, time.Time)

+ Type func(key string) (byte, error)

type TSMIndex

+ Contains func(key string) bool

+ ContainsValue func(key string, timestamp time.Time) bool

+ Delete func(keys []string)

+ Key func(index int) (string, []*IndexEntry)

+ KeyCount func() int

+ KeyRange func() (string, string)

+ Keys func() []string

+ Size func() uint32

+ TimeRange func() (time.Time, time.Time)

+ Type func(key string) (byte, error)

+ type TSMReader struct

+ func NewTSMReaderWithOptions(opt TSMReaderOptions) (*TSMReader, error)

+ func (t *TSMReader) Close() error

+ func (t *TSMReader) Contains(key string) bool

+ func (t *TSMReader) ContainsValue(key string, ts time.Time) bool

+ func (t *TSMReader) Delete(keys []string) error

+ func (t *TSMReader) Entries(key string) []*IndexEntry

+ func (t *TSMReader) HasTombstones() bool

+ func (t *TSMReader) IndexSize() uint32

+ func (t *TSMReader) Key(index int) (string, []*IndexEntry)

+ func (t *TSMReader) KeyRange() (string, string)

+ func (t *TSMReader) Keys() []string

+ func (t *TSMReader) LastModified() time.Time

+ func (t *TSMReader) Path() string

+ func (t *TSMReader) Read(key string, timestamp time.Time) ([]Value, error)

+ func (t *TSMReader) ReadAll(key string) ([]Value, error)

+ func (t *TSMReader) ReadAt(entry *IndexEntry, vals []Value) ([]Value, error)

+ func (t *TSMReader) Remove() error

+ func (t *TSMReader) Size() uint32

+ func (t *TSMReader) Stats() FileStat

+ func (t *TSMReader) TimeRange() (time.Time, time.Time)

+ func (t *TSMReader) Type(key string) (byte, error)

+ type TSMReaderOptions struct

+ MMAPFile *os.File

+ Reader io.ReadSeeker

type TSMWriter

+ Size func() uint32

+ WriteIndex func() error

+ type Tombstoner struct

+ Path string

+ func (t *Tombstoner) Add(keys []string) error

+ func (t *Tombstoner) Delete() error

+ func (t *Tombstoner) HasTombstones() bool

+ func (t *Tombstoner) ReadAll() ([]string, error)

type Value

+ String func() string

type Values

+ func (a Values) InfluxQLType() (influxql.DataType, error)

+ func (a Values) Size() int

+ type WAL struct

+ LogOutput io.Writer

+ LoggingEnabled bool

+ SegmentSize int

+ func NewWAL(path string) *WAL

+ func (l *WAL) Close() error

+ func (l *WAL) CloseSegment() error

+ func (l *WAL) ClosedSegments() ([]string, error)

+ func (l *WAL) Delete(keys []string) (int, error)

+ func (l *WAL) LastWriteTime() time.Time

+ func (l *WAL) Open() error

+ func (l *WAL) Path() string

+ func (l *WAL) Remove(files []string) error

+ func (l *WAL) WritePoints(values map[string][]Value) (int, error)

+ type WALEntry interface

+ Encode func(dst []byte) ([]byte, error)

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

+ Type func() WalEntryType

+ UnmarshalBinary func(b []byte) error

+ type WALSegmentReader struct

+ func NewWALSegmentReader(r io.ReadCloser) *WALSegmentReader

+ func (r *WALSegmentReader) Close() error

+ func (r *WALSegmentReader) Count() int64

+ func (r *WALSegmentReader) Error() error

+ func (r *WALSegmentReader) Next() bool

+ func (r *WALSegmentReader) Read() (WALEntry, error)

+ type WALSegmentWriter struct

+ func NewWALSegmentWriter(w io.WriteCloser) *WALSegmentWriter

+ func (w *WALSegmentWriter) Write(entryType WalEntryType, compressed []byte) error

+ type WalEntryType byte

+ const DeleteWALEntryType

+ const WriteWALEntryType

+ type WriteWALEntry struct

+ Values map[string][]Value

+ func (w *WriteWALEntry) Encode(dst []byte) ([]byte, error)

+ func (w *WriteWALEntry) MarshalBinary() ([]byte, error)

+ func (w *WriteWALEntry) Type() WalEntryType

+ func (w *WriteWALEntry) UnmarshalBinary(b []byte) error

Nov 17, 2015

Changes in this version

+ const BlockBool

+ const BlockFloat64

+ const BlockInt64

+ const BlockString

+ const CheckpointExtension

+ const CollisionsFileExtension

+ const CompactionExtension

+ const DefaultMaxPointsPerBlock

+ const DefaultRotateFileSize

+ const DefaultSegmentSize

+ const FieldsFileExtension

+ const Format

+ const IDsFileExtension

+ const MAP_POPULATE

+ const MagicNumber

+ const MaxDataFileSize

+ const SeriesFileExtension

+ const Version

+ const WALFileExtension

+ const WALFilePrefix

+ var ErrWALClosed = fmt.Errorf("WAL closed")

+ func DecodeBlock(block []byte, vals *[]Value) error

+ func NewCombinedEngineCursor(wc, ec tsdb.Cursor, ascending bool) tsdb.Cursor

+ func NewDataFile(f *os.File) (*dataFile, error)

+ func NewEngine(path string, walPath string, opt tsdb.EngineOptions) tsdb.Engine

+ func NewMultiFieldCursor(fields []string, cursors []tsdb.Cursor, ascending bool) tsdb.Cursor

+ func NewTSMReader(r io.ReadSeeker) (*tsmReader, error)

+ func SeriesFieldKey(seriesKey, field string) string

+ func ZigZagDecode(v uint64) int64

+ func ZigZagEncode(x int64) uint64

+ type BoolDecoder interface

+ Error func() error

+ Next func() bool

+ Read func() bool

+ func NewBoolDecoder(b []byte) BoolDecoder

+ type BoolEncoder interface

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

+ Write func(b bool)

+ func NewBoolEncoder() BoolEncoder

+ type BoolValue struct

+ func (b *BoolValue) Size() int

+ func (b *BoolValue) Time() time.Time

+ func (b *BoolValue) UnixNano() int64

+ func (b *BoolValue) Value() interface{}

+ type EmptyValue struct

+ func (e *EmptyValue) Size() int

+ func (e *EmptyValue) Time() time.Time

+ func (e *EmptyValue) UnixNano() int64

+ func (e *EmptyValue) Value() interface{}

+ type Engine struct

+ CompactionAge time.Duration

+ HashSeriesField func(key string) uint64

+ IndexCompactionFullAge time.Duration

+ IndexMinCompactionInterval time.Duration

+ MaxFileSize uint32

+ MaxPointsPerBlock int

+ MinCompactionFileCount int

+ RotateFileSize uint32

+ SkipCompaction bool

+ WAL *Log

+ func (e *Engine) Begin(writable bool) (tsdb.Tx, error)

+ func (e *Engine) Close() error

+ func (e *Engine) Compact(fullCompaction bool) error

+ func (e *Engine) DataFileCount() int

+ func (e *Engine) DecodeAndCombine(newValues Values, block, buf []byte, nextTime int64, hasFutureBlock bool) (Values, []byte, error)

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

+ func (e *Engine) DeleteSeries(seriesKeys []string) error

+ func (e *Engine) Format() tsdb.EngineFormat

+ func (e *Engine) LoadMetadataIndex(shard *tsdb.Shard, index *tsdb.DatabaseIndex, ...) error

+ func (e *Engine) MarkDeletes(keys []string)

+ func (e *Engine) MarkMeasurementDelete(name string)

+ func (e *Engine) Open() error

+ func (e *Engine) Path() string

+ func (e *Engine) PerformMaintenance()

+ func (e *Engine) SeriesCount() (n int, err error)

+ func (e *Engine) SetLogOutput(w io.Writer)

+ func (e *Engine) Write(pointsByKey map[string]Values, ...) error

+ func (e *Engine) WritePoints(points []models.Point, ...) error

+ func (e *Engine) WriteTo(w io.Writer) (n int64, err error)

+ type FloatDecoder struct

+ func NewFloatDecoder(b []byte) (*FloatDecoder, error)

+ func (it *FloatDecoder) Error() error

+ func (it *FloatDecoder) Next() bool

+ func (it *FloatDecoder) Values() float64

+ type FloatEncoder struct

+ func NewFloatEncoder() *FloatEncoder

+ func (s *FloatEncoder) Bytes() ([]byte, error)

+ func (s *FloatEncoder) Finish()

+ func (s *FloatEncoder) Push(v float64)

+ type FloatValue struct

+ func (f *FloatValue) Size() int

+ func (f *FloatValue) Time() time.Time

+ func (f *FloatValue) UnixNano() int64

+ func (f *FloatValue) Value() interface{}

+ type IndexEntry struct

+ MaxTime time.Time

+ MinTime time.Time

+ Offset int64

+ Size uint32

+ func (e *IndexEntry) Contains(t time.Time) bool

+ func (e *IndexEntry) UnmarshalBinary(b []byte) error

+ type IndexWriter interface

+ MarkDeletes func(keys []string)

+ MarkMeasurementDelete func(name string)

+ Write func(valuesByKey map[string]Values, ...) error

+ type Int64Decoder interface

+ Error func() error

+ Next func() bool

+ Read func() int64

+ func NewInt64Decoder(b []byte) Int64Decoder

+ type Int64Encoder interface

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

+ Write func(v int64)

+ func NewInt64Encoder() Int64Encoder

+ type Int64Value struct

+ func (v *Int64Value) Size() int

+ func (v *Int64Value) String() string

+ func (v *Int64Value) Time() time.Time

+ func (v *Int64Value) UnixNano() int64

+ func (v *Int64Value) Value() interface{}

+ type Log struct

+ FlushColdInterval time.Duration

+ FlushMemorySizeThreshold int

+ IndexWriter IndexWriter

+ LogOutput io.Writer

+ LoggingEnabled bool

+ MaxMemorySizeThreshold int

+ SegmentSize int

+ SkipCache bool

+ SkipDurability bool

+ func NewLog(path string) *Log

+ func (l *Log) Close() error

+ func (l *Log) Cursor(series string, fields []string, dec *tsdb.FieldCodec, ascending bool) tsdb.Cursor

+ func (l *Log) DeleteMeasurement(measurement string, keys []string) error

+ func (l *Log) DeleteSeries(keys []string) error

+ func (l *Log) Flush() error

+ func (l *Log) LastWriteTime() time.Time

+ func (l *Log) Open() error

+ func (l *Log) Path() string

+ func (l *Log) WritePoints(points []models.Point, fields map[string]*tsdb.MeasurementFields, ...) error

+ type StringDecoder interface

+ Error func() error

+ Next func() bool

+ Read func() string

+ func NewStringDecoder(b []byte) (StringDecoder, error)

+ type StringEncoder interface

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

+ Write func(s string)

+ func NewStringEncoder() StringEncoder

+ type StringValue struct

+ func (v *StringValue) Size() int

+ func (v *StringValue) String() string

+ func (v *StringValue) Time() time.Time

+ func (v *StringValue) UnixNano() int64

+ func (v *StringValue) Value() interface{}

+ type TSMIndex interface

+ Add func(key string, minTime, maxTime time.Time, offset int64, size uint32)

+ Entries func(key string) []*IndexEntry

+ Entry func(key string, timestamp time.Time) *IndexEntry

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

+ UnmarshalBinary func(b []byte) error

+ func NewDirectIndex() TSMIndex

+ func NewIndirectIndex() TSMIndex

+ type TSMWriter interface

+ Close func() error

+ Write func(key string, values Values) error

+ func NewTSMWriter(w io.Writer) (TSMWriter, error)

+ type TimeDecoder interface

+ Error func() error

+ Next func() bool

+ Read func() time.Time

+ func NewTimeDecoder(b []byte) TimeDecoder

+ type TimeEncoder interface

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

+ Write func(t time.Time)

+ func NewTimeEncoder() TimeEncoder

+ type TimePrecision uint8

+ const Microseconds

+ const Milliseconds

+ const Nanoseconds

+ const Seconds

+ type Value interface

+ Size func() int

+ Time func() time.Time

+ UnixNano func() int64

+ Value func() interface{}

+ func NewValue(t time.Time, value interface{}) Value

+ type Values []Value

+ func (a Values) Deduplicate() Values

+ func (a Values) Encode(buf []byte) ([]byte, error)

+ func (a Values) Len() int

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

+ func (a Values) MaxTime() int64

+ func (a Values) MinTime() int64

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

+ type WriteLock struct

+ func (w *WriteLock) LockRange(min, max int64)

+ func (w *WriteLock) UnlockRange(min, max int64)