Versions in this module Expand all Collapse all v0 v0.0.1 May 1, 2022 Changes in this version + type Compressor interface + Close func() error + Write func(points []*DataPoint) error + type DataPoint struct + Timestamp int64 + Value float64 + type DeCompressor interface + Close func() error + Read func(dst *DataPoint) error + type Label struct + Name string + Value string + type Logger interface + Printf func(format string, v ...interface{}) + type Option func(*storage) + func WithDataPath(dataPath string) Option + func WithLogger(logger Logger) Option + func WithPartitionDuration(duration time.Duration) Option + func WithTimestampPrecision(precision time.Duration) Option + type Reader interface + Select func(metrics string, labels []Label, start, end int64) (points []*DataPoint, err error) + type Row struct + Labels []Label + Metrics string + type Storage interface + Close func() error + InsertRows func(rows []Row) error + func NewStorage(opts ...Option) (Storage, error) + type TimestampPrecision string + const Microseconds + const Milliseconds + const Nanoseconds + const Seconds + type Wal interface