Versions in this module Expand all Collapse all v0 v0.2.0 Jul 13, 2026 Changes in this version type DB + func (db *DB) Sketches(key string) Sketches + type Sketch struct + func (h Sketch) Count() uint64 + func (h Sketch) Max() float64 + func (h Sketch) Mean() float64 + func (h Sketch) Min() float64 + func (h Sketch) Quantile(q float64) float64 + func (h Sketch) Sum() float64 + type Sketches struct + func (h Sketches) Add(ctx context.Context, at time.Time, value float64) error + func (h Sketches) Compact(ctx context.Context) error + func (h Sketches) Range(ctx context.Context, from, to time.Time, span time.Duration) (iter.Seq2[time.Time, Sketch], error) + func (h Sketches) Values(ctx context.Context, from, to time.Time) (iter.Seq2[time.Time, Sketch], error) v0.1.0 Jun 30, 2026 Changes in this version + func Register(scheme string, open func(*url.URL) (Store, error)) + type Agg uint8 + const Count + const First + const Last + const Max + const Mean + const Min + const Sum + type Counters struct + func (c Counters) Add(ctx context.Context, at time.Time, delta uint64) error + func (c Counters) Compact(ctx context.Context) error + func (c Counters) Range(ctx context.Context, from, to time.Time, span time.Duration, agg Agg) (iter.Seq2[time.Time, float64], error) + func (c Counters) Values(ctx context.Context, from, to time.Time) (iter.Seq2[time.Time, float64], error) + type DB struct + func New(store Store, opts ...Option) (*DB, error) + func Open(uri string, opts ...Option) (*DB, error) + func (db *DB) Close() error + func (db *DB) Counters(key string) Counters + func (db *DB) Flush(ctx context.Context) error + func (db *DB) Samples(key string) Samples + type Option func(*DB) error + func WithCompaction(after, span time.Duration) Option + func WithCompactor(every, jitter time.Duration) Option + func WithFlushEvery(every time.Duration) Option + func WithReplica(id string) Option + type Samples struct + func (s Samples) Compact(ctx context.Context) error + func (s Samples) Range(ctx context.Context, from, to time.Time, span time.Duration, agg Agg) (iter.Seq2[time.Time, float64], error) + func (s Samples) Set(ctx context.Context, at time.Time, value float64) error + func (s Samples) Values(ctx context.Context, from, to time.Time) (iter.Seq2[time.Time, float64], error) + type Store interface + Close func() error + Delete func(context.Context, string) error + Load func(context.Context, string) ([]byte, error) + Update func(context.Context, string, func([]byte) ([]byte, error)) error
Go to main page