store

Documentation

Index

• Constants
• func NewStore(d *sql.DB) domain.Store
• type DataPoint
• type Metric
• type MetricTags
• type Store
  • func (s *Store) CreateMetric(m domain.Metric) error
  • func (s *Store) DeleteMetric(name string) error
  • func (s *Store) GetDataSet(dq domain.DataQuery) ([]domain.DataSet, error)
  • func (s *Store) GetMetric(name string) (domain.Metric, error)
  • func (s *Store) SaveDataSet(ds domain.DataSet) error
  • func (s *Store) UpdateMetric(m domain.Metric) error

Constants

const CREATE_SCHEMA_SQL = `` /* 1459-byte string literal not displayed */

const INSERT_DATA_STMT = `INSERT INTO data (time, metric, value, tags) VALUES (?, ?, ?, ?)`

const INSERT_METRIC_STMT = `INSERT INTO meta(name,desc) VALUES(?,?)`

const INSERT_TAG_STMT = `INSERT OR IGNORE INTO tags(metric,tag) VALUES(?,?)`

const SELECT_METRIC_STMT = `SELECT * FROM meta WHERE name = ? LIMIT 1`

Functions

func NewStore

func NewStore(d *sql.DB) domain.Store

Types

type DataPoint

type DataPoint struct {
	Timestamp int64  `db:"time"`
	Metric    string `db:"metric"`
	Value     int64  `db:"value"`
	Tags      string `db:"tags"`
}

type Metric

type Metric struct {
	Name string `db:"name"`
	Desc string `db:"desc,omitempty"`
}

type MetricTags

type MetricTags struct {
	Metric string `db:"metric"`
	Tag    string `db:"tag"`
}

type Store

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

func (*Store) CreateMetric

func (s *Store) CreateMetric(m domain.Metric) error

func (*Store) DeleteMetric

func (s *Store) DeleteMetric(name string) error

func (*Store) GetDataSet

func (s *Store) GetDataSet(dq domain.DataQuery) ([]domain.DataSet, error)

func (*Store) GetMetric

func (s *Store) GetMetric(name string) (domain.Metric, error)

func (*Store) SaveDataSet

func (s *Store) SaveDataSet(ds domain.DataSet) error

func (*Store) UpdateMetric

func (s *Store) UpdateMetric(m domain.Metric) error