tsm1

package

Go to main page

Versions in this module

v0

v0.10.0-rc2

Feb 2, 2016

v0.10.0-rc1

Jan 28, 2016

v0.10.0-beta2

Jan 23, 2016

v0.10.0-beta1

Jan 13, 2016

v0.9.6

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

v0.9.6-rc2

Dec 8, 2015

v0.9.6-rc1

Dec 7, 2015

v0.9.5-rc3

Nov 16, 2015

v0.9.5-rc2

Nov 13, 2015

v0.9.5-rc1

Nov 12, 2015

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