tsm1

Apr 4, 2016

Changes in this version

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)

Feb 4, 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

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)