Versions in this module Expand all Collapse all v0 v0.2.0 Oct 27, 2015 Changes in this version + const BlockBool + const BlockFloat64 + const BlockInt64 + const BlockString + const CheckpointExtension + const CollisionsFileExtension + const DefaultMaxPointsPerBlock + const DefaultRotateBlockSize + const DefaultRotateFileSize + const DefaultSegmentSize + const FieldsFileExtension + const Format + const IDsFileExtension + const MAP_POPULATE + const MaxDataFileSize + const SeriesFileExtension + const WALFileExtension + const WALFilePrefix + 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 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 + MaxPointsPerBlock int + MinCompactionFileCount int + RotateBlockSize 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 + 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 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 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 DecodeBlock(block []byte) (Values, error) + 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)