db

Documentation

Index

• func SetConfigMongo(host string, port int, dbname string)
• func SetConfigPG(host string, port int, user string, password string, dbname string)
• func SetupMongo(host string, port int, dbname string)
• func SetupPG(host string, port int, user string, password string, dbname string)
• type Metric
  • func MongoQuery(metric string, begin time.Time, end time.Time) ([]Metric, error)
  • func MongoQuerySource(metric string, begin time.Time, end time.Time, source string) ([]Metric, error)
  • func PgQuery(metric string, begin time.Time, end time.Time) ([]Metric, error)
  • func PgQuerySource(metric string, begin time.Time, end time.Time, source string) ([]Metric, error)
  • func Query(metric string, begin time.Time, end time.Time) ([]Metric, error)
  • func QuerySource(metric string, begin time.Time, end time.Time, source string) ([]Metric, error)
• type MongoMetric
• type Tags
  • func (a *Tags) Scan(value interface{}) error
  • func (a Tags) Value() (driver.Value, error)

Functions

func SetConfigMongo

func SetConfigMongo(host string, port int, dbname string)

func SetConfigPG

func SetConfigPG(host string, port int, user string, password string, dbname string)

func SetupMongo

func SetupMongo(host string, port int, dbname string)

func SetupPG

func SetupPG(host string, port int, user string, password string, dbname string)

Types

type Metric

type Metric struct {
	Date   time.Time              `json:"date"`
	Metric string                 `json:"metric"`
	Source string                 `json:"source"`
	Tags   map[string]interface{} `json:"tags"`
	Value  float64                `json:"value"`
}

func MongoQuery

func MongoQuery(metric string, begin time.Time, end time.Time) ([]Metric, error)

func MongoQuerySource

func MongoQuerySource(metric string, begin time.Time, end time.Time, source string) ([]Metric, error)

func PgQuery

func PgQuery(metric string, begin time.Time, end time.Time) ([]Metric, error)

func PgQuerySource

func PgQuerySource(metric string, begin time.Time, end time.Time, source string) ([]Metric, error)

func Query

func Query(metric string, begin time.Time, end time.Time) ([]Metric, error)

func QuerySource

func QuerySource(metric string, begin time.Time, end time.Time, source string) ([]Metric, error)

type MongoMetric

type MongoMetric struct {
	ID     primitive.ObjectID     `bson:"_id,omitempty"`
	Date   time.Time              `bson:"date,omitempty"`
	Metric string                 `bson:"metric,omitempty"`
	Source string                 `bson:"source,omitempty"`
	Tags   map[string]interface{} `bson:"tags,omitempty"`
	Value  float64                `bson:"value,omitempty"`
}

type Tags

type Tags map[string]interface{}

func (*Tags) Scan

func (a *Tags) Scan(value interface{}) error

func (Tags) Value

func (a Tags) Value() (driver.Value, error)