tstorage

Oct 31, 2021

Changes in this version

type Option

+ func WithWALBufferedSize(size int) Option

Jul 20, 2021

Changes in this version

type Option

+ func WithRetention(retention time.Duration) Option

Jun 1, 2021

Changes in this version

+ var ErrNoDataPoints = errors.New("no data points found")

+ type DataPoint struct

+ Timestamp int64

+ Value float64

+ 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 TimestampPrecision) Option

+ func WithWriteTimeout(timeout time.Duration) Option

+ type Reader interface

+ Select func(metric string, labels []Label, start, end int64) (points []*DataPoint, err error)

+ type Row struct

+ Labels []Label

+ Metric 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