tstorage

Apr 5, 2023

Changes in this version

type Option

+ func WithLogLevel(level log.Level) Option

Mar 20, 2023

Changes in this version

type Option

+ func WithWalRecovery(option WalRecoveryOption) Option

+ type WalRecoveryOption int

+ const AbsoluteConsistency

+ const SkipAnyCorruptedRecord

+ const TolerateCorruptedTailRecords

Feb 27, 2023

Changes in this version

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

+ type DataPoint struct

+ Timestamp int64

+ Value float64

+ type Option func(*storage)

+ func WithDataPath(dataPath string) Option

+ func WithDatabaseMaxSize(databaseMaxSize int64) Option

+ func WithLkoStorage() Option

+ func WithLogger(logger log.Logger) Option

+ func WithMaxPartitions(maxPartitions int64) Option

+ func WithPartitionDuration(duration time.Duration) Option

+ func WithPartitionMaxSize(partitionMaxSize int64) Option

+ func WithRetention(retention time.Duration) Option

+ func WithTimestampPrecision(precision TimestampPrecision) Option

+ func WithWALBufferedSize(size int) Option

+ func WithWriteTimeout(timeout time.Duration) Option

+ func WithoutLkoStorage() Option

+ type Reader interface

+ Poll func(metric uint32) *DataPoint

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

+ type Row struct

+ Metric uint32

+ 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