store

package

v0.1.3 Latest Latest Go to latest Published: Jul 15, 2024 License: AGPL-3.0 Imports: 35 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gernest/frieren

Links

Open Source Insights

Documentation ¶

Index ¶

func BSI(base Data, columns []uint64, c *rbf.Cursor, exists *rows.Row, shard uint64, ...) error
func Distinct(c *rbf.Cursor, o *roaring32.Bitmap, filters *rows.Row) error
func Hash32(f func(h hash.Hash32)) (o uint32)
func Hash64(data []byte) (o uint64)
type Batch
- func NewBatch() *Batch
- func (b *Batch) Append(ts *prompb.TimeSeries)
- func (b *Batch) Blob(data []byte) uint32
- func (b *Batch) Release()
- func (b *Batch) Reset()
- func (b *Batch) Resize(n int)
- func (b *Batch) Write(f func(w Labels)) (labels []uint32, series uint32)
type DB
- func New(path string) (*DB, error)
- func (db *DB) Close() error
- func (db *DB) Exemplars(min, max int64, matchers ...[]*labels.Matcher) ([]exemplar.QueryResult, error)
- func (db *DB) Get(ids []uint32, f func(pos int, value []byte) error) error
- func (db *DB) Match(w *roaring.Bitmap, matchers ...*labels.Matcher) error
- func (db *DB) Metadata(name string) (result map[string][]metadata.Metadata, err error)
- func (db *DB) Names() (names []string, err error)
- func (db *DB) Save(m pmetric.Metrics) error
- func (db *DB) Select(min, max int64, matchers ...*labels.Matcher) (MapSet, error)
- func (db *DB) Values(name string) (values []string, err error)
type Data
- func NewData(columns []uint64) Data
- func (d Data) Clone() Data
type Ex
type FH
- func NewFH(o *prompb.Histogram) *FH
- func (h *FH) F() float64
- func (h *FH) FH() *histogram.FloatHistogram
- func (h *FH) H() *histogram.Histogram
- func (h *FH) T() int64
- func (h *FH) Type() chunkenc.ValueType
type H
- func NewH(o *prompb.Histogram) *H
- func (h *H) F() float64
- func (h *H) FH() *histogram.FloatHistogram
- func (h *H) H() *histogram.Histogram
- func (h *H) T() int64
- func (h *H) Type() chunkenc.ValueType
type Labels
type LabelsFunc
- func (f LabelsFunc) Write(key, value []byte)
type MapSet
type S
type SeriesSet
- func NewSeriesSet(m MapSet) *SeriesSet
- func (s *SeriesSet) At() storage.Series
- func (s *SeriesSet) Err() error
- func (s *SeriesSet) Next() bool
- func (s *SeriesSet) Warnings() annotations.Annotations
type V
- func (h *V) F() float64
- func (h *V) FH() *histogram.FloatHistogram
- func (h *V) H() *histogram.Histogram
- func (h *V) T() int64
- func (h *V) Type() chunkenc.ValueType
type Value

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BSI ¶

func BSI(base Data, columns []uint64, c *rbf.Cursor, exists *rows.Row, shard uint64, f func(position int, value int64) error) error

func Distinct ¶

func Distinct(c *rbf.Cursor, o *roaring32.Bitmap, filters *rows.Row) error

func Hash32 ¶

func Hash32(f func(h hash.Hash32)) (o uint32)

func Hash64 ¶

func Hash64(data []byte) (o uint64)

Types ¶

type Batch ¶

type Batch struct {
	// contains filtered or unexported fields
}

func NewBatch ¶

func NewBatch() *Batch

func (*Batch) Append ¶

func (b *Batch) Append(ts *prompb.TimeSeries)

func (*Batch) Blob ¶

func (b *Batch) Blob(data []byte) uint32

func (*Batch) Release ¶

func (b *Batch) Release()

func (*Batch) Reset ¶

func (b *Batch) Reset()

func (*Batch) Resize ¶

func (b *Batch) Resize(n int)

func (*Batch) Write ¶

func (b *Batch) Write(f func(w Labels)) (labels []uint32, series uint32)

type DB ¶

type DB struct {
	// contains filtered or unexported fields
}

func New ¶

func New(path string) (*DB, error)

func (*DB) Close ¶

func (db *DB) Close() error

func (*DB) Exemplars ¶

func (db *DB) Exemplars(min, max int64, matchers ...[]*labels.Matcher) ([]exemplar.QueryResult, error)

func (*DB) Get ¶

func (db *DB) Get(ids []uint32, f func(pos int, value []byte) error) error

func (*DB) Match ¶

func (db *DB) Match(w *roaring.Bitmap, matchers ...*labels.Matcher) error

func (*DB) Metadata ¶

func (db *DB) Metadata(name string) (result map[string][]metadata.Metadata, err error)

func (*DB) Names ¶

func (db *DB) Names() (names []string, err error)

func (*DB) Save ¶

func (db *DB) Save(m pmetric.Metrics) error

func (*DB) Select ¶

func (db *DB) Select(min, max int64, matchers ...*labels.Matcher) (MapSet, error)

func (*DB) Values ¶

func (db *DB) Values(name string) (values []string, err error)

type Data ¶

type Data map[uint64]uint64

func NewData ¶

func NewData(columns []uint64) Data

func (Data) Clone ¶

func (d Data) Clone() Data

type Ex ¶

type Ex struct {
	Labels labels.Labels
	Ex     roaring.Bitmap
}

type FH ¶

type FH struct {
	// contains filtered or unexported fields
}

func NewFH ¶

func NewFH(o *prompb.Histogram) *FH

func (*FH) F ¶

func (h *FH) F() float64

func (*FH) FH ¶

func (h *FH) FH() *histogram.FloatHistogram

func (*FH) H ¶

func (h *FH) H() *histogram.Histogram

func (*FH) T ¶

func (h *FH) T() int64

func (*FH) Type ¶

func (h *FH) Type() chunkenc.ValueType

type H ¶

type H struct {
	// contains filtered or unexported fields
}

func NewH ¶

func NewH(o *prompb.Histogram) *H

func (*H) F ¶

func (h *H) F() float64

func (*H) FH ¶

func (h *H) FH() *histogram.FloatHistogram

func (*H) H ¶

func (h *H) H() *histogram.Histogram

func (*H) T ¶

func (h *H) T() int64

func (*H) Type ¶

func (h *H) Type() chunkenc.ValueType

type Labels ¶

type Labels interface {
	Write(key, value []byte)
}

type LabelsFunc ¶

type LabelsFunc func(key, value []byte)

func (LabelsFunc) Write ¶

func (f LabelsFunc) Write(key, value []byte)

type MapSet ¶

type MapSet map[uint64]*S

type S ¶

type S struct {
	Labels  labels.Labels
	Samples []chunks.Sample
}

type SeriesSet ¶

type SeriesSet struct {
	// contains filtered or unexported fields
}

func NewSeriesSet ¶

func NewSeriesSet(m MapSet) *SeriesSet

func (*SeriesSet) At ¶

func (s *SeriesSet) At() storage.Series

func (*SeriesSet) Err ¶

func (s *SeriesSet) Err() error

func (*SeriesSet) Next ¶

func (s *SeriesSet) Next() bool

func (*SeriesSet) Warnings ¶

func (s *SeriesSet) Warnings() annotations.Annotations

type V ¶

type V struct {
	// contains filtered or unexported fields
}

func (*V) F ¶

func (h *V) F() float64

func (*V) FH ¶

func (h *V) FH() *histogram.FloatHistogram

func (*V) H ¶

func (h *V) H() *histogram.Histogram

func (*V) T ¶

func (h *V) T() int64

func (*V) Type ¶

func (h *V) Type() chunkenc.ValueType

type Value ¶

type Value struct {
	// contains filtered or unexported fields
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL