sopdb

type DB interface {
	Index() IndexDB
	Latest() LatestDB
	TS() TSDB
	Close() error
}

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

type IndexDB interface {
	// Query returns the ids of the series that match the given expression.
	Query(expr model.LabelExpr) (ids []int, err error)

	// Make gets the id of the series identified by the given fully-qualified
	// metric. If the series does not exist, it is created and a new id is
	// returned.
	Make(metric model.Metric) (id int, err error)

	// Lookup
	Lookup(id int) (metric model.Metric, err error)

	LookupMetric(metric model.Metric) (id int, err error)

	LabelValues(name string) (values []string, err error)

	// Close the database. No further operations must be attempted.
	Close() error
}

type Iterator interface {
	Seek(t uint64) bool

	At() (t uint64, v float64)

	Next() bool

	Close()
}

type LatestDB interface {
	Put(seriesID int, metric model.Metric, timestamp uint64, value float64) error

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

	Iterate(cb LatestDBProcessorFunc) error

	Close() error
}

type LatestDBProcessorFunc func(seriesID int, metric model.Metric, timestamp uint64,
	value float64) error

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

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

type TSDB interface {
	Put(seriesID int, timestamp uint64, value float64) error

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

	Iterate(seriesID int) Iterator

	Close() error

	DeleteUntil(timestamp uint64) (count int, err error)
}