storage

May 15, 2023

Changes in this version

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

+ var ErrNoRowsData = errors.New("no rows given")

+ var ErrUnknown = "UNKNOWN"

+ func NewMemoryPartition(partitionDuration time.Duration, precision TimestampPrecision) partition

+ type DataPoint struct

+ Timestamp int64

+ Value float64

+ type Label struct

+ Key string

+ Value string

+ type Option func(*Storage)

+ func WithLogger(logger *logger.Logger) Option

+ func WithPartitionDuration(duration time.Duration) Option

+ func WithRetention(retention time.Duration) Option

+ func WithTimestampPrecision(precision TimestampPrecision) Option

+ func WithWriteTimeout(timeout time.Duration) Option

+ type Reader interface

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

+ type Row struct

+ Labels []Label

+ Name string

+ type Storage struct

+ func (s *Storage) Close() error

+ func (s *Storage) InsertRows(rows []Row) error

+ func (s *Storage) Select(name string, labels []Label, start, end int64) ([]*DataPoint, error)

+ type StorageInterface interface

+ Close func() error

+ InsertRows func(rows []Row) error

+ func NewStorage(opts ...Option) (StorageInterface, error)

+ type TimestampPrecision int

+ const Microseconds

+ const Milliseconds

+ const Nanoseconds

+ const Seconds

+ func (p TimestampPrecision) String() string