rdb

package

v0.0.0-...-c1b23f5 Latest Latest Go to latest Published: Oct 3, 2017 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rapidloop/sop

Links

Open Source Insights

Documentation ¶

Index ¶

func NewDB(dir string) (sopdb.DB, error)
type IndexDB
- func OpenIndexDB(dir string) (db *IndexDB, err error)
type Iterator
- func NewIterator(id int, it *gorocksdb.Iterator) *Iterator
type LatestDB
- func OpenLatestDB(dir string) (db *LatestDB, err error)
type TSDB
- func OpenTSDB(dir string) (db *TSDB, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewDB ¶

func NewDB(dir string) (sopdb.DB, error)

Types ¶

type IndexDB ¶

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

func OpenIndexDB ¶

func OpenIndexDB(dir string) (db *IndexDB, err error)

func (*IndexDB) Close ¶

func (db *IndexDB) Close() error

func (*IndexDB) Dump ¶

func (db *IndexDB) Dump() (errors int)

func (*IndexDB) LabelValues ¶

func (db *IndexDB) LabelValues(name string) (values []string, err error)

func (*IndexDB) Lookup ¶

func (db *IndexDB) Lookup(id int) (metric model.Metric, err error)

func (*IndexDB) LookupMetric ¶

func (db *IndexDB) LookupMetric(metric model.Metric) (id int, err error)

func (*IndexDB) Make ¶

func (db *IndexDB) Make(metric model.Metric) (id int, err error)

func (*IndexDB) Query ¶

func (db *IndexDB) Query(expr model.LabelExpr) ([]int, error)

func (*IndexDB) Verify ¶

func (db *IndexDB) Verify() (errors int)

type Iterator ¶

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

func NewIterator ¶

func NewIterator(id int, it *gorocksdb.Iterator) *Iterator

func (*Iterator) At ¶

func (i *Iterator) At() (uint64, float64)

func (*Iterator) Close ¶

func (i *Iterator) Close()

func (*Iterator) Next ¶

func (i *Iterator) Next() bool

func (*Iterator) Seek ¶

func (i *Iterator) Seek(t uint64) bool

type LatestDB ¶

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

func OpenLatestDB ¶

func OpenLatestDB(dir string) (db *LatestDB, err error)

func (*LatestDB) Close ¶

func (db *LatestDB) Close() error

func (*LatestDB) Get ¶

func (db *LatestDB) Get(seriesID int) (metric model.Metric, timestamp uint64,
	value float64, err error)

func (*LatestDB) Iterate ¶

func (db *LatestDB) Iterate(cb sopdb.LatestDBProcessorFunc) error

func (*LatestDB) Put ¶

func (db *LatestDB) Put(seriesID int, metric model.Metric, timestamp uint64,
	value float64) error

type TSDB ¶

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

func OpenTSDB ¶

func OpenTSDB(dir string) (db *TSDB, err error)

func (*TSDB) Close ¶

func (db *TSDB) Close() error

func (*TSDB) DeleteUntil ¶

func (db *TSDB) DeleteUntil(timestamp uint64) (int, error)

DeleteUntil deletes all records that have a timestamp less than the specified one. It probably needs to trigger a compaction after this.

func (*TSDB) Iterate ¶

func (db *TSDB) Iterate(seriesID int) sopdb.Iterator

func (*TSDB) Put ¶

func (db *TSDB) Put(seriesID int, timestamp uint64, value float64) error

func (*TSDB) Query ¶

func (db *TSDB) Query(seriesID int, from, to uint64) (result []model.Sample, err error)

Source Files ¶

View all Source files

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