Documentation ¶
Index ¶
- func NewDB(dir string) (sopdb.DB, error)
- type IndexDB
- func (db *IndexDB) Close() error
- func (db *IndexDB) Dump() (errors int)
- func (db *IndexDB) LabelValues(name string) (values []string, err error)
- func (db *IndexDB) Lookup(id int) (metric model.Metric, err error)
- func (db *IndexDB) LookupMetric(metric model.Metric) (id int, err error)
- func (db *IndexDB) Make(metric model.Metric) (id int, err error)
- func (db *IndexDB) Query(expr model.LabelExpr) ([]int, error)
- func (db *IndexDB) Verify() (errors int)
- type Iterator
- type LatestDB
- func (db *LatestDB) Close() error
- func (db *LatestDB) Get(seriesID int) (metric model.Metric, timestamp uint64, value float64, err error)
- func (db *LatestDB) Iterate(cb sopdb.LatestDBProcessorFunc) error
- func (db *LatestDB) Put(seriesID int, metric model.Metric, timestamp uint64, value float64) error
- type TSDB
- func (db *TSDB) Close() error
- func (db *TSDB) DeleteUntil(timestamp uint64) (int, error)
- func (db *TSDB) Iterate(seriesID int) sopdb.Iterator
- func (db *TSDB) Put(seriesID int, timestamp uint64, value float64) error
- func (db *TSDB) Query(seriesID int, from, to uint64) (result []model.Sample, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type IndexDB ¶
type IndexDB struct {
// contains filtered or unexported fields
}
func OpenIndexDB ¶
func (*IndexDB) LabelValues ¶
func (*IndexDB) LookupMetric ¶
type LatestDB ¶
type LatestDB struct {
// contains filtered or unexported fields
}
func OpenLatestDB ¶
type TSDB ¶
type TSDB struct {
// contains filtered or unexported fields
}
func (*TSDB) DeleteUntil ¶
DeleteUntil deletes all records that have a timestamp less than the specified one. It probably needs to trigger a compaction after this.
Click to show internal directories.
Click to hide internal directories.