Versions in this module Expand all Collapse all v0 v0.1.7 Aug 27, 2015 v0.1.6 Aug 24, 2015 Changes in this version + const CompactionExtension + const DefaultSegmentSize + const FileExtension + const MetaFileExtension + const MetaFlushInterval + const PartitionCount + var CompactSequence = []byte + var ErrCompactionRunning = errors.New("compaction running") + var ErrMemoryCompactionDone = errors.New("compaction already run to free up memory") + func MarshalEntry(timestamp int64, data []byte) []byte + func UnmarshalEntry(buf []byte) (timestamp int64, data []byte) + type IndexWriter interface + WriteIndex func(pointsByKey map[string][][]byte, ...) error + type Log struct + CompactionThreshold float64 + EnableLogging bool + FlushColdInterval time.Duration + Index IndexWriter + LogOutput io.Writer + MaxSeriesSize int + PartitionSizeThreshold uint64 + ReadySeriesSize int + SegmentSize int64 + func NewLog(path string) *Log + func (l *Log) Close() error + func (l *Log) Cursor(key string) tsdb.Cursor + func (l *Log) DeleteSeries(keys []string) error + func (l *Log) Flush() error + func (l *Log) LoadMetadataIndex(index *tsdb.DatabaseIndex, ...) error + func (l *Log) Open() error + func (l *Log) WritePoints(points []tsdb.Point, fields map[string]*tsdb.MeasurementFields, ...) error + type Partition struct + func NewPartition(id uint8, path string, segmentSize int64, sizeThreshold uint64, ...) (*Partition, error) + func (p *Partition) Close() error + func (p *Partition) Write(points []tsdb.Point) error