pointstores

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

type FileAdapter struct {
	Path string
}

type Point struct {
	Labels    map[string]string
	Values    map[string]float32
	TimeStamp int64
}

type PointStore interface {
	// Adds a point to a series, should create it if it doesn't exist (calling AddSeries)
	AddPoint(name string, p Point) error
	// Create a new series
	AddSeries(name string, sample Point, retentionDays int) error
	// Delete a series
	DeleteSeries(name string) error
	Exists(name string) (bool, error)
	GetCount(name string, labels map[string]string) (int, error)
	// Gets the current value of the series
	GetLatest(name string, labels map[string]string) (Point, error)
	GetLastN(name string, labels map[string]string, n int) ([]Point, error)
	// Get list of available series
	ListSeries() ([]types.BriefSeries, error)
}

type QResponse struct {
	Took     int  `json:"took"`
	TimedOut bool `json:"timed_out"`
	Hits     struct {
		Total struct {
			Value    int    `json:"value"`
			Relation string `json:"relation"`
		} `json:"total"`
		Hits []struct {
			Index string `json:"_index"`
			ID    string `json:"_id"`
			P     Point  `json:"_source"`
		} `json:"hits"`
	} `json:"hits"`
}