metricdb

Documentation

Index

• func CheckMetricSelector(s string) (string, bool)
• func CreateSchema(db *sqlx.DB) error
• func NewBatchInserter(db *sqlx.DB, maxBatch int64) (*metricBatchInserter, error)
• func RowsOf(rows *sqlx.Rows, err error) rh
• func SplitMetricKey(s string) (string, string)
• func ValueFromValidSelector(selector, label string) (string, bool)
• func VersionParts(version string) (major, minor, micro int, stream string, t time.Time, pre string, ok bool)
• type DB
  • func New(path string, statusURL url.URL, maxAge time.Duration) (*DB, error)
  • func (d *DB) JobCountsByName() map[string]int64
  • func (d *DB) JobsByName() map[string]int64
  • func (d *DB) MetricsByName() map[string]int64
  • func (d *DB) NewReadConnection() (*sqlx.DB, error)
  • func (d *DB) Run() error
• type Int64Range
  • func (r Int64Range) Includes(v int64) bool
• type OutputMetric

Functions

func CheckMetricSelector

func CheckMetricSelector(s string) (string, bool)

func CreateSchema

func CreateSchema(db *sqlx.DB) error

func NewBatchInserter

func NewBatchInserter(db *sqlx.DB, maxBatch int64) (*metricBatchInserter, error)

func RowsOf

func RowsOf(rows *sqlx.Rows, err error) rh

func SplitMetricKey

func SplitMetricKey(s string) (string, string)

func ValueFromValidSelector

func ValueFromValidSelector(selector, label string) (string, bool)

func VersionParts

func VersionParts(version string) (major, minor, micro int, stream string, t time.Time, pre string, ok bool)

Types

type DB

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

func New

func New(path string, statusURL url.URL, maxAge time.Duration) (*DB, error)

func (*DB) JobCountsByName

func (d *DB) JobCountsByName() map[string]int64

func (*DB) JobsByName

func (d *DB) JobsByName() map[string]int64

func (*DB) MetricsByName

func (d *DB) MetricsByName() map[string]int64

func (*DB) NewReadConnection

func (d *DB) NewReadConnection() (*sqlx.DB, error)

func (*DB) Run

func (d *DB) Run() error

type Int64Range

type Int64Range struct {
	Min int64
	Max int64
}

func (Int64Range) Includes

func (r Int64Range) Includes(v int64) bool

type OutputMetric

type OutputMetric struct {
	Timestamp int64  `json:"timestamp"`
	Value     string `json:"value"`
}